這是一個使用 KylinCubeOperator 的範例 DAG。以下任務包含 kylin 建置、重新整理、合併操作。
模組內容
屬性
-
tests.system.apache.kylin.example_kylin_dag.ENV_ID[source]
-
tests.system.apache.kylin.example_kylin_dag.DAG_ID = 'example_kylin_operator'[source]
-
tests.system.apache.kylin.example_kylin_dag.gen_build_time()[source]
產生建置時間並推送到 XCom (鍵值為 “return_value”) :return: 包含建置時間值的字典。
-
tests.system.apache.kylin.example_kylin_dag.test_run[source]