使用 SQLExecuteQueryOperator 连接到 Trino 的示例 DAG。
模块内容
-
tests.system.trino.example_trino.SCHEMA = 'hive.cities'[源代码]
-
tests.system.trino.example_trino.TABLE = 'city'[源代码]
-
tests.system.trino.example_trino.TABLE1 = 'city1'[源代码]
-
tests.system.trino.example_trino.TABLE2 = 'city2'[源代码]
-
tests.system.trino.example_trino.trino_create_schema[源代码]
-
tests.system.trino.example_trino.test_run[源代码]