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	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.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.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	BEAM_QUERYSTRING_PREFIX	"beam."
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.gcp.datastore.DatastoreV1.Read

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

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"