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[源码]