tests.system.apache.hive.example_hive
这是一个使用 SQLExecuteQueryOperator 和 Hive 的示例 DAG。
模块内容
-
tests.system.apache.hive.example_hive.DAG_ID = 'example_hive'[源代码]
-
tests.system.apache.hive.example_hive.create_table_hive_task[源代码]
-
tests.system.apache.hive.example_hive.test_run[源代码]