public static final java.lang.String |
ALLOWED_ENCODINGS |
"allowed_encodings" |
public static final java.lang.String |
APPEND_TRAILING_NEWLINES |
"append_trailing_newlines" |
public static final java.lang.String |
BIGQUERY_CREATE_DISPOSITION |
"create_disposition" |
public static final java.lang.String |
BIGQUERY_DATASET |
"dataset" |
public static final java.lang.String |
BIGQUERY_EXPORT_FORMAT |
"bigquery_export_format" |
public static final java.lang.String |
BIGQUERY_EXPORT_SCHEMA |
"bigquery_export_schema" |
public static final java.lang.String |
BIGQUERY_FLATTEN_RESULTS |
"bigquery_flatten_results" |
public static final java.lang.String |
BIGQUERY_PROJECT |
"project" |
public static final java.lang.String |
BIGQUERY_QUERY |
"bigquery_query" |
public static final java.lang.String |
BIGQUERY_SCHEMA |
"schema" |
public static final java.lang.String |
BIGQUERY_TABLE |
"table" |
public static final java.lang.String |
BIGQUERY_USE_LEGACY_SQL |
"bigquery_use_legacy_sql" |
public static final java.lang.String |
BIGQUERY_WRITE_DISPOSITION |
"write_disposition" |
public static final java.lang.String |
CO_GBK_RESULT_SCHEMA |
"co_gbk_result_schema" |
public static final java.lang.String |
COMBINE_FN |
"combine_fn" |
public static final java.lang.String |
COMPONENT_ENCODINGS |
"component_encodings" |
public static final java.lang.String |
COMPRESSION_TYPE |
"compression_type" |
public static final java.lang.String |
CONCAT_SOURCE_BASE_SPECS |
"base_specs" |
public static final java.lang.String |
CONCAT_SOURCE_SOURCES |
"sources" |
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 |
ELEMENT |
"element" |
public static final java.lang.String |
ELEMENTS |
"elements" |
public static final java.lang.String |
ENCODING |
"encoding" |
public static final java.lang.String |
ENCODING_ID |
"encoding_id" |
public static final java.lang.String |
END_INDEX |
"end_index" |
public static final java.lang.String |
END_OFFSET |
"end_offset" |
public static final java.lang.String |
END_SHUFFLE_POSITION |
"end_shuffle_position" |
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 |
FILENAME |
"filename" |
public static final java.lang.String |
FILENAME_PREFIX |
"filename_prefix" |
public static final java.lang.String |
FILENAME_SUFFIX |
"filename_suffix" |
public static final java.lang.String |
FILEPATTERN |
"filepattern" |
public static final java.lang.String |
FOOTER |
"footer" |
public static final java.lang.String |
FORMAT |
"format" |
public static final java.lang.String |
HEADER |
"header" |
public static final java.lang.String |
INPUT_CODER |
"input_coder" |
public static final java.lang.String |
INPUTS |
"inputs" |
public static final java.lang.String |
IS_GENERATED |
"is_generated" |
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 |
NUM_METADATA_SHARD_CODERS |
"num_metadata_shard_coders" |
public static final java.lang.String |
NUM_SHARD_CODERS |
"num_shard_coders" |
public static final java.lang.String |
NUM_SHARDS |
"num_shards" |
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 |
PHASE |
"phase" |
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 |
SCALAR_FIELD_NAME |
"value" |
public static final java.lang.String |
SERIALIZED_FN |
"serialized_fn" |
public static final java.lang.String |
SHARD_NAME_TEMPLATE |
"shard_template" |
public static final java.lang.String |
SHUFFLE_KIND |
"shuffle_kind" |
public static final java.lang.String |
SHUFFLE_READER_CONFIG |
"shuffle_reader_config" |
public static final java.lang.String |
SHUFFLE_WRITER_CONFIG |
"shuffle_writer_config" |
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_PRODUCES_SORTED_KEYS |
"produces_sorted_keys" |
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 |
START_INDEX |
"start_index" |
public static final java.lang.String |
START_OFFSET |
"start_offset" |
public static final java.lang.String |
START_SHUFFLE_POSITION |
"start_shuffle_position" |
public static final java.lang.String |
STRIP_TRAILING_NEWLINES |
"strip_trailing_newlines" |
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 |
VALIDATE_SINK |
"validate_sink" |
public static final java.lang.String |
VALIDATE_SOURCE |
"validate_source" |
public static final java.lang.String |
VALUE |
"value" |