`tests.system.apache.spark.example_spark_dag`¶

範例 Airflow DAG，用於使用 SparkSubmitOperator、SparkJDBCOperator 和 SparkSqlOperator 提交 Apache Spark 應用程式。

模組內容¶

tests.system.apache.spark.example_spark_dag.ENV_ID[source]¶

tests.system.apache.spark.example_spark_dag.DAG_ID = 'example_spark_operator'[source]¶

tests.system.apache.spark.example_spark_dag.submit_job[source]¶

tests.system.apache.spark.example_spark_dag.test_run[source]¶

這個條目是否有幫助？