Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
READ_JSON_URN |
"beam:transform:org.apache.beam:debezium_read:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BEAM_INSTANCE_PROPERTY |
"beam.parent.instance" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public final java.lang.String |
type |
"OutputReference" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ACCUMULATOR_NAME |
"__metricscontainers" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SDF_PREFIX |
"sdf_checkpoint" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_MAX_INVOCATION_HISTORY |
10 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_MASTER_URL |
"local[4]" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TRANSFORM_URN |
"beam:transform:spark:consoleio_write_unbound:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TRANSFORM_URN |
"beam:transform:spark:createstream:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
OUTPUT_ROWS_TAG |
"output" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
AVRO_CODER_URN |
"beam:coder:avro:generic:v1" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SCHEME |
"gs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_MAX_ELEMENTS_TO_OUTPUT |
10000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
-5043999806040629525L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"Fixed32" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"Fixed64" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"SFixed32" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"SFixed64" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"Sint32" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"Sint64" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"Uint32" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"Uint64" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"LocalMktDate" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"TZTimeOnly" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"TZTimestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"uint16" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"uint32" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"uint64" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"uint8" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"UTCDateOnly" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"UTCTimeOnly" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"UTCTimestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
UDF_METHOD |
"eval" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PCOLLECTION_NAME |
"PCOLLECTION" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONNECT_STRING_PREFIX |
"jdbc:beam:" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final double |
CONSTANT_WINDOW_SIZE |
10.0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ERROR |
"error" |
public static final java.lang.String |
ROW |
"row" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"SqlTimeWithLocalTzType" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PUSH_DOWN_OPTION |
"push_down" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ZETASQL_NUMERIC_SCALE |
9 |
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" |
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 |
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 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
URN |
"beam:runner:source:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
URN |
"beam:runner:sink:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_OUTBOUND_BUFFER_LIMIT_BYTES |
1000000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
SPLIT_POINTS_UNKNOWN |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SCHEMA |
"classpath" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_SCHEME |
"file" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
URN |
"beam:external:java:generate_sequence:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final boolean |
DEFAULT_USES_RESHUFFLE |
true |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
BACKLOG_UNKNOWN |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FILE_TRIGGERING_BYTE_COUNT |
67108864 |
public static final int |
FILE_TRIGGERING_RECORD_COUNT |
100000 |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_UPLOAD_BUFFER_SIZE_BYTES |
5242880 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_UPLOAD_BUFFER_SIZE_BYTES |
5242880 |
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 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_UPLOAD_BUFFER_SIZE_BYTES |
5242880 |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_MAX_INSERT_BLOCK_SIZE |
1000000L |
public static final int |
DEFAULT_MAX_RETRIES |
5 |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BIGQUERY_JOB_TEMPLATE |
"beam_bq_job_{TYPE}_{JOB_ID}_{STEP}_{RANDOM}" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BIGQUERY_EARLY_ROLLOUT_REGION |
"us-east7" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DYNAMIC_DESTINATIONS |
"DYNAMIC_DESTINATIONS" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NUM_QUERY_SPLITS_MAX |
50000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
KEY_FIELD_PROPERTY |
"keyField" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TIMESTAMP_FIELD_NAME |
"observed_time" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
URN |
"beam:transform:org.apache.beam:pubsub_read:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
URN |
"beam:transform:org.apache.beam:pubsub_write:v1" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
VALID_FORMATS_STR |
"RAW,AVRO,JSON" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
VALID_FORMATS_STR |
"RAW,AVRO,JSON" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
VALID_FORMATS_STR |
"RAW,AVRO,JSON,PROTO" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SUPPORTED_FORMATS_STR |
"RAW,JSON,AVRO,PROTO" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_ATTRIBUTE |
"x-goog-pubsublite-dataflow-uuid" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_CHANGE_STREAM_NAME |
"" |
public static final int |
THROUGHPUT_WINDOW_SECONDS |
10 |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PARTITION_TOKEN |
"Parent0" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
URN |
"beam:transform:org.apache.beam:kafka_write:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
VALID_FORMATS_STR |
"RAW,AVRO,JSON,PROTO" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SUPPORTED_FORMATS_STR |
"RAW,JSON,AVRO,PROTO" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
OFFSET_INFINITY |
9223372036854775807L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
INPUT_TAG |
"INPUT" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_ADVANCE_TIMEOUT_IN_MILLIS |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ICEBERG |
"iceberg" |
public static final java.lang.String |
KAFKA |
"kafka" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ICEBERG_READ |
"beam:schematransform:org.apache.beam:iceberg_read:v1" |
public static final java.lang.String |
ICEBERG_WRITE |
"beam:schematransform:org.apache.beam:iceberg_write:v1" |
public static final java.lang.String |
INPUT |
"input" |
public static final java.lang.String |
KAFKA_READ |
"beam:schematransform:org.apache.beam:kafka_read:v1" |
public static final java.lang.String |
KAFKA_WRITE |
"beam:schematransform:org.apache.beam:kafka_write:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
LINEAGE_NAMESPACE |
"lineage" |
public static final java.lang.String |
SINK_METRIC_NAME |
"sinks" |
public static final java.lang.String |
SOURCE_METRIC_NAME |
"sources" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
OUTPUT_ROWS_TAG |
"output" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
5645783967169L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"beam:logical_type:date:v1" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"Enum" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"beam:logical_type:fixed_decimal:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"beam:logical_type:nanos_duration:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"beam:logical_type:nanos_instant:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"OneOf" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"beam:logical_type:schema:v1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
IDENTIFIER |
"beam:logical_type:time:v1" |
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" |
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 |
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 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
LHS_TAG |
"lhs" |
public static final java.lang.String |
RHS_TAG |
"rhs" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
OUTPUT_ROWS_TAG |
"output" |
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" |
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" |
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" |
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" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
FAILURE_COUNTER |
"PAssertFailure" |
public static final java.lang.String |
SUCCESS_COUNTER |
"PAssertSuccess" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPERTY_BEAM_TEST_PIPELINE_OPTIONS |
"beamTestPipelineOptions" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_MAX_NUM_ELEMENTS |
1000000000L |
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" |