| :py:mod:`airflow.providers.google.cloud.example_dags.example_dataflow` |
| ====================================================================== |
| |
| .. py:module:: airflow.providers.google.cloud.example_dags.example_dataflow |
| |
| .. autoapi-nested-parse:: |
| |
| Example Airflow DAG for Google Cloud Dataflow service |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| .. py:data:: START_DATE |
| |
| |
| |
| |
| .. py:data:: GCS_TMP |
| |
| |
| |
| |
| .. py:data:: GCS_STAGING |
| |
| |
| |
| |
| .. py:data:: GCS_OUTPUT |
| |
| |
| |
| |
| .. py:data:: GCS_JAR |
| |
| |
| |
| |
| .. py:data:: GCS_PYTHON |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_PARTS |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_BUCKET_NAME |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_OBJECT_NAME |
| |
| |
| |
| |
| .. py:data:: default_args |
| |
| |
| |
| |
| .. py:data:: start_java_job |
| |
| |
| |
| |
| .. py:data:: start_python_job |
| |
| |
| |
| |
| .. py:data:: start_python_job_async |
| |
| |
| |
| |
| .. py:data:: start_template_job |
| |
| |
| |
| |
