`tests.system.apache.druid.example_druid_dag`¶

示例 Airflow DAG，使用 DruidOperator 提交 Apache Druid json 索引文件

模块内容¶

tests.system.apache.druid.example_druid_dag.ENV_ID[源代码]¶

tests.system.apache.druid.example_druid_dag.DAG_ID = 'example_druid_operator'[源代码]¶

tests.system.apache.druid.example_druid_dag.submit_job[源代码]¶

tests.system.apache.druid.example_druid_dag.test_run[源代码]¶

此条目是否有帮助？