`tests.system.trino.example_trino`¶

Example DAG using SQLExecuteQueryOperator to connect to Trino.

Module Contents¶

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]¶

Was this entry helpful?