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[源代码]¶

此条目有帮助吗？