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 |
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 |
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 |
RESTRICTION_CODER |
"restriction_coder" |
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 |
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" |