| :py:mod:`tests.system.providers.apache.beam.utils` |
| ================================================== |
| |
| .. py:module:: tests.system.providers.apache.beam.utils |
| |
| .. autoapi-nested-parse:: |
| |
| Example Utils for Apache Beam operator example DAG's |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| .. py:data:: GCP_PROJECT_ID |
| |
| |
| |
| |
| .. py:data:: GCS_INPUT |
| |
| |
| |
| |
| .. py:data:: GCS_TMP |
| |
| |
| |
| |
| .. py:data:: GCS_STAGING |
| |
| |
| |
| |
| .. py:data:: GCS_OUTPUT |
| |
| |
| |
| |
| .. py:data:: GCS_PYTHON |
| |
| |
| |
| |
| .. py:data:: GCS_PYTHON_DATAFLOW_ASYNC |
| |
| |
| |
| |
| .. py:data:: GCS_GO |
| |
| |
| |
| |
| .. py:data:: GCS_GO_DATAFLOW_ASYNC |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_DIRECT_RUNNER |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_DATAFLOW_RUNNER |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_SPARK_RUNNER |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_FLINK_RUNNER |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_DIRECT_RUNNER_PARTS |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_DIRECT_RUNNER_BUCKET_NAME |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_DIRECT_RUNNER_OBJECT_NAME |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_DATAFLOW_RUNNER_PARTS |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_DATAFLOW_RUNNER_BUCKET_NAME |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_DATAFLOW_RUNNER_OBJECT_NAME |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_SPARK_RUNNER_PARTS |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_SPARK_RUNNER_BUCKET_NAME |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_SPARK_RUNNER_OBJECT_NAME |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_FLINK_RUNNER_PARTS |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_FLINK_RUNNER_BUCKET_NAME |
| |
| |
| |
| |
| .. py:data:: GCS_JAR_FLINK_RUNNER_OBJECT_NAME |
| |
| |
| |
| |
| .. py:data:: DEFAULT_ARGS |
| |
| |
| |
| |
| .. py:data:: START_DATE |
| |
| |
| |
| |
