SparkJobEntry Sınıf
Spark işi için giriş.
- Devralma
-
azure.ai.ml.entities._mixins.RestTranslatableMixinSparkJobEntry
Oluşturucu
SparkJobEntry(*, entry: str, type: str = 'SparkJobPythonEntry')
Yalnızca Anahtar Sözcük Parametreleri
Name | Description |
---|---|
entry
|
Dosya veya sınıf giriş noktası. |
type
|
Giriş türü. Kabul edilen değerler SparkJobEntryType.SPARK_JOB_FILE_ENTRY veya SparkJobEntryType.SPARK_JOB_CLASS_ENTRY. Varsayılan olarak SparkJobEntryType.SPARK_JOB_FILE_ENTRY. varsayılan değer: SparkJobPythonEntry
|
Örnekler
SparkComponent oluşturuluyor.
from azure.ai.ml.entities import SparkComponent
component = SparkComponent(
name="add_greeting_column_spark_component",
display_name="Aml Spark add greeting column test module",
description="Aml Spark add greeting column test module",
version="1",
inputs={
"file_input": {"type": "uri_file", "mode": "direct"},
},
driver_cores=2,
driver_memory="1g",
executor_cores=1,
executor_memory="1g",
executor_instances=1,
code="./src",
entry={"file": "add_greeting_column.py"},
py_files=["utils.zip"],
files=["my_files.txt"],
args="--file_input ${{inputs.file_input}}",
base_path="./sdk/ml/azure-ai-ml/tests/test_configs/dsl_pipeline/spark_job_in_pipeline",
)
GitHub'da bizimle işbirliği yapın
Bu içeriğin kaynağı GitHub'da bulunabilir; burada ayrıca sorunları ve çekme isteklerini oluşturup gözden geçirebilirsiniz. Daha fazla bilgi için katkıda bulunan kılavuzumuzu inceleyin.
Azure SDK for Python
Geri Bildirim
https://aka.ms/ContentUserFeedback.
Çok yakında: 2024 boyunca, içerik için geri bildirim mekanizması olarak GitHub Sorunları’nı kullanımdan kaldıracak ve yeni bir geri bildirim sistemiyle değiştireceğiz. Daha fazla bilgi için bkz.Gönderin ve geri bildirimi görüntüleyin