这是一个使用 KylinCubeOperator 的示例 DAG。下面的任务包括 kylin 构建、刷新、合并操作。
模块内容
属性
-
tests.system.apache.kylin.example_kylin_dag.ENV_ID[源代码]
-
tests.system.apache.kylin.example_kylin_dag.DAG_ID = 'example_kylin_operator'[源代码]
-
tests.system.apache.kylin.example_kylin_dag.gen_build_time()[源代码]
生成构建时间并推送到 XCom（键为“return_value”） :return: 包含构建时间值的字典。
-
tests.system.apache.kylin.example_kylin_dag.test_run[源代码]