tests.system.apache.spark.example_spark_dag

使用 SparkSubmitOperatorSparkJDBCOperatorSparkSqlOperator 提交 Apache Spark 应用程序的示例 Airflow DAG。

属性

ENV_ID

DAG_ID

submit_job

test_run

模块内容

tests.system.apache.spark.example_spark_dag.ENV_ID[源]
tests.system.apache.spark.example_spark_dag.DAG_ID = 'example_spark_operator'[源]
tests.system.apache.spark.example_spark_dag.submit_job[源]
tests.system.apache.spark.example_spark_dag.test_run[源]

此条目有帮助吗?