tests.system.apache.druid.example_druid_dag

一个示例 Airflow DAG,用于使用 DruidOperator 提交 Apache Druid json 索引文件

属性

ENV_ID

DAG_ID

submit_job

test_run

模块内容

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

此条目有帮助吗?