Example Airflow DAG for Google Cloud Dataflow service
Module Contents
-
airflow.providers.google.cloud.example_dags.example_dataflow.START_DATE[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.GCS_TMP[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.GCS_STAGING[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.GCS_OUTPUT[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.GCS_JAR[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.GCS_PYTHON[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.GCS_JAR_PARTS[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.GCS_JAR_BUCKET_NAME[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.GCS_JAR_OBJECT_NAME[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.default_args[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.start_java_job[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.start_python_job[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.start_python_job_async[source]
-
airflow.providers.google.cloud.example_dags.example_dataflow.start_template_job[source]
