tests.system.apache.beam.utils

Apache Beam 运算符示例 DAG 的实用工具示例

属性

GCP_PROJECT_ID

GCS_INPUT

GCS_TMP

GCS_STAGING

GCS_OUTPUT

GCS_PYTHON

GCS_PYTHON_DATAFLOW_ASYNC

GCS_GO

GCS_GO_DATAFLOW_ASYNC

GCS_JAR_DIRECT_RUNNER

GCS_JAR_DATAFLOW_RUNNER

GCS_JAR_SPARK_RUNNER

GCS_JAR_FLINK_RUNNER

GCS_JAR_DIRECT_RUNNER_PARTS

GCS_JAR_DIRECT_RUNNER_BUCKET_NAME

GCS_JAR_DIRECT_RUNNER_OBJECT_NAME

GCS_JAR_DATAFLOW_RUNNER_PARTS

GCS_JAR_DATAFLOW_RUNNER_BUCKET_NAME

GCS_JAR_DATAFLOW_RUNNER_OBJECT_NAME

GCS_JAR_SPARK_RUNNER_PARTS

GCS_JAR_SPARK_RUNNER_BUCKET_NAME

GCS_JAR_SPARK_RUNNER_OBJECT_NAME

GCS_JAR_FLINK_RUNNER_PARTS

GCS_JAR_FLINK_RUNNER_BUCKET_NAME

GCS_JAR_FLINK_RUNNER_OBJECT_NAME

DEFAULT_ARGS

START_DATE

模块内容

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_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.DEFAULT_ARGS[source]
tests.system.apache.beam.utils.START_DATE[source]

此条目有帮助吗?