Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.beam.runners.apex.ApexRunner

Modifier and Type	Constant Field	Value
public static final java.lang.String	CLASSPATH_SCHEME	"classpath"

org.apache.beam.runners.dataflow.DataflowRunner

Modifier and Type	Constant Field	Value
public static final java.lang.String	PROJECT_ID_REGEXP	"[a-z][-a-z0-9:.]+[a-z0-9]"

org.apache.beam.runners.dataflow.util.OutputReference

Modifier and Type	Constant Field	Value
public final java.lang.String	type	"OutputReference"

org.apache.beam.runners.dataflow.util.PropertyNames

Modifier and Type	Constant Field	Value
public static final java.lang.String	CO_GBK_RESULT_SCHEMA	"co_gbk_result_schema"
public static final java.lang.String	COMPONENT_ENCODINGS	"component_encodings"
public static final java.lang.String	CUSTOM_SOURCE_FORMAT	"custom_source"
public static final java.lang.String	DISALLOW_COMBINER_LIFTING	"disallow_combiner_lifting"
public static final java.lang.String	DISPLAY_DATA	"display_data"
public static final java.lang.String	ENCODING	"encoding"
public static final java.lang.String	ENVIRONMENT_VERSION_JOB_TYPE_KEY	"job_type"
public static final java.lang.String	ENVIRONMENT_VERSION_MAJOR_KEY	"major"
public static final java.lang.String	FORMAT	"format"
public static final java.lang.String	IMPULSE_ELEMENT	"impulse_element"
public static final java.lang.String	INPUTS	"inputs"
public static final java.lang.String	IS_MERGING_WINDOW_FN	"is_merging_window_fn"
public static final java.lang.String	IS_PAIR_LIKE	"is_pair_like"
public static final java.lang.String	IS_STREAM_LIKE	"is_stream_like"
public static final java.lang.String	IS_WRAPPER	"is_wrapper"
public static final java.lang.String	NON_PARALLEL_INPUTS	"non_parallel_inputs"
public static final java.lang.String	OBJECT_TYPE_NAME	"@type"
public static final java.lang.String	OUTPUT	"output"
public static final java.lang.String	OUTPUT_INFO	"output_info"
public static final java.lang.String	OUTPUT_NAME	"output_name"
public static final java.lang.String	PARALLEL_INPUT	"parallel_input"
public static final java.lang.String	PIPELINE_PROTO_CODER_ID	"pipeline_proto_coder_id"
public static final java.lang.String	PUBSUB_ID_ATTRIBUTE	"pubsub_id_label"
public static final java.lang.String	PUBSUB_SERIALIZED_ATTRIBUTES_FN	"pubsub_serialized_attributes_fn"
public static final java.lang.String	PUBSUB_SUBSCRIPTION	"pubsub_subscription"
public static final java.lang.String	PUBSUB_SUBSCRIPTION_OVERRIDE	"pubsub_subscription_runtime_override"
public static final java.lang.String	PUBSUB_TIMESTAMP_ATTRIBUTE	"pubsub_timestamp_label"
public static final java.lang.String	PUBSUB_TOPIC	"pubsub_topic"
public static final java.lang.String	PUBSUB_TOPIC_OVERRIDE	"pubsub_topic_runtime_override"
public static final java.lang.String	RESTRICTION_CODER	"restriction_coder"
public static final java.lang.String	SCALAR_FIELD_NAME	"value"
public static final java.lang.String	SERIALIZED_FN	"serialized_fn"
public static final java.lang.String	SORT_VALUES	"sort_values"
public static final java.lang.String	SOURCE_DOES_NOT_NEED_SPLITTING	"does_not_need_splitting"
public static final java.lang.String	SOURCE_ESTIMATED_SIZE_BYTES	"estimated_size_bytes"
public static final java.lang.String	SOURCE_IS_INFINITE	"is_infinite"
public static final java.lang.String	SOURCE_METADATA	"metadata"
public static final java.lang.String	SOURCE_SPEC	"spec"
public static final java.lang.String	SOURCE_STEP_INPUT	"custom_source_step_input"
public static final java.lang.String	TUPLE_TAGS	"tuple_tags"
public static final java.lang.String	USE_INDEXED_FORMAT	"use_indexed_format"
public static final java.lang.String	USER_FN	"user_fn"
public static final java.lang.String	USER_NAME	"user_name"
public static final java.lang.String	USES_KEYED_STATE	"uses_keyed_state"
public static final java.lang.String	VALUE	"value"
public static final java.lang.String	WINDOWING_STRATEGY	"windowing_strategy"

org.apache.beam.runners.flink.FlinkPipelineOptions

Modifier and Type	Constant Field	Value
public static final java.lang.String	AUTO	"[auto]"
public static final java.lang.String	PIPELINED	"PIPELINED"

org.apache.beam.runners.flink.metrics.FlinkMetricContainer

Modifier and Type	Constant Field	Value
public static final java.lang.String	ACCUMULATOR_NAME	"__metricscontainers"

org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService

Modifier and Type	Constant Field	Value
public static final java.lang.String	ARTIFACTS	"artifacts"
public static final java.lang.String	MANIFEST	"MANIFEST"

org.apache.beam.runners.spark.io.ConsoleIO.Write.Unbound<T>

Modifier and Type	Constant Field	Value
public static final java.lang.String	TRANSFORM_URN	"beam:transform:spark:consoleio_write_unbound:v1"

org.apache.beam.runners.spark.io.CreateStream<T>

Modifier and Type	Constant Field	Value
public static final java.lang.String	TRANSFORM_URN	"beam:transform:spark:createstream:v1"

org.apache.beam.sdk.extensions.sql.BeamSqlUdf

Modifier and Type	Constant Field	Value
public static final java.lang.String	UDF_METHOD	"eval"

org.apache.beam.sdk.extensions.sql.impl.JdbcDriver

Modifier and Type	Constant Field	Value
public static final java.lang.String	CONNECT_STRING_PREFIX	"jdbc:beam:"

org.apache.beam.sdk.fn.data.BeamFnDataBufferingOutboundObserver<T>

Modifier and Type	Constant Field	Value
public static final java.lang.String	BEAM_FN_API_DATA_BUFFER_LIMIT	"beam_fn_api_data_buffer_limit="

org.apache.beam.sdk.fn.data.RemoteGrpcPortRead

Modifier and Type	Constant Field	Value
public static final java.lang.String	URN	"urn:org.apache.beam:source:runner:0.1"

org.apache.beam.sdk.fn.data.RemoteGrpcPortWrite

Modifier and Type	Constant Field	Value
public static final java.lang.String	URN	"urn:org.apache.beam:sink:runner:0.1"

org.apache.beam.sdk.fn.stream.DataStreams

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_OUTBOUND_BUFFER_LIMIT_BYTES	1000000

org.apache.beam.sdk.io.BoundedSource.BoundedReader<T>

Modifier and Type	Constant Field	Value
public static final long	SPLIT_POINTS_UNKNOWN	-1L

org.apache.beam.sdk.io.DefaultFilenamePolicy

Modifier and Type	Constant Field	Value
public static final java.lang.String	DEFAULT_UNWINDOWED_SHARD_TEMPLATE	"-SSSSS-of-NNNNN"
public static final java.lang.String	DEFAULT_WINDOWED_SHARD_TEMPLATE	"W-P-SSSSS-of-NNNNN"

org.apache.beam.sdk.io.FileSystems

Modifier and Type	Constant Field	Value
public static final java.lang.String	DEFAULT_SCHEME	"file"

org.apache.beam.sdk.io.ShardNameTemplate

Modifier and Type	Constant Field	Value
public static final java.lang.String	DIRECTORY_CONTAINER	"/part-SSSSS"
public static final java.lang.String	INDEX_OF_MAX	"-SSSSS-of-NNNNN"

org.apache.beam.sdk.io.UnboundedSource.UnboundedReader<OutputT>

Modifier and Type	Constant Field	Value
public static final long	BACKLOG_UNKNOWN	-1L

org.apache.beam.sdk.io.aws.options.S3Options.S3UploadBufferSizeBytesFactory

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_UPLOAD_BUFFER_SIZE_BYTES	5242880

org.apache.beam.sdk.io.clickhouse.ClickHouseIO

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_INSERT_BLOCK_SIZE	1000000L
public static final int	DEFAULT_MAX_RETRIES	5

org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read

Modifier and Type	Constant Field	Value
public static final int	NUM_QUERY_SPLITS_MAX	50000

org.apache.beam.sdk.io.hadoop.format.HadoopFormatIO

Modifier and Type	Constant Field	Value
public static final java.lang.String	JOB_ID	"mapreduce.job.id"
public static final java.lang.String	NUM_REDUCES	"mapreduce.job.reduces"
public static final java.lang.String	OUTPUT_DIR	"mapreduce.output.fileoutputformat.outputdir"
public static final java.lang.String	OUTPUT_FORMAT_CLASS_ATTR	"mapreduce.job.outputformat.class"
public static final java.lang.String	OUTPUT_KEY_CLASS	"mapreduce.job.output.key.class"
public static final java.lang.String	OUTPUT_VALUE_CLASS	"mapreduce.job.output.value.class"
public static final java.lang.String	PARTITIONER_CLASS_ATTR	"mapreduce.job.partitioner.class"

org.apache.beam.sdk.io.range.OffsetRangeTracker

Modifier and Type	Constant Field	Value
public static final long	OFFSET_INFINITY	9223372036854775807L

org.apache.beam.sdk.testing.PAssert

Modifier and Type	Constant Field	Value
public static final java.lang.String	FAILURE_COUNTER	"PAssertFailure"
public static final java.lang.String	SUCCESS_COUNTER	"PAssertSuccess"

org.apache.beam.sdk.testing.TestPipeline

Modifier and Type	Constant Field	Value
public static final java.lang.String	PROPERTY_BEAM_TEST_PIPELINE_OPTIONS	"beamTestPipelineOptions"

org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn<T,ComparatorT extends java.util.Comparator<T> & java.io.Serializable>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_MAX_NUM_ELEMENTS	1000000000L

org.apache.beam.sdk.transforms.Materializations

Modifier and Type	Constant Field	Value
public static final java.lang.String	MULTIMAP_MATERIALIZATION_URN	"urn:beam:sideinput:materialization:multimap:0.1"