tests.system.trino.example_trino

使用 SQLExecuteQueryOperator 連線 Trino 的 DAG 示例。

屬性

SCHEMA

TABLE

TABLE1

TABLE2

trino_create_schema

test_run

模組內容

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[原始碼]

此條目有幫助嗎?