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.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	ALLOW_DUPLICATES	"allow_duplicates"
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.prism.PrismPipelineOptions

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

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.avro.AvroGenericCoderRegistrar

Modifier and Type	Constant Field	Value
public static final java.lang.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 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.ordered.OrderedEventProcessor<EventT,EventKeyT,ResultT,StateT extends MutableState<EventT,ResultT>>

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

org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler<EventT,KeyT,StateT extends MutableState<EventT,?>,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 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.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.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"
public static final java.lang.String	THROTTLED_TIME	"ThrottledTime"

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

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

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"
protected static final java.lang.String	ROW_PROPERTY_MUTATION_INFO	"row_mutation_info"
protected static final java.lang.String	ROW_PROPERTY_MUTATION_SQN	"change_sequence_number"
protected static final java.lang.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 java.lang.String	DYNAMIC_DESTINATIONS	"DYNAMIC_DESTINATIONS"

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

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

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,PROTO"

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,PROTO"

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

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

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.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 java.lang.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 java.lang.String	BIGQUERY	"bigquery"
public static final java.lang.String	ICEBERG	"iceberg"
public static final java.lang.String	KAFKA	"kafka"

org.apache.beam.sdk.managed.ManagedTransformConstants

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

org.apache.beam.sdk.metrics.Lineage

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

org.apache.beam.sdk.metrics.Metrics

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

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"