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[原始碼]

這個條目是否有幫助?