用於 DataprocSubmitJobOperator 的範例 Airflow DAG，搭配 trino 工作。
模組內容
-
tests.system.google.cloud.dataproc.example_dataproc_trino.ENV_ID[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.DAG_ID = 'dataproc_trino'[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.PROJECT_ID[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.CLUSTER_NAME_BASE[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.CLUSTER_NAME_FULL[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.CLUSTER_NAME[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.REGION = 'europe-west1'[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.CLUSTER_CONFIG[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.TRINO_JOB[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.create_cluster[原始碼]
-
tests.system.google.cloud.dataproc.example_dataproc_trino.test_run[原始碼]