Apache Beam 運算子範例 DAG 的範例工具
模組內容
-
tests.system.apache.beam.utils.GCP_PROJECT_ID[source]
-
tests.system.apache.beam.utils.GCS_INPUT[source]
-
tests.system.apache.beam.utils.GCS_TMP[source]
-
tests.system.apache.beam.utils.GCS_STAGING[source]
-
tests.system.apache.beam.utils.GCS_OUTPUT[source]
-
tests.system.apache.beam.utils.GCS_PYTHON[source]
-
tests.system.apache.beam.utils.GCS_PYTHON_DATAFLOW_ASYNC[source]
-
tests.system.apache.beam.utils.GCS_GO[source]
-
tests.system.apache.beam.utils.GCS_GO_DATAFLOW_ASYNC[source]
-
tests.system.apache.beam.utils.GCS_JAR_DIRECT_RUNNER[source]
-
tests.system.apache.beam.utils.GCS_JAR_DATAFLOW_RUNNER[source]
-
tests.system.apache.beam.utils.GCS_JAR_SPARK_RUNNER[source]
-
tests.system.apache.beam.utils.GCS_JAR_FLINK_RUNNER[source]
-
tests.system.apache.beam.utils.GCS_JAR_DIRECT_RUNNER_PARTS[source]
-
tests.system.apache.beam.utils.GCS_JAR_DIRECT_RUNNER_BUCKET_NAME[source]
-
tests.system.apache.beam.utils.GCS_JAR_DIRECT_RUNNER_OBJECT_NAME[source]
-
tests.system.apache.beam.utils.GCS_JAR_DATAFLOW_RUNNER_PARTS[source]
-
tests.system.apache.beam.utils.GCS_JAR_DATAFLOW_RUNNER_BUCKET_NAME[source]
-
tests.system.apache.beam.utils.GCS_JAR_DATAFLOW_RUNNER_OBJECT_NAME[source]
-
tests.system.apache.beam.utils.GCS_JAR_SPARK_RUNNER_PARTS[source]
-
tests.system.apache.beam.utils.GCS_JAR_SPARK_RUNNER_BUCKET_NAME[source]
-
tests.system.apache.beam.utils.GCS_JAR_SPARK_RUNNER_OBJECT_NAME[source]
-
tests.system.apache.beam.utils.GCS_JAR_FLINK_RUNNER_PARTS[source]
-
tests.system.apache.beam.utils.GCS_JAR_FLINK_RUNNER_BUCKET_NAME[source]
-
tests.system.apache.beam.utils.GCS_JAR_FLINK_RUNNER_OBJECT_NAME[source]
-
tests.system.apache.beam.utils.DEFAULT_ARGS[source]
-
tests.system.apache.beam.utils.START_DATE[source]