SparkJobEntry الفصل
إدخال لوظيفة Spark.
- توريث
-
azure.ai.ml.entities._mixins.RestTranslatableMixinSparkJobEntry
الدالمنشئ
SparkJobEntry(*, entry: str, type: str = 'SparkJobPythonEntry')
معلمات الكلمة الأساسية فقط
الاسم | الوصف |
---|---|
entry
|
نقطة إدخال الملف أو الفئة. |
type
|
نوع الإدخال. القيم المقبولة هي SparkJobEntryType.SPARK_JOB_FILE_ENTRY أو SparkJobEntryType.SPARK_JOB_CLASS_ENTRY. الإعدادات الافتراضية SparkJobEntryType.SPARK_JOB_FILE_ENTRY. القيمة الافتراضية: SparkJobPythonEntry
|
أمثلة
إنشاء SparkComponent.
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
يمكن العثور على مصدر هذا المحتوى على GitHub حيث يمكنك أيضاً إضافة مشاكل وطلبات سحب ومراجعتها. للحصول على معلومات إضافية، اطلع على دليل المساهم لدينا.
Azure SDK for Python
الملاحظات
https://aka.ms/ContentUserFeedback.
قريبًا: خلال عام 2024، سنتخلص تدريجيًا من GitHub Issues بوصفها آلية إرسال ملاحظات للمحتوى ونستبدلها بنظام ملاحظات جديد. لمزيد من المعلومات، راجعإرسال الملاحظات وعرضها المتعلقة بـ