使用 SQLExecuteQueryOperator 連接到 Trino 的範例 DAG。
模組內容
-
tests.system.trino.example_trino.SCHEMA = 'hive.cities'[source]
-
tests.system.trino.example_trino.TABLE = 'city'[source]
-
tests.system.trino.example_trino.TABLE1 = 'city1'[source]
-
tests.system.trino.example_trino.TABLE2 = 'city2'[source]
-
tests.system.trino.example_trino.trino_create_schema[source]
-
tests.system.trino.example_trino.test_run[source]