tests.system.apache.drill.example_drill_dag

Example Airflow DAG to execute SQL in an Apache Drill environment using the DrillOperator.

Module Contents

tests.system.apache.drill.example_drill_dag.ENV_ID[source]
tests.system.apache.drill.example_drill_dag.DAG_ID = 'example_drill_dag'[source]
tests.system.apache.drill.example_drill_dag.sql_task[source]
tests.system.apache.drill.example_drill_dag.test_run[source]

Was this entry helpful?