Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.beam.io.debezium.DebeziumTransformRegistrar

Modifier and Type	Constant Field	Value
public static final String	READ_JSON_URN	"beam:transform:org.apache.beam:debezium_read:v1"

org.apache.beam.io.debezium.KafkaSourceConsumerFn<T>

Modifier and Type	Constant Field	Value
public static final String	BEAM_INSTANCE_PROPERTY	"beam.parent.instance"

org.apache.beam.runners.dataflow.DataflowRunner

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

org.apache.beam.runners.dataflow.internal.IsmFormat

Modifier and Type	Constant Field	Value
public static final int	SHARD_BITS	127

org.apache.beam.runners.dataflow.internal.IsmFormat.Footer

Modifier and Type	Constant Field	Value
public static final int	FIXED_LENGTH	25
public static final int	LONG_BYTES	8
public static final byte	VERSION	0x2

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

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

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

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

org.apache.beam.runners.flink.FlinkPipelineOptions

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

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

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

org.apache.beam.runners.flink.translation.wrappers.streaming.io.source.unbounded.FlinkUnboundedSourceReader<T>

Modifier and Type	Constant Field	Value
protected static final String	PENDING_BYTES_METRIC_NAME	"pendingBytes"

org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_BUFFER_SIZE	2097152
public static final String	EMBEDDED_ARTIFACT_URN	"beam:artifact:type:embedded:v1"
public static final String	FILE_ARTIFACT_URN	"beam:artifact:type:file:v1"
public static final String	STAGING_TO_ARTIFACT_URN	"beam:artifact:role:staging_to:v1"
public static final String	URL_ARTIFACT_URN	"beam:artifact:type:url:v1"

org.apache.beam.runners.fnexecution.control.BundleCheckpointHandlers.StateAndTimerBundleCheckpointHandler<T>

Modifier and Type	Constant Field	Value
public static final String	SDF_PREFIX	"sdf_checkpoint"

org.apache.beam.runners.jobsubmission.InMemoryJobService

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_INVOCATION_HISTORY	10

org.apache.beam.runners.prism.PrismPipelineOptions

Modifier and Type	Constant Field	Value
public static final String	JOB_PORT_FLAG_NAME	"job_port"

org.apache.beam.runners.spark.SparkCommonPipelineOptions

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_MASTER_URL	"local[4]"

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

Modifier and Type	Constant Field	Value
public static final 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 String	TRANSFORM_URN	"beam:transform:spark:createstream:v1"

org.apache.beam.runners.spark.translation.SparkContextFactory

Modifier and Type	Constant Field	Value
public static final String	TEST_REUSE_SPARK_CONTEXT	"beam.spark.test.reuseSparkContext"

org.apache.beam.runners.spark.translation.streaming.CreateStreamingSparkView<ElemT,ViewT>

Modifier and Type	Constant Field	Value
public static final String	CREATE_STREAMING_SPARK_VIEW_URN	"beam:transform:spark:create-streaming-spark-view:v1"

org.apache.beam.sdk.expansion.service.WindowIntoTransformProvider

Modifier and Type	Constant Field	Value
protected static final String	OUTPUT_ROWS_TAG	"output"

org.apache.beam.sdk.extensions.avro.AvroGenericCoderRegistrar

Modifier and Type	Constant Field	Value
public static final String	AVRO_CODER_URN	"beam:coder:avro:generic:v1"

org.apache.beam.sdk.extensions.gcp.options.GcpOptions

Modifier and Type	Constant Field	Value
public static final String	STREAMING_ENGINE_EXPERIMENT	"enable_streaming_engine"
public static final String	WINDMILL_SERVICE_EXPERIMENT	"enable_windmill_service"

org.apache.beam.sdk.extensions.gcp.util.gcsfs.GcsPath

Modifier and Type	Constant Field	Value
public static final String	SCHEME	"gs"

org.apache.beam.sdk.extensions.kafka.factories.FileAwareFactoryFn<T>

Modifier and Type	Constant Field	Value
public static final String	DIRECTORY_PREFIX	"/tmp"
public static final String	SECRET_VALUE_PREFIX	"secretValue:"

org.apache.beam.sdk.extensions.ordered.OrderedEventProcessor<EventT,EventKeyT,ResultT,StateT>

Modifier and Type	Constant Field	Value
public static final String	GLOBAL_SEQUENCE_TRACKER	"global_sequence_tracker"

org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler<EventT,KeyT,StateT,ResultT>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_ELEMENTS_TO_OUTPUT	10000

org.apache.beam.sdk.extensions.protobuf.DynamicProtoCoder

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

org.apache.beam.sdk.extensions.protobuf.ProtoCoder<T>

Modifier and Type	Constant Field	Value
public static final long	serialVersionUID	-5043999806040629525L

org.apache.beam.sdk.extensions.protobuf.ProtoDomain

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

org.apache.beam.sdk.extensions.protobuf.ProtoDynamicMessageSchema<T>

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

org.apache.beam.sdk.extensions.protobuf.ProtoSchemaLogicalTypes.Fixed32

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"Fixed32"

org.apache.beam.sdk.extensions.protobuf.ProtoSchemaLogicalTypes.Fixed64

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"Fixed64"

org.apache.beam.sdk.extensions.protobuf.ProtoSchemaLogicalTypes.SFixed32

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"SFixed32"

org.apache.beam.sdk.extensions.protobuf.ProtoSchemaLogicalTypes.SFixed64

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"SFixed64"

org.apache.beam.sdk.extensions.protobuf.ProtoSchemaLogicalTypes.SInt32

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"Sint32"

org.apache.beam.sdk.extensions.protobuf.ProtoSchemaLogicalTypes.SInt64

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"Sint64"

org.apache.beam.sdk.extensions.protobuf.ProtoSchemaLogicalTypes.UInt32

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"Uint32"

org.apache.beam.sdk.extensions.protobuf.ProtoSchemaLogicalTypes.UInt64

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"Uint64"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.LocalMktDate

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"LocalMktDate"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.TZTimeOnly

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"TZTimeOnly"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.TZTimestamp

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"TZTimestamp"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.Uint16

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"uint16"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.Uint32

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"uint32"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.Uint64

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"uint64"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.Uint8

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"uint8"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.UTCDateOnly

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"UTCDateOnly"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.UTCTimeOnly

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"UTCTimeOnly"

org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.UTCTimestamp

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"UTCTimestamp"

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

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

org.apache.beam.sdk.extensions.sql.SqlTransform

Modifier and Type	Constant Field	Value
public static final String	PCOLLECTION_NAME	"PCOLLECTION"

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

Modifier and Type	Constant Field	Value
public static final String	BEAMSYSTEM	"beamsystem"

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

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

org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSourceRel

Modifier and Type	Constant Field	Value
public static final double	CONSTANT_WINDOW_SIZE	10.0

org.apache.beam.sdk.extensions.sql.impl.rel.BeamSqlRelUtils

Modifier and Type	Constant Field	Value
public static final String	ERROR	"error"
public static final String	ROW	"row"

org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.TimeWithLocalTzType

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"SqlTimeWithLocalTzType"

org.apache.beam.sdk.extensions.sql.impl.utils.TVFStreamingUtils

Modifier and Type	Constant Field	Value
public static final String	FIXED_WINDOW_TVF	"TUMBLE"
public static final String	SESSION_WINDOW_TVF	"SESSION"
public static final String	SLIDING_WINDOW_TVF	"HOP"
public static final String	WINDOW_END	"window_end"
public static final String	WINDOW_START	"window_start"

org.apache.beam.sdk.extensions.sql.meta.catalog.Catalog

Modifier and Type	Constant Field	Value
public static final String	DEFAULT	"default"

org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BeamBigQuerySqlDialect

Modifier and Type	Constant Field	Value
public static final String	DOUBLE_NAN_WRAPPER	"double_nan"
public static final String	DOUBLE_NEGATIVE_INF_WRAPPER	"double_negative_inf"
public static final String	DOUBLE_POSITIVE_INF_WRAPPER	"double_positive_inf"
public static final String	IN_ARRAY_OPERATOR	"$in_array"
public static final String	NUMERIC_LITERAL_WRAPPER	"numeric_literal"

org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableProvider

Modifier and Type	Constant Field	Value
public static final String	PUSH_DOWN_OPTION	"push_down"

org.apache.beam.sdk.extensions.zetasketch.HllCount

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PRECISION	15
public static final int	MAXIMUM_PRECISION	24
public static final int	MINIMUM_PRECISION	10

org.apache.beam.sdk.fn.data.BeamFnDataOutboundAggregator

Modifier and Type	Constant Field	Value
public static final String	DATA_BUFFER_SIZE_LIMIT	"data_buffer_size_limit="
public static final String	DATA_BUFFER_TIME_LIMIT_MS	"data_buffer_time_limit_ms="
public static final int	DEFAULT_BUFFER_LIMIT_BYTES	1000000
public static final long	DEFAULT_BUFFER_LIMIT_TIME_MS	-1L

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

Modifier and Type	Constant Field	Value
public static final String	URN	"beam:runner:source:v1"

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

Modifier and Type	Constant Field	Value
public static final String	URN	"beam:runner:sink:v1"

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.ClassLoaderFileSystem

Modifier and Type	Constant Field	Value
public static final String	SCHEMA	"classpath"

org.apache.beam.sdk.io.DefaultFilenamePolicy

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_UNWINDOWED_SHARD_TEMPLATE	"-SSSSS-of-NNNNN"
public static final 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 String	DEFAULT_SCHEME	"file"

org.apache.beam.sdk.io.GenerateSequence.External

Modifier and Type	Constant Field	Value
public static final String	URN	"beam:external:java:generate_sequence:v1"

org.apache.beam.sdk.io.ReadAllViaFileBasedSourceTransform<InT,T>

Modifier and Type	Constant Field	Value
public static final boolean	DEFAULT_USES_RESHUFFLE	true

org.apache.beam.sdk.io.ShardNameTemplate

Modifier and Type	Constant Field	Value
public static final String	DIRECTORY_CONTAINER	"/part-SSSSS"
public static final 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.WriteFiles<UserT,DestinationT,OutputT>

Modifier and Type	Constant Field	Value
public static final int	FILE_TRIGGERING_BYTE_COUNT	67108864
public static final int	FILE_TRIGGERING_RECORD_COUNT	100000

org.apache.beam.sdk.io.aws2.kinesis.KinesisTransformRegistrar

Modifier and Type	Constant Field	Value
public static final String	READ_DATA_URN	"beam:transform:org.apache.beam:kinesis_read_data:v2"
public static final String	WRITE_URN	"beam:transform:org.apache.beam:kinesis_write:v2"

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

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_UPLOAD_BUFFER_SIZE_BYTES	67108864
public static final int	MINIMUM_UPLOAD_BUFFER_SIZE_BYTES	5242880
public static final int	REQUIRED_MEMORY_FOR_DEFAULT_BUFFER_BYTES	536870912

org.apache.beam.sdk.io.aws2.s3.S3FileSystemConfiguration

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

org.apache.beam.sdk.io.aws2.sqs.providers.SqsReadSchemaTransformProvider

Modifier and Type	Constant Field	Value
public static final String	OUTPUT_TAG	"output"

org.apache.beam.sdk.io.cdap.context.BatchContextImpl

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_SCHEMA_FIELD_NAME	"Name"
public static final String	DEFAULT_SCHEMA_RECORD_NAME	"Record"

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.contextualtextio.RecordWithMetadata

Modifier and Type	Constant Field	Value
public static final String	RANGE_OFFSET	"rangeOffset"
public static final String	RECORD_NUM	"recordNum"
public static final String	RECORD_NUM_IN_OFFSET	"recordNumInOffset"
public static final String	RECORD_OFFSET	"recordOffset"
public static final String	RESOURCE_ID	"resourceId"
public static final String	VALUE	"value"

org.apache.beam.sdk.io.datadog.DatadogEventPublisher

Modifier and Type	Constant Field	Value
protected static final String	DD_URL_PATH	"api/v2/logs"

org.apache.beam.sdk.io.datadog.DatadogEventWriter

Modifier and Type	Constant Field	Value
protected static final String	INVALID_URL_FORMAT_MESSAGE	"Invalid url format. Url format should match PROTOCOL://HOST[:PORT], where PORT is optional. Supported Protocols are http and https. eg: http://hostname:8088"

org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO

Modifier and Type	Constant Field	Value
public static final String	BIGQUERY_JOB_TEMPLATE	"beam_bq_job_{TYPE}_{JOB_ID}_{STEP}_{RANDOM}"

org.apache.beam.sdk.io.gcp.bigquery.BigQuerySinkMetrics

Modifier and Type	Constant Field	Value
public static final String	METRICS_NAMESPACE	"BigQuerySink"
public static final String	PAYLOAD_TOO_LARGE	"PayloadTooLarge"
public static final String	THROTTLED_TIME	"ThrottledTime"

org.apache.beam.sdk.io.gcp.bigquery.StorageApiCDC

Modifier and Type	Constant Field	Value
public static final String	CHANGE_SQN_COLUMN	"_CHANGE_SEQUENCE_NUMBER"
public static final String	CHANGE_TYPE_COLUMN	"_CHANGE_TYPE"

org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions

Modifier and Type	Constant Field	Value
public static final String	BIGQUERY_EARLY_ROLLOUT_REGION	"us-east7"

org.apache.beam.sdk.io.gcp.bigquery.providers.BigQueryDirectReadSchemaTransformProvider

Modifier and Type	Constant Field	Value
public static final String	OUTPUT_TAG	"output"

org.apache.beam.sdk.io.gcp.bigquery.providers.BigQueryStorageWriteApiSchemaTransformProvider

Modifier and Type	Constant Field	Value
protected static final String	DYNAMIC_DESTINATIONS	"DYNAMIC_DESTINATIONS"
protected static final String	ROW_PROPERTY_MUTATION_INFO	"row_mutation_info"
protected static final String	ROW_PROPERTY_MUTATION_SQN	"change_sequence_number"
protected static final String	ROW_PROPERTY_MUTATION_TYPE	"mutation_type"

org.apache.beam.sdk.io.gcp.bigquery.providers.BigQueryWriteConfiguration

Modifier and Type	Constant Field	Value
protected static final String	DYNAMIC_DESTINATIONS	"DYNAMIC_DESTINATIONS"

org.apache.beam.sdk.io.gcp.bigquery.providers.PortableBigQueryDestinations

Modifier and Type	Constant Field	Value
public static final String	DESTINATION	"destination"
public static final String	RECORD	"record"

org.apache.beam.sdk.io.gcp.bigtable.RowUtils

Modifier and Type	Constant Field	Value
public static final String	COLUMNS_MAPPING	"columnsMapping"
public static final String	KEY	"key"
public static final String	LABELS	"labels"
public static final String	TIMESTAMP_MICROS	"timestampMicros"
public static final String	VALUE	"val"

org.apache.beam.sdk.io.gcp.bigtable.changestreams.dao.MetadataTableAdminDao

Modifier and Type	Constant Field	Value
public static final String	CF_CONTINUATION_TOKEN	"continuation_token"
public static final String	CF_INITIAL_TOKEN	"initial_continuation_token"
public static final String	CF_LOCK	"lock"
public static final String	CF_MISSING_PARTITIONS	"missing_partitions"
public static final String	CF_PARENT_LOW_WATERMARKS	"parent_low_watermarks"
public static final String	CF_PARENT_PARTITIONS	"parent_partitions"
public static final String	CF_SHOULD_DELETE	"should_delete"
public static final String	CF_VERSION	"version"
public static final String	CF_WATERMARK	"watermark"
public static final int	CURRENT_METADATA_TABLE_VERSION	1
public static final String	DEFAULT_METADATA_TABLE_NAME	"__change_stream_md_table"
public static final String	QUALIFIER_DEFAULT	"latest"

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.gcp.datastore.DataStoreV1SchemaIOProvider

Modifier and Type	Constant Field	Value
public static final String	KEY_FIELD_PROPERTY	"keyField"

org.apache.beam.sdk.io.gcp.healthcare.HealthcareIOErrorToTableRow<T>

Modifier and Type	Constant Field	Value
public static final String	TIMESTAMP_FIELD_NAME	"observed_time"

org.apache.beam.sdk.io.gcp.pubsub.ExternalRead

Modifier and Type	Constant Field	Value
public static final String	URN	"beam:transform:org.apache.beam:pubsub_read:v1"

org.apache.beam.sdk.io.gcp.pubsub.ExternalWrite

Modifier and Type	Constant Field	Value
public static final String	URN	"beam:transform:org.apache.beam:pubsub_write:v1"

org.apache.beam.sdk.io.gcp.pubsub.PubsubIO

Modifier and Type	Constant Field	Value
public static final String	ENABLE_CUSTOM_PUBSUB_SINK	"enable_custom_pubsub_sink"
public static final String	ENABLE_CUSTOM_PUBSUB_SOURCE	"enable_custom_pubsub_source"

org.apache.beam.sdk.io.gcp.pubsub.PubsubReadSchemaTransformProvider

Modifier and Type	Constant Field	Value
public static final String	VALID_FORMATS_STR	"RAW,AVRO,JSON"

org.apache.beam.sdk.io.gcp.pubsub.PubsubWriteSchemaTransformProvider

Modifier and Type	Constant Field	Value
public static final String	VALID_FORMATS_STR	"RAW,AVRO,JSON"

org.apache.beam.sdk.io.gcp.spanner.SpannerAccessor

Modifier and Type	Constant Field	Value
public static final String	EXPERIMENTAL_HOST_INSTANCE_ID	"default"

org.apache.beam.sdk.io.gcp.spanner.SpannerTransformRegistrar

Modifier and Type	Constant Field	Value
public static final String	DELETE_URN	"beam:transform:org.apache.beam:spanner_delete:v1"
public static final String	INSERT_OR_UPDATE_URN	"beam:transform:org.apache.beam:spanner_insert_or_update:v1"
public static final String	INSERT_URN	"beam:transform:org.apache.beam:spanner_insert:v1"
public static final String	READ_CHANGE_STREAM_URN	"beam:transform:org.apache.beam:spanner_change_stream_reader:v1"
public static final String	READ_URN	"beam:transform:org.apache.beam:spanner_read:v1"
public static final String	REPLACE_URN	"beam:transform:org.apache.beam:spanner_replace:v1"
public static final String	UPDATE_URN	"beam:transform:org.apache.beam:spanner_update:v1"

org.apache.beam.sdk.io.gcp.spanner.changestreams.ChangeStreamsConstants

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_CHANGE_STREAM_NAME	""
public static final int	DEFAULT_HEARTBEAT_MILLIS	2000
public static final int	LOW_LATENCY_DEFAULT_HEARTBEAT_MILLIS	100
public static final int	THROUGHPUT_WINDOW_SECONDS	10

org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao

Modifier and Type	Constant Field	Value
public static final String	COLUMN_CREATED_AT	"CreatedAt"
public static final String	COLUMN_END_TIMESTAMP	"EndTimestamp"
public static final String	COLUMN_FINISHED_AT	"FinishedAt"
public static final String	COLUMN_HEARTBEAT_MILLIS	"HeartbeatMillis"
public static final String	COLUMN_PARENT_TOKENS	"ParentTokens"
public static final String	COLUMN_PARTITION_TOKEN	"PartitionToken"
public static final String	COLUMN_RUNNING_AT	"RunningAt"
public static final String	COLUMN_SCHEDULED_AT	"ScheduledAt"
public static final String	COLUMN_START_TIMESTAMP	"StartTimestamp"
public static final String	COLUMN_STATE	"State"
public static final String	COLUMN_WATERMARK	"Watermark"

org.apache.beam.sdk.io.gcp.spanner.changestreams.model.InitialPartition

Modifier and Type	Constant Field	Value
public static final String	PARTITION_TOKEN	"Parent0"

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

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

org.apache.beam.sdk.io.jdbc.JdbcUtil

Modifier and Type	Constant Field	Value
public static final String	MSSQL	"mssql"
public static final String	MYSQL	"mysql"
public static final String	ORACLE	"oracle"
public static final String	POSTGRES	"postgres"

org.apache.beam.sdk.io.kafka.KafkaIO.Read.External

Modifier and Type	Constant Field	Value
public static final String	URN_WITH_METADATA	"beam:transform:org.apache.beam:kafka_read_with_metadata:v1"
public static final String	URN_WITHOUT_METADATA	"beam:transform:org.apache.beam:kafka_read_without_metadata:v1"

org.apache.beam.sdk.io.kafka.KafkaIO.Write.External

Modifier and Type	Constant Field	Value
public static final String	URN	"beam:transform:org.apache.beam:kafka_write:v1"
public static final String	URN_WITH_HEADERS	"beam:transform:org.apache.beam:kafka_write_with_headers:v1"

org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformConfiguration

Modifier and Type	Constant Field	Value
public static final String	VALID_FORMATS_STR	"RAW,STRING,AVRO,JSON,PROTO"

org.apache.beam.sdk.io.kafka.KafkaSinkMetrics

Modifier and Type	Constant Field	Value
public static final String	METRICS_NAMESPACE	"KafkaSink"

org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProvider

Modifier and Type	Constant Field	Value
public static final String	SUPPORTED_FORMATS_STR	"RAW,JSON,AVRO,PROTO"

org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslation

Modifier and Type	Constant Field	Value
public static final String	KAFKA_READ_WITH_METADATA_TRANSFORM_URN_V2	"beam:transform:org.apache.beam:kafka_read_with_metadata:v2"
public static final String	KAFKA_WRITE_TRANSFORM_URN_V2	"beam:transform:org.apache.beam:kafka_write:v2"

org.apache.beam.sdk.io.mongodb.MongoDbIO

Modifier and Type	Constant Field	Value
public static final String	ERROR_MSG_QUERY_FN	" class is not supported. Please provide one of the predefined classes in the MongoDbIO package such as FindQuery or AggregationQuery."

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

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

org.apache.beam.sdk.io.singlestore.schematransform.SingleStoreSchemaTransformWriteProvider

Modifier and Type	Constant Field	Value
public static final String	INPUT_TAG	"INPUT"

org.apache.beam.sdk.io.snowflake.SnowflakePipelineOptions

Modifier and Type	Constant Field	Value
public static final String	AUTH_VALIDATION_GROUP	"AUTH_VALIDATION_GROUP"
public static final String	BASIC_CONNECTION_INFO_VALIDATION_GROUP	"BASIC_CONNECTION_INFO_GROUP"

org.apache.beam.sdk.io.snowflake.crosslanguage.SnowflakeTransformRegistrar

Modifier and Type	Constant Field	Value
public static final String	READ_URN	"beam:transform:org.apache.beam:snowflake_read:v1"
public static final String	WRITE_URN	"beam:transform:org.apache.beam:snowflake_write:v1"

org.apache.beam.sdk.io.solace.SolaceIO

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_WRITER_CLIENTS_PER_WORKER	4
public static final int	DEFAULT_WRITER_NUM_SHARDS	20

org.apache.beam.sdk.io.solace.broker.SessionService

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_VPN_NAME	"default"

org.apache.beam.sdk.io.solace.broker.SolaceMessageReceiver

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_ADVANCE_TIMEOUT_IN_MILLIS	100

org.apache.beam.sdk.managed.Managed

Modifier and Type	Constant Field	Value
public static final String	BIGQUERY	"bigquery"
public static final String	ICEBERG	"iceberg"
public static final String	ICEBERG_CDC	"iceberg_cdc"
public static final String	KAFKA	"kafka"
public static final String	MYSQL	"mysql"
public static final String	POSTGRES	"postgres"
public static final String	SQL_SERVER	"sqlserver"

org.apache.beam.sdk.managed.Managed.ManagedTransform

Modifier and Type	Constant Field	Value
public static final String	INPUT	"input"

org.apache.beam.sdk.metrics.Lineage

Modifier and Type	Constant Field	Value
public static final String	LINEAGE_NAMESPACE	"lineage"

org.apache.beam.sdk.metrics.Metrics

Modifier and Type	Constant Field	Value
public static final String	THROTTLE_TIME_COUNTER_NAME	"throttling-msecs"
public static final String	THROTTLE_TIME_NAMESPACE	"beam-throttling-metrics"

org.apache.beam.sdk.options.ExperimentalOptions

Modifier and Type	Constant Field	Value
public static final String	STATE_CACHE_SIZE	"state_cache_size"
public static final String	STATE_SAMPLING_PERIOD_MILLIS	"state_sampling_period_millis"

org.apache.beam.sdk.providers.GenerateSequenceSchemaTransformProvider

Modifier and Type	Constant Field	Value
public static final String	OUTPUT_ROWS_TAG	"output"

org.apache.beam.sdk.schemas.io.payloads.PayloadSerializer

Modifier and Type	Constant Field	Value
public static final long	serialVersionUID	5645783967169L

org.apache.beam.sdk.schemas.logicaltypes.DateTime

Modifier and Type	Constant Field	Value
public static final String	DATE_FIELD_NAME	"Date"
public static final String	IDENTIFIER	"beam:logical_type:datetime:v1"
public static final String	TIME_FIELD_NAME	"Time"

org.apache.beam.sdk.schemas.logicaltypes.EnumerationType

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"Enum"

org.apache.beam.sdk.schemas.logicaltypes.FixedPrecisionNumeric

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"beam:logical_type:fixed_decimal:v1"

org.apache.beam.sdk.schemas.logicaltypes.NanosDuration

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"beam:logical_type:nanos_duration:v1"

org.apache.beam.sdk.schemas.logicaltypes.NanosInstant

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"beam:logical_type:nanos_instant:v1"

org.apache.beam.sdk.schemas.logicaltypes.OneOfType

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"OneOf"

org.apache.beam.sdk.schemas.logicaltypes.SchemaLogicalType

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"beam:logical_type:schema:v1"

org.apache.beam.sdk.schemas.logicaltypes.Time

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"beam:logical_type:time:v1"

org.apache.beam.sdk.schemas.logicaltypes.Timestamp

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"beam:logical_type:timestamp:v1"

org.apache.beam.sdk.schemas.logicaltypes.UuidLogicalType

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"beam:logical_type:uuid:v1"
public static final String	LEAST_SIGNIFICANT_BITS_FIELD_NAME	"LeastSignificantBits"
public static final String	MOST_SIGNIFICANT_BITS_FIELD_NAME	"MostSignificantBits"

org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationLexer

Modifier and Type	Constant Field	Value
public static final String	_serializedATN	"\u0003\u608b\ua72a\u8133\ub9ed\u417c\u3be7\u7786\u5964\u0002\n1\b\u0001\u0004\u0002\t\u0002\u0004\u0003\t\u0003\u0004\u0004\t\u0004\u0004\u0005\t\u0005\u0004\u0006\t\u0006\u0004\u0007\t\u0007\u0004\b\t\b\u0004\t\t\t\u0003\u0002\u0003\u0002\u0003\u0003\u0003\u0003\u0003\u0003\u0003\u0004\u0003\u0004\u0003\u0004\u0003\u0004\u0003\u0005\u0003\u0005\u0003\u0005\u0003\u0006\u0003\u0006\u0003\u0006\u0003\u0006\u0003\u0007\u0006\u0007%\n\u0007\r\u0007\u000e\u0007&\u0003\b\u0003\b\u0003\t\u0006\t,\n\t\r\t\u000e\t-\u0003\t\u0003\t\u0002\u0002\n\u0003\u0003\u0005\u0004\u0007\u0005\t\u0006\u000b\u0007\r\b\u000f\t\u0011\n\u0003\u0002\u0004\u0007\u0002&&2;C\\aac|\u0005\u0002\u000b\f\u000f\u000f\"\"\u00022\u0002\u0003\u0003\u0002\u0002\u0002\u0002\u0005\u0003\u0002\u0002\u0002\u0002\u0007\u0003\u0002\u0002\u0002\u0002\t\u0003\u0002\u0002\u0002\u0002\u000b\u0003\u0002\u0002\u0002\u0002\r\u0003\u0002\u0002\u0002\u0002\u000f\u0003\u0002\u0002\u0002\u0002\u0011\u0003\u0002\u0002\u0002\u0003\u0013\u0003\u0002\u0002\u0002\u0005\u0015\u0003\u0002\u0002\u0002\u0007\u0018\u0003\u0002\u0002\u0002\t\u001c\u0003\u0002\u0002\u0002\u000b\u001f\u0003\u0002\u0002\u0002\r$\u0003\u0002\u0002\u0002\u000f(\u0003\u0002\u0002\u0002\u0011+\u0003\u0002\u0002\u0002\u0013\u0014\u00070\u0002\u0002\u0014\u0004\u0003\u0002\u0002\u0002\u0015\u0016\u0007]\u0002\u0002\u0016\u0017\u0007_\u0002\u0002\u0017\u0006\u0003\u0002\u0002\u0002\u0018\u0019\u0007]\u0002\u0002\u0019\u001a\u0007,\u0002\u0002\u001a\u001b\u0007_\u0002\u0002\u001b\b\u0003\u0002\u0002\u0002\u001c\u001d\u0007}\u0002\u0002\u001d\u001e\u0007\u007f\u0002\u0002\u001e\n\u0003\u0002\u0002\u0002\u001f \u0007}\u0002\u0002 !\u0007,\u0002\u0002!\"\u0007\u007f\u0002\u0002\"\f\u0003\u0002\u0002\u0002#%\t\u0002\u0002\u0002$#\u0003\u0002\u0002\u0002%&\u0003\u0002\u0002\u0002&$\u0003\u0002\u0002\u0002&\'\u0003\u0002\u0002\u0002\'\u000e\u0003\u0002\u0002\u0002()\u0007,\u0002\u0002)\u0010\u0003\u0002\u0002\u0002*,\t\u0003\u0002\u0002+*\u0003\u0002\u0002\u0002,-\u0003\u0002\u0002\u0002-+\u0003\u0002\u0002\u0002-.\u0003\u0002\u0002\u0002./\u0003\u0002\u0002\u0002/0\b\t\u0002\u00020\u0012\u0003\u0002\u0002\u0002\u0005\u0002&-\u0003\b\u0002\u0002"
public static final int	IDENTIFIER	6
public static final int	T__0	1
public static final int	T__1	2
public static final int	T__2	3
public static final int	T__3	4
public static final int	T__4	5
public static final int	WILDCARD	7
public static final int	WS	8

org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser

Modifier and Type	Constant Field	Value
public static final String	_serializedATN	"\u0003\u608b\ua72a\u8133\ub9ed\u417c\u3be7\u7786\u5964\u0003\n7\u0004\u0002\t\u0002\u0004\u0003\t\u0003\u0004\u0004\t\u0004\u0004\u0005\t\u0005\u0004\u0006\t\u0006\u0004\u0007\t\u0007\u0004\b\t\b\u0003\u0002\u0003\u0002\u0003\u0003\u0003\u0003\u0003\u0003\u0007\u0003\u0016\n\u0003\f\u0003\u000e\u0003\u0019\u000b\u0003\u0003\u0004\u0003\u0004\u0003\u0004\u0005\u0004\u001e\n\u0004\u0003\u0005\u0003\u0005\u0003\u0005\u0003\u0006\u0003\u0006\u0007\u0006%\n\u0006\f\u0006\u000e\u0006(\u000b\u0006\u0003\u0006\u0003\u0006\u0007\u0006,\n\u0006\f\u0006\u000e\u0006/\u000b\u0006\u0005\u00061\n\u0006\u0003\u0007\u0003\u0007\u0003\b\u0003\b\u0003\b\u0002\u0002\t\u0002\u0004\u0006\b\n\f\u000e\u0002\u0004\u0003\u0002\u0004\u0005\u0003\u0002\u0006\u0007\u00025\u0002\u0010\u0003\u0002\u0002\u0002\u0004\u0012\u0003\u0002\u0002\u0002\u0006\u001d\u0003\u0002\u0002\u0002\b\u001f\u0003\u0002\u0002\u0002\n0\u0003\u0002\u0002\u0002\f2\u0003\u0002\u0002\u0002\u000e4\u0003\u0002\u0002\u0002\u0010\u0011\u0005\u0004\u0003\u0002\u0011\u0003\u0003\u0002\u0002\u0002\u0012\u0017\u0005\u0006\u0004\u0002\u0013\u0014\u0007\u0003\u0002\u0002\u0014\u0016\u0005\u0006\u0004\u0002\u0015\u0013\u0003\u0002\u0002\u0002\u0016\u0019\u0003\u0002\u0002\u0002\u0017\u0015\u0003\u0002\u0002\u0002\u0017\u0018\u0003\u0002\u0002\u0002\u0018\u0005\u0003\u0002\u0002\u0002\u0019\u0017\u0003\u0002\u0002\u0002\u001a\u001e\u0005\b\u0005\u0002\u001b\u001e\u0007\b\u0002\u0002\u001c\u001e\u0007\t\u0002\u0002\u001d\u001a\u0003\u0002\u0002\u0002\u001d\u001b\u0003\u0002\u0002\u0002\u001d\u001c\u0003\u0002\u0002\u0002\u001e\u0007\u0003\u0002\u0002\u0002\u001f \u0007\b\u0002\u0002 !\u0005\n\u0006\u0002!\t\u0003\u0002\u0002\u0002\"&\u0005\f\u0007\u0002#%\u0005\n\u0006\u0002$#\u0003\u0002\u0002\u0002%(\u0003\u0002\u0002\u0002&$\u0003\u0002\u0002\u0002&\'\u0003\u0002\u0002\u0002\'1\u0003\u0002\u0002\u0002(&\u0003\u0002\u0002\u0002)-\u0005\u000e\b\u0002*,\u0005\n\u0006\u0002+*\u0003\u0002\u0002\u0002,/\u0003\u0002\u0002\u0002-+\u0003\u0002\u0002\u0002-.\u0003\u0002\u0002\u0002.1\u0003\u0002\u0002\u0002/-\u0003\u0002\u0002\u00020\"\u0003\u0002\u0002\u00020)\u0003\u0002\u0002\u00021\u000b\u0003\u0002\u0002\u000223\t\u0002\u0002\u00023\r\u0003\u0002\u0002\u000245\t\u0003\u0002\u00025\u000f\u0003\u0002\u0002\u0002\u0007\u0017\u001d&-0"
public static final int	IDENTIFIER	6
public static final int	RULE_arrayQualifier	5
public static final int	RULE_dotExpression	1
public static final int	RULE_dotExpressionComponent	2
public static final int	RULE_fieldSpecifier	0
public static final int	RULE_mapQualifier	6
public static final int	RULE_qualifiedComponent	3
public static final int	RULE_qualifierList	4
public static final int	T__0	1
public static final int	T__1	2
public static final int	T__2	3
public static final int	T__3	4
public static final int	T__4	5
public static final int	WILDCARD	7
public static final int	WS	8

org.apache.beam.sdk.schemas.transforms.Join

Modifier and Type	Constant Field	Value
public static final String	LHS_TAG	"lhs"
public static final String	RHS_TAG	"rhs"

org.apache.beam.sdk.schemas.transforms.providers.FlattenTransformProvider

Modifier and Type	Constant Field	Value
protected static final String	OUTPUT_ROWS_TAG	"output"

org.apache.beam.sdk.schemas.transforms.providers.JavaExplodeTransformProvider

Modifier and Type	Constant Field	Value
protected static final String	INPUT_ROWS_TAG	"input"
protected static final String	OUTPUT_ROWS_TAG	"output"

org.apache.beam.sdk.schemas.transforms.providers.JavaFilterTransformProvider

Modifier and Type	Constant Field	Value
protected static final String	INPUT_ROWS_TAG	"input"
protected static final String	OUTPUT_ROWS_TAG	"output"

org.apache.beam.sdk.schemas.transforms.providers.JavaMapToFieldsTransformProvider

Modifier and Type	Constant Field	Value
protected static final String	INPUT_ROWS_TAG	"input"
protected static final String	OUTPUT_ROWS_TAG	"output"

org.apache.beam.sdk.schemas.transforms.providers.LoggingTransformProvider

Modifier and Type	Constant Field	Value
protected static final String	INPUT_ROWS_TAG	"input"
protected static final String	OUTPUT_ROWS_TAG	"output"

org.apache.beam.sdk.testing.PAssert

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

org.apache.beam.sdk.testing.TestPipeline

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

org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn<T,ComparatorT>

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 String	ITERABLE_MATERIALIZATION_URN	"beam:side_input:iterable:v1"
public static final String	MULTIMAP_MATERIALIZATION_URN	"beam:side_input:multimap:v1"