Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.beam.io.debezium.DebeziumTransformRegistrar

Modifier and Type	Constant Field	Value
public static final java.lang.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 java.lang.String	BEAM_INSTANCE_PROPERTY	"beam.parent.instance"

org.apache.beam.it.gcp.IOLoadTestBase

Modifier and Type	Constant Field	Value
public static final java.lang.String	BEAM_METRICS_NAMESPACE	"BEAM_METRICS"

org.apache.beam.it.gcp.bigtable.BigtableResourceManagerUtils

Modifier and Type	Constant Field	Value
public static final int	MAX_INSTANCE_ID_LENGTH	30

org.apache.beam.it.gcp.dataflow.AbstractPipelineLauncher

Modifier and Type	Constant Field	Value
public static final java.lang.String	LEGACY_RUNNER	"Dataflow Legacy Runner"
public static final java.lang.String	PARAM_JOB_ID	"jobId"
public static final java.lang.String	PARAM_JOB_TYPE	"jobType"
public static final java.lang.String	PARAM_RUNNER	"runner"
public static final java.lang.String	RUNNER_V2	"Dataflow Runner V2"

org.apache.beam.it.gcp.spanner.utils.SpannerResourceManagerUtils

Modifier and Type	Constant Field	Value
public static final int	MAX_DATABASE_ID_LENGTH	30
public static final int	MAX_INSTANCE_ID_LENGTH	30

org.apache.beam.it.jdbc.AbstractJDBCResourceManager<T extends JdbcDatabaseContainer<?>>

Modifier and Type	Constant Field	Value
protected static final java.lang.String	DEFAULT_JDBC_USERNAME	"root"

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]"
public static final java.lang.String	UNSAFELY_ATTEMPT_TO_PROCESS_UNBOUNDED_DATA_IN_BATCH_MODE	"unsafely_attempt_to_process_unbounded_data_in_batch_mode"

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	ALLOWS_SHARDABLE_STATE	"allows_shardable_state"
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	PRESERVES_KEYS	"preserves_keys"
public static final java.lang.String	PUBSUB_DYNAMIC_DESTINATIONS	"pubsub_with_dynamic_destinations"
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	RESOURCE_HINTS	"resource_hints"
public static final java.lang.String	RESTRICTION_CODER	"restriction_coder"
public static final java.lang.String	RESTRICTION_ENCODING	"restriction_encoding"
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	SERIALIZED_TEST_STREAM	"serialized_test_stream"
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	EXACTLY_ONCE	"EXACTLY_ONCE"
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.ArtifactRetrievalService

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_BUFFER_SIZE	2097152
public static final java.lang.String	EMBEDDED_ARTIFACT_URN	"beam:artifact:type:embedded:v1"
public static final java.lang.String	FILE_ARTIFACT_URN	"beam:artifact:type:file:v1"
public static final java.lang.String	STAGING_TO_ARTIFACT_URN	"beam:artifact:role:staging_to:v1"
public static final java.lang.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 java.lang.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.spark.SparkCommonPipelineOptions

Modifier and Type	Constant Field	Value
public static final java.lang.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 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.expansion.service.WindowIntoTransformProvider

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

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

Modifier and Type	Constant Field	Value
public static final java.lang.String	STREAMING_ENGINE_EXPERIMENT	"enable_streaming_engine"
public static final java.lang.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 java.lang.String	SCHEME	"gs"

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 extends com.google.protobuf.Message>

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 java.lang.String	IDENTIFIER	"Fixed32"

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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.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 java.lang.String	ERROR	"error"
public static final java.lang.String	ROW	"row"

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

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

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

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

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

Modifier and Type	Constant Field	Value
public static final java.lang.String	DOUBLE_NAN_WRAPPER	"double_nan"
public static final java.lang.String	DOUBLE_NEGATIVE_INF_WRAPPER	"double_negative_inf"
public static final java.lang.String	DOUBLE_POSITIVE_INF_WRAPPER	"double_positive_inf"
public static final java.lang.String	IN_ARRAY_OPERATOR	"$in_array"
public static final java.lang.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 java.lang.String	PUSH_DOWN_OPTION	"push_down"

org.apache.beam.sdk.extensions.sql.zetasql.BeamZetaSqlCatalog

Modifier and Type	Constant Field	Value
public static final java.lang.String	PRE_DEFINED_WINDOW_FUNCTIONS	"pre_defined_window_functions"
public static final java.lang.String	USER_DEFINED_JAVA_AGGREGATE_FUNCTIONS	"user_defined_java_aggregate_functions"
public static final java.lang.String	USER_DEFINED_JAVA_SCALAR_FUNCTIONS	"user_defined_java_scalar_functions"
public static final java.lang.String	USER_DEFINED_SQL_FUNCTIONS	"user_defined_functions"
public static final java.lang.String	ZETASQL_FUNCTION_GROUP_NAME	"ZetaSQL"

org.apache.beam.sdk.extensions.sql.zetasql.ZetaSqlCalciteTranslationUtils

Modifier and Type	Constant Field	Value
public static final int	ZETASQL_NUMERIC_SCALE	9

org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.StringFunctions

Modifier and Type	Constant Field	Value
public static final java.lang.String	SUBSTR_PARAMETER_EXCEED_INTEGER	"SUBSTR function only allows: -2147483648 <= position or length <= 2147483647"

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 java.lang.String	DATA_BUFFER_SIZE_LIMIT	"data_buffer_size_limit="
public static final java.lang.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 java.lang.String	URN	"beam:runner:source:v1"

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

Modifier and Type	Constant Field	Value
public static final java.lang.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 java.lang.String	SCHEMA	"classpath"

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.GenerateSequence.External

Modifier and Type	Constant Field	Value
public static final java.lang.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 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.AwsModule

Modifier and Type	Constant Field	Value
public static final java.lang.String	CLIENT_EXECUTION_TIMEOUT	"clientExecutionTimeout"
public static final java.lang.String	CONNECTION_MAX_IDLE_TIME	"connectionMaxIdleTime"
public static final java.lang.String	CONNECTION_TIME_TO_LIVE	"connectionTimeToLive"
public static final java.lang.String	CONNECTION_TIMEOUT	"connectionTimeout"
public static final java.lang.String	MAX_CONNECTIONS	"maxConnections"
public static final java.lang.String	PROXY_HOST	"proxyHost"
public static final java.lang.String	PROXY_PASSWORD	"proxyPassword"
public static final java.lang.String	PROXY_PORT	"proxyPort"
public static final java.lang.String	PROXY_USERNAME	"proxyUsername"
public static final java.lang.String	REQUEST_TIMEOUT	"requestTimeout"
public static final java.lang.String	SOCKET_TIMEOUT	"socketTimeout"

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.aws.s3.S3FileSystemConfiguration

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

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.cdap.context.BatchContextImpl

Modifier and Type	Constant Field	Value
public static final java.lang.String	DEFAULT_SCHEMA_FIELD_NAME	"Name"
public static final java.lang.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 java.lang.String	RANGE_OFFSET	"rangeOffset"
public static final java.lang.String	RECORD_NUM	"recordNum"
public static final java.lang.String	RECORD_NUM_IN_OFFSET	"recordNumInOffset"
public static final java.lang.String	RECORD_OFFSET	"recordOffset"
public static final java.lang.String	RESOURCE_ID	"resourceId"
public static final java.lang.String	VALUE	"value"

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

Modifier and Type	Constant Field	Value
public static final java.lang.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 java.lang.String	METRICS_NAMESPACE	"BigQuerySink"
public static final java.lang.String	PAYLOAD_TOO_LARGE	"PayloadTooLarge"

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

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

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

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

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

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

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

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

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

Modifier and Type	Constant Field	Value
public static final java.lang.String	CF_CONTINUATION_TOKEN	"continuation_token"
public static final java.lang.String	CF_INITIAL_TOKEN	"initial_continuation_token"
public static final java.lang.String	CF_LOCK	"lock"
public static final java.lang.String	CF_MISSING_PARTITIONS	"missing_partitions"
public static final java.lang.String	CF_PARENT_LOW_WATERMARKS	"parent_low_watermarks"
public static final java.lang.String	CF_PARENT_PARTITIONS	"parent_partitions"
public static final java.lang.String	CF_SHOULD_DELETE	"should_delete"
public static final java.lang.String	CF_VERSION	"version"
public static final java.lang.String	CF_WATERMARK	"watermark"
public static final int	CURRENT_METADATA_TABLE_VERSION	1
public static final java.lang.String	DEFAULT_METADATA_TABLE_NAME	"__change_stream_md_table"
public static final java.lang.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 java.lang.String	KEY_FIELD_PROPERTY	"keyField"

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

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

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

Modifier and Type	Constant Field	Value
public static final java.lang.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 java.lang.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 java.lang.String	ENABLE_CUSTOM_PUBSUB_SINK	"enable_custom_pubsub_sink"
public static final java.lang.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 java.lang.String	VALID_FORMATS_STR	"RAW,AVRO,JSON"

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

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

org.apache.beam.sdk.io.gcp.pubsublite.PubsubLiteReadSchemaTransformProvider

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

org.apache.beam.sdk.io.gcp.pubsublite.PubsubLiteWriteSchemaTransformProvider

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

org.apache.beam.sdk.io.gcp.pubsublite.internal.ExternalTransformRegistrarImpl

Modifier and Type	Constant Field	Value
public static final java.lang.String	READ_URN	"beam:transform:org.apache.beam:pubsublite_read:v1"
public static final java.lang.String	WRITE_URN	"beam:transform:org.apache.beam:pubsublite_write:v1"

org.apache.beam.sdk.io.gcp.pubsublite.internal.Uuid

Modifier and Type	Constant Field	Value
public static final java.lang.String	DEFAULT_ATTRIBUTE	"x-goog-pubsublite-dataflow-uuid"

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

Modifier and Type	Constant Field	Value
public static final java.lang.String	DELETE_URN	"beam:transform:org.apache.beam:spanner_delete:v1"
public static final java.lang.String	INSERT_OR_UPDATE_URN	"beam:transform:org.apache.beam:spanner_insert_or_update:v1"
public static final java.lang.String	INSERT_URN	"beam:transform:org.apache.beam:spanner_insert:v1"
public static final java.lang.String	READ_URN	"beam:transform:org.apache.beam:spanner_read:v1"
public static final java.lang.String	REPLACE_URN	"beam:transform:org.apache.beam:spanner_replace:v1"
public static final java.lang.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 java.lang.String	DEFAULT_CHANGE_STREAM_NAME	""
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 java.lang.String	COLUMN_CREATED_AT	"CreatedAt"
public static final java.lang.String	COLUMN_END_TIMESTAMP	"EndTimestamp"
public static final java.lang.String	COLUMN_FINISHED_AT	"FinishedAt"
public static final java.lang.String	COLUMN_HEARTBEAT_MILLIS	"HeartbeatMillis"
public static final java.lang.String	COLUMN_PARENT_TOKENS	"ParentTokens"
public static final java.lang.String	COLUMN_PARTITION_TOKEN	"PartitionToken"
public static final java.lang.String	COLUMN_RUNNING_AT	"RunningAt"
public static final java.lang.String	COLUMN_SCHEDULED_AT	"ScheduledAt"
public static final java.lang.String	COLUMN_START_TIMESTAMP	"StartTimestamp"
public static final java.lang.String	COLUMN_STATE	"State"
public static final java.lang.String	COLUMN_WATERMARK	"Watermark"

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

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

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.kafka.KafkaIO.Read.External

Modifier and Type	Constant Field	Value
public static final java.lang.String	URN_WITH_METADATA	"beam:transform:org.apache.beam:kafka_read_with_metadata:v1"
public static final java.lang.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 java.lang.String	URN	"beam:transform:org.apache.beam:kafka_write:v1"

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

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

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

Modifier and Type	Constant Field	Value
public static final java.lang.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 java.lang.String	KAFKA_READ_WITH_METADATA_TRANSFORM_URN_V2	"beam:transform:org.apache.beam:kafka_read_with_metadata:v2"
public static final java.lang.String	KAFKA_WRITE_TRANSFORM_URN_V2	"beam:transform:org.apache.beam:kafka_write:v2"

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

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

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 java.lang.String	INPUT_TAG	"INPUT"

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

Modifier and Type	Constant Field	Value
public static final java.lang.String	AUTH_VALIDATION_GROUP	"AUTH_VALIDATION_GROUP"
public static final java.lang.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 java.lang.String	READ_URN	"beam:transform:org.apache.beam:snowflake_read:v1"
public static final java.lang.String	WRITE_URN	"beam:transform:org.apache.beam:snowflake_write:v1"

org.apache.beam.sdk.options.ExperimentalOptions

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

org.apache.beam.sdk.providers.GenerateSequenceSchemaTransformProvider

Modifier and Type	Constant Field	Value
public static final java.lang.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.Date

Modifier and Type	Constant Field	Value
public static final java.lang.String	IDENTIFIER	"beam:logical_type:date:v1"

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Modifier and Type	Constant Field	Value
public static final java.lang.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 java.lang.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 java.lang.String	LHS_TAG	"lhs"
public static final java.lang.String	RHS_TAG	"rhs"

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

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

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

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

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

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

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

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

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

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

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