tests.system.apache.kylin.example_kylin_dag

這是一個使用 KylinCubeOperator 的範例 DAG。以下任務包含 kylin 建置、重新整理、合併操作。

模組內容

函式

gen_build_time()

產生建置時間並推送到 XCom (鍵值為 "return_value")

屬性

ENV_ID

DAG_ID

test_run

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]

這個條目有幫助嗎?