Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SSE_KMS |
"SSE-KMS" |
public static final String |
SSE_S3 |
"SSE-S3" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
UPDATE_ANON_PREFIX |
"SYS$ANON" |
public static final String |
UPDATE_SRC_ALIAS |
"SYS$SRC" |
public static final String |
UPDATE_TGT_ALIAS |
"SYS$TGT" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_IN_SUB_QUERY_THRESHOLD |
20 |
public static final int |
DEFAULT_IN_SUBQUERY_THRESHOLD |
20 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ALL_JOB_MANAGER |
"all_jobmanager" |
public static final String |
ALL_TASK_MANAGER |
"all_taskmanager" |
public static final String |
ALL_TASK_MANAGER_NETWORK |
"all_taskmanager_network" |
public static final String |
CHECKPOINT_FILE_MERGING |
"checkpoint_file_merging" |
public static final String |
COMMON_CHECKPOINTING |
"common_checkpointing" |
public static final String |
COMMON_HIGH_AVAILABILITY |
"common_high_availability" |
public static final String |
COMMON_HIGH_AVAILABILITY_JOB_RESULT_STORE |
"common_high_availability_jrs" |
public static final String |
COMMON_HIGH_AVAILABILITY_ZOOKEEPER |
"common_high_availability_zk" |
public static final String |
COMMON_HOST_PORT |
"common_host_port" |
public static final String |
COMMON_MEMORY |
"common_memory" |
public static final String |
COMMON_MISCELLANEOUS |
"common_miscellaneous" |
public static final String |
COMMON_STATE_BACKENDS |
"common_state_backends" |
public static final String |
DEPRECATED_FILE_SINKS |
"deprecated_file_sinks" |
public static final String |
EXPERT_CHECKPOINTING |
"expert_checkpointing" |
public static final String |
EXPERT_CLASS_LOADING |
"expert_class_loading" |
public static final String |
EXPERT_CLUSTER |
"expert_cluster" |
public static final String |
EXPERT_DEBUGGING_AND_TUNING |
"expert_debugging_and_tuning" |
public static final String |
EXPERT_FAULT_TOLERANCE |
"expert_fault_tolerance" |
public static final String |
EXPERT_HIGH_AVAILABILITY |
"expert_high_availability" |
public static final String |
EXPERT_JOB_MANAGER |
"expert_jobmanager" |
public static final String |
EXPERT_KUBERNETES_HIGH_AVAILABILITY |
"expert_high_availability_k8s" |
public static final String |
EXPERT_REST |
"expert_rest" |
public static final String |
EXPERT_ROCKSDB |
"expert_rocksdb" |
public static final String |
EXPERT_SCHEDULING |
"expert_scheduling" |
public static final String |
EXPERT_SECURITY_SSL |
"expert_security_ssl" |
public static final String |
EXPERT_ZOOKEEPER_HIGH_AVAILABILITY |
"expert_high_availability_zk" |
public static final String |
METRIC_REPORTERS |
"metric_reporters" |
public static final String |
SECURITY_AUTH_KERBEROS |
"security_auth_kerberos" |
public static final String |
SECURITY_AUTH_ZOOKEEPER |
"security_auth_zk" |
public static final String |
SECURITY_DELEGATION_TOKEN |
"security_delegation_token" |
public static final String |
SECURITY_SSL |
"security_ssl" |
public static final String |
STATE_BACKEND_ROCKSDB |
"state_backend_rocksdb" |
public static final String |
STATE_CHANGELOG |
"state_changelog" |
public static final String |
STATE_LATENCY_TRACKING |
"state_latency_tracking" |
public static final String |
TRACE_REPORTERS |
"trace_reporters" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PARALLELISM_AUTO_MAX |
2147483647 |
public static final int |
PARALLELISM_DEFAULT |
-1 |
public static final int |
PARALLELISM_UNKNOWN |
-2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
NO_TIMESTAMP |
-9223372036854775808L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
NATIVE_BLOCK_SIZE |
-9223372036854775808L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
NATIVE_BLOCK_SIZE |
-9223372036854775808L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
RECORD_DELIMITER |
"delimited-format.delimiter" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final long |
READ_WHOLE_SPLIT_FLAG |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HADOOP_COPYING |
"_COPYING_" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final float |
AVG_RECORD_BYTES_UNKNOWN |
-1.0f |
public static final long |
NUM_RECORDS_UNKNOWN |
-1L |
public static final long |
SIZE_UNKNOWN |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SELECT_ALL_CHAR |
"*" |
public static final String |
SELECT_ALL_CHAR_SCALA |
"_" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SIZE_MISMATCH_MESSAGE |
"The number of specified keys is different." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TERMINATION_CRITERION_AGGREGATOR_NAME |
"terminationCriterion.aggregator" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NAME |
"CPU" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
INITIAL_CHECKPOINT_ID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
UPPER_BOUND_MAX_PARALLELISM |
32768 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_FIELD_DELIMITER |
"," |
public static final String |
DEFAULT_LINE_DELIMITER |
"\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_LINE_DELIMITER |
"\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final double |
EPSILON |
1.0E-5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_ARITY |
25 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ROW_KIND_OFFSET |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
DEFAULT_UNDEFINED |
"<undefined>" |
protected static final String |
NO_VALUE_KEY |
"__NO_VALUE_KEY" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_LINE_DELIMITER |
"\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONFIG_OPTIONS_FQ_NAME |
"org.apache.flink.configuration.ConfigOption" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
ENDING_STATE_NAME |
"$endState$" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
STATE_NAME_DELIM |
":" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CHANGELOG_STORAGE_ATTEMPTS_PER_UPLOAD |
"ChangelogStorage.attemptsPerUpload" |
public static final String |
CHANGELOG_STORAGE_NUM_UPLOAD_FAILURES |
"ChangelogStorage.numberOfUploadFailures" |
public static final String |
CHANGELOG_STORAGE_NUM_UPLOAD_REQUESTS |
"ChangelogStorage.numberOfUploadRequests" |
public static final String |
CHANGELOG_STORAGE_TOTAL_ATTEMPTS_PER_UPLOAD |
"ChangelogStorage.totalAttemptsPerUpload" |
public static final String |
CHANGELOG_STORAGE_UPLOAD_BATCH_SIZES |
"ChangelogStorage.uploadBatchSizes" |
public static final String |
CHANGELOG_STORAGE_UPLOAD_LATENCIES_NANOS |
"ChangelogStorage.uploadLatenciesNanos" |
public static final String |
CHANGELOG_STORAGE_UPLOAD_QUEUE_SIZE |
"ChangelogStorage.uploadQueueSize" |
public static final String |
CHANGELOG_STORAGE_UPLOAD_SIZES |
"ChangelogStorage.uploadSizes" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"filesystem" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PATH_SUB_DIR |
"dstl" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ID |
"default" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NAME |
"embedded" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NAME |
"local" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NAME |
"remote" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MANIFEST_ATTRIBUTE_ASSEMBLER_CLASS |
"program-class" |
public static final String |
MANIFEST_ATTRIBUTE_MAIN_CLASS |
"Main-Class" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXPONENTIAL_DELAY_LABEL |
"exponential-delay" |
public static final String |
FIXED_DELAY_LABEL |
"fixed-delay" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_FLINK_LIB_DIR |
"lib" |
public static final String |
DEFAULT_FLINK_OPT_DIR |
"opt" |
public static final String |
DEFAULT_FLINK_PLUGINS_DIRS |
"plugins" |
public static final String |
DEFAULT_FLINK_USR_LIB_DIR |
"usrlib" |
public static final int |
DEFAULT_LOCAL_NUMBER_TASK_MANAGER |
1 |
public static final String |
DEFAULT_YARN_CONTAINER_START_COMMAND_TEMPLATE |
"%java% %jvmmem% %jvmopts% %logging% %class% %args% %redirects%" |
public static final String |
ENV_FLINK_CONF_DIR |
"FLINK_CONF_DIR" |
public static final String |
ENV_FLINK_HOME_DIR |
"FLINK_HOME" |
public static final String |
ENV_FLINK_LIB_DIR |
"FLINK_LIB_DIR" |
public static final String |
ENV_FLINK_OPT_DIR |
"FLINK_OPT_DIR" |
public static final String |
ENV_FLINK_PLUGINS_DIR |
"FLINK_PLUGINS_DIR" |
public static final String |
FLINK_REST_CLIENT_HEADERS |
"FLINK_REST_CLIENT_HEADERS" |
public static final String |
METRICS_REPORTER_PREFIX |
"metrics.reporter." |
public static final String |
TRACES_REPORTER_PREFIX |
"traces.reporter." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LEGACY_FLINK_CONF_FILENAME |
"flink-conf.yaml" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DISABLED_NETWORK_BUFFER_TIMEOUT |
-1L |
public static final long |
FLUSH_AFTER_EVERY_RECORD |
0L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXTERNAL_RESOURCE_AMOUNT_SUFFIX |
"amount" |
public static final String |
EXTERNAL_RESOURCE_DRIVER_FACTORY_SUFFIX |
"driver-factory.class" |
public static final String |
EXTERNAL_RESOURCE_DRIVER_PARAM_SUFFIX |
"param." |
public static final String |
NONE |
"none" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FLINK_CONF_FILENAME |
"config.yaml" |
public static final String |
HIDDEN_CONTENT |
"******" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FAILED_RPC_DETECTION_DISABLED |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONTAINERIZED_MASTER_ENV_PREFIX |
"containerized.master.env." |
public static final String |
CONTAINERIZED_TASK_MANAGER_ENV_PREFIX |
"containerized.taskmanager.env." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
RESTART_STRATEGY_CONFIG_PREFIX |
"restart-strategy" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DELEGATION_TOKEN_PROVIDER_PREFIX |
"security.delegation.token.provider.<serviceName>" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MANAGED_MEMORY_CONSUMER_NAME_DATAPROC |
"DATAPROC" |
public static final String |
MANAGED_MEMORY_CONSUMER_NAME_OPERATOR |
"OPERATOR" |
public static final String |
MANAGED_MEMORY_CONSUMER_NAME_PYTHON |
"PYTHON" |
public static final String |
MANAGED_MEMORY_CONSUMER_NAME_STATE_BACKEND |
"STATE_BACKEND" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final boolean |
DEFAULT_FAIL_ON_TIMEOUT |
false |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"blackhole" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
END |
"end" |
public static final String |
FIELDS |
"fields" |
public static final String |
KIND |
"kind" |
public static final String |
LENGTH |
"length" |
public static final String |
MAX |
"max" |
public static final String |
MAX_PAST |
"max-past" |
public static final String |
MIN |
"min" |
public static final String |
NULL_RATE |
"null-rate" |
public static final String |
RANDOM |
"random" |
public static final String |
SEQUENCE |
"sequence" |
public static final String |
START |
"start" |
public static final String |
VAR_LEN |
"var-len" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"datagen" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
RANDOM_BYTES_LENGTH_DEFAULT |
100 |
public static final int |
RANDOM_STRING_LENGTH_DEFAULT |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_CHARSET_NAME |
"UTF-8" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
NO_OFFSET |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
NO_OFFSET |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"filesystem" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CUSTOM |
"custom" |
public static final String |
METASTORE |
"metastore" |
public static final String |
SUCCESS_FILE |
"success-file" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CUSTOM |
"custom" |
public static final String |
DEFAULT |
"default" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMPACT_OP_NAME |
"compact-operator" |
public static final String |
COORDINATOR_OP_NAME |
"compact-coordinator" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ATTEMPT_PREFIX |
"attempt-" |
public static final String |
COMPACTED_PREFIX |
"compacted-" |
public static final String |
UNCOMPACTED_PREFIX |
"uncompacted-" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMPACTED_PREFIX |
"compacted-" |
public static final String |
UNCOMPACTED_PREFIX |
".uncompacted-" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"print" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXTERNAL_CONTEXT_FACTORIES_STORE_KEY |
"externalContext" |
public static final String |
EXTERNAL_SYSTEM_STORE_KEY |
"externalSystem" |
public static final String |
SUPPORTED_SEMANTIC_STORE_KEY |
"supportedSemantic" |
public static final String |
TEST_ENV_STORE_KEY |
"testEnvironment" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SPLIT_ID |
"fakeSplitId" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
HEARTBEAT_INTERVAL_MS |
1000L |
public static final long |
HEARTBEAT_TIMEOUT_MS |
5000L |
public static final long |
METRIC_FETCHER_UPDATE_INTERVAL_MS |
1000L |
public static final long |
SLOT_REQUEST_TIMEOUT_MS |
10000L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
NUM_RECORDS_PER_SPLIT |
10 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"upsert-files" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BATCH_COMPACT_WRITER_OP_NAME |
"batch_writer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MERGE_OPERATOR_NAME |
"stringappendtest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRICS_COLUMN_FAMILY_AS_VARIABLE_KEY |
"state.backend.rocksdb.metrics.column-family-as-variable" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
CONFIG_KEY_FORMAT |
"state.backend.rocksdb.metrics.%s" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SST_FILE_SUFFIX |
".sst" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DETACHED_MESSAGE |
"Job was submitted in detached mode. " |
public static final String |
EAGER_FUNCTION_MESSAGE |
"Please make sure your program doesn\'t call an eager execution function [collect, print, printToErr, count]. " |
public static final String |
JOB_RESULT_MESSAGE |
"Results of job execution, such as accumulators, runtime, etc. are not available. " |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CUR_DIR |
"." |
public static final String |
SEPARATOR |
"/" |
public static final char |
SEPARATOR_CHAR |
47 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
BUFFER_SIZE |
4096 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CHECK_MULTIPLE_FREE_PROPERTY |
"flink.tests.check-segment-multiple-free" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONFIG_PREFIX |
"security.delegation.token.provider" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONFIG_PREFIX |
"security.delegation.token.receiver" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARG_CONVERSION_DURATION |
"durationConversion" |
public static final String |
ARG_CONVERSION_RATE |
"rateConversion" |
public static final String |
ARG_HOST |
"host" |
public static final String |
ARG_PORT |
"port" |
public static final String |
ARG_PREFIX |
"prefix" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BYTES_COPIED_CNT_NAME |
"BYTES_COPIED" |
public static final String |
FILES_COPIED_CNT_NAME |
"FILES_COPIED" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
V1 |
0 |
public static final int |
V2 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
D1 |
2 |
public static final int |
D2 |
3 |
public static final int |
V1 |
0 |
public static final int |
V2 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
V1 |
0 |
public static final int |
V2 |
1 |
public static final int |
V3 |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DATASET_DEPRECATION_INFO |
"All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API. This class is retained for testing purposes. See Also: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=158866741" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ARROW_TYPE_FIELD_NUMBER |
3 |
public static final int |
FLATTEN_ROW_TYPE_FIELD_NUMBER |
1 |
public static final int |
MODE_FIELD_NUMBER |
6 |
public static final int |
OVER_WINDOW_ARROW_TYPE_FIELD_NUMBER |
4 |
public static final int |
RAW_TYPE_FIELD_NUMBER |
5 |
public static final int |
ROW_TYPE_FIELD_NUMBER |
2 |
public static final int |
SEPARATED_WITH_END_MESSAGE_FIELD_NUMBER |
7 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SCHEMA_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SCHEMA_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MULTIPLE_VALUE |
1 |
public static final int |
SINGLE_VALUE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SCHEMA_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
TYPE_INFO_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SCHEMA_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ALLOWEDLATENESS_FIELD_NUMBER |
8 |
public static final int |
IS_ROW_TIME_FIELD_NUMBER |
6 |
public static final int |
IS_TIME_WINDOW_FIELD_NUMBER |
2 |
public static final int |
NAMEDPROPERTIES_FIELD_NUMBER |
9 |
public static final int |
SHIFT_TIMEZONE_FIELD_NUMBER |
10 |
public static final int |
TIME_FIELD_INDEX_FIELD_NUMBER |
7 |
public static final int |
WINDOW_GAP_FIELD_NUMBER |
5 |
public static final int |
WINDOW_SIZE_FIELD_NUMBER |
4 |
public static final int |
WINDOW_SLIDE_FIELD_NUMBER |
3 |
public static final int |
WINDOW_TYPE_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PROC_TIME_ATTRIBUTE_VALUE |
3 |
public static final int |
ROW_TIME_ATTRIBUTE_VALUE |
2 |
public static final int |
WINDOW_END_VALUE |
1 |
public static final int |
WINDOW_START_VALUE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SESSION_GROUP_WINDOW_VALUE |
2 |
public static final int |
SLIDING_GROUP_WINDOW_VALUE |
1 |
public static final int |
TUMBLING_GROUP_WINDOW_VALUE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INPUTCONSTANT_FIELD_NUMBER |
3 |
public static final int |
INPUTOFFSET_FIELD_NUMBER |
2 |
public static final int |
UDF_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KEY_FIELD_NUMBER |
1 |
public static final int |
VALUE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LOWER_BOUNDARY_FIELD_NUMBER |
2 |
public static final int |
UPPER_BOUNDARY_FIELD_NUMBER |
3 |
public static final int |
WINDOW_TYPE_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
RANGE_SLIDING_VALUE |
3 |
public static final int |
RANGE_UNBOUNDED_FOLLOWING_VALUE |
2 |
public static final int |
RANGE_UNBOUNDED_PRECEDING_VALUE |
1 |
public static final int |
RANGE_UNBOUNDED_VALUE |
0 |
public static final int |
ROW_SLIDING_VALUE |
7 |
public static final int |
ROW_UNBOUNDED_FOLLOWING_VALUE |
6 |
public static final int |
ROW_UNBOUNDED_PRECEDING_VALUE |
5 |
public static final int |
ROW_UNBOUNDED_VALUE |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FIELDS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LENGTH_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LENGTH_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PRECISION_FIELD_NUMBER |
1 |
public static final int |
SCALE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DESCRIPTION_FIELD_NUMBER |
2 |
public static final int |
NAME_FIELD_NUMBER |
1 |
public static final int |
TYPE_FIELD_NUMBER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
BINARY_INFO_FIELD_NUMBER |
11 |
public static final int |
CHAR_INFO_FIELD_NUMBER |
13 |
public static final int |
COLLECTION_ELEMENT_TYPE_FIELD_NUMBER |
3 |
public static final int |
DECIMAL_INFO_FIELD_NUMBER |
6 |
public static final int |
LOCAL_ZONED_TIMESTAMP_INFO_FIELD_NUMBER |
9 |
public static final int |
MAP_INFO_FIELD_NUMBER |
4 |
public static final int |
NULLABLE_FIELD_NUMBER |
2 |
public static final int |
ROW_SCHEMA_FIELD_NUMBER |
5 |
public static final int |
TIME_INFO_FIELD_NUMBER |
7 |
public static final int |
TIMESTAMP_INFO_FIELD_NUMBER |
8 |
public static final int |
TYPE_NAME_FIELD_NUMBER |
1 |
public static final int |
VAR_BINARY_INFO_FIELD_NUMBER |
12 |
public static final int |
VAR_CHAR_INFO_FIELD_NUMBER |
14 |
public static final int |
ZONED_TIMESTAMP_INFO_FIELD_NUMBER |
10 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PRECISION_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KEY_TYPE_FIELD_NUMBER |
1 |
public static final int |
VALUE_TYPE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PRECISION_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PRECISION_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
BASIC_ARRAY_VALUE |
16 |
public static final int |
BIGINT_VALUE |
4 |
public static final int |
BINARY_VALUE |
12 |
public static final int |
BOOLEAN_VALUE |
11 |
public static final int |
CHAR_VALUE |
14 |
public static final int |
DATE_VALUE |
8 |
public static final int |
DECIMAL_VALUE |
5 |
public static final int |
DOUBLE_VALUE |
7 |
public static final int |
FLOAT_VALUE |
6 |
public static final int |
INT_VALUE |
3 |
public static final int |
LOCAL_ZONED_TIMESTAMP_VALUE |
19 |
public static final int |
MAP_VALUE |
17 |
public static final int |
MULTISET_VALUE |
18 |
public static final int |
NULL_VALUE |
21 |
public static final int |
ROW_VALUE |
0 |
public static final int |
SMALLINT_VALUE |
2 |
public static final int |
TIME_VALUE |
9 |
public static final int |
TIMESTAMP_VALUE |
10 |
public static final int |
TINYINT_VALUE |
1 |
public static final int |
VARBINARY_VALUE |
13 |
public static final int |
VARCHAR_VALUE |
15 |
public static final int |
ZONED_TIMESTAMP_VALUE |
20 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LENGTH_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
LENGTH_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
PRECISION_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
STATE_NAME_FIELD_NUMBER |
1 |
public static final int |
STATE_TTL_CONFIG_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CLEANUP_STRATEGIES_FIELD_NUMBER |
5 |
public static final int |
STATE_VISIBILITY_FIELD_NUMBER |
2 |
public static final int |
TTL_FIELD_NUMBER |
4 |
public static final int |
TTL_TIME_CHARACTERISTIC_FIELD_NUMBER |
3 |
public static final int |
UPDATE_TYPE_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
IS_CLEANUP_IN_BACKGROUND_FIELD_NUMBER |
1 |
public static final int |
STRATEGIES_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
EMPTY_STRATEGY_VALUE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CLEANUP_SIZE_FIELD_NUMBER |
1 |
public static final int |
RUN_CLEANUP_FOR_EVERY_RECORD_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
EMPTY_STRATEGY_FIELD_NUMBER |
2 |
public static final int |
INCREMENTAL_CLEANUP_STRATEGY_FIELD_NUMBER |
3 |
public static final int |
ROCKSDB_COMPACT_FILTER_CLEANUP_STRATEGY_FIELD_NUMBER |
4 |
public static final int |
STRATEGY_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
QUERY_TIME_AFTER_NUM_ENTRIES_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FULL_STATE_SCAN_SNAPSHOT_VALUE |
0 |
public static final int |
INCREMENTAL_CLEANUP_VALUE |
1 |
public static final int |
ROCKSDB_COMPACTION_FILTER_VALUE |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NeverReturnExpired_VALUE |
1 |
public static final int |
ReturnExpiredIfNotCleanedUp_VALUE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ProcessingTime_VALUE |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
Disabled_VALUE |
0 |
public static final int |
OnCreateAndWrite_VALUE |
1 |
public static final int |
OnReadAndWrite_VALUE |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
AVRO_TYPE_INFO_FIELD_NUMBER |
6 |
public static final int |
COLLECTION_ELEMENT_TYPE_FIELD_NUMBER |
2 |
public static final int |
MAP_TYPE_INFO_FIELD_NUMBER |
5 |
public static final int |
ROW_TYPE_INFO_FIELD_NUMBER |
3 |
public static final int |
TUPLE_TYPE_INFO_FIELD_NUMBER |
4 |
public static final int |
TYPE_NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SCHEMA_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KEY_TYPE_FIELD_NUMBER |
1 |
public static final int |
VALUE_TYPE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FIELDS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FIELD_NAME_FIELD_NUMBER |
1 |
public static final int |
FIELD_TYPE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FIELD_TYPES_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
AVRO_VALUE |
23 |
public static final int |
BASIC_ARRAY_VALUE |
15 |
public static final int |
BIG_DEC_VALUE |
11 |
public static final int |
BIG_INT_VALUE |
10 |
public static final int |
BOOLEAN_VALUE |
3 |
public static final int |
BYTE_VALUE |
2 |
public static final int |
CHAR_VALUE |
9 |
public static final int |
DOUBLE_VALUE |
8 |
public static final int |
FLOAT_VALUE |
7 |
public static final int |
INSTANT_VALUE |
22 |
public static final int |
INT_VALUE |
5 |
public static final int |
LIST_VALUE |
18 |
public static final int |
LOCAL_DATE_VALUE |
24 |
public static final int |
LOCAL_DATETIME_VALUE |
26 |
public static final int |
LOCAL_TIME_VALUE |
25 |
public static final int |
LOCAL_ZONED_TIMESTAMP_VALUE |
27 |
public static final int |
LONG_VALUE |
6 |
public static final int |
MAP_VALUE |
19 |
public static final int |
OBJECT_ARRAY_VALUE |
21 |
public static final int |
PICKLED_BYTES_VALUE |
20 |
public static final int |
PRIMITIVE_ARRAY_VALUE |
16 |
public static final int |
ROW_VALUE |
0 |
public static final int |
SHORT_VALUE |
4 |
public static final int |
SQL_DATE_VALUE |
12 |
public static final int |
SQL_TIME_VALUE |
13 |
public static final int |
SQL_TIMESTAMP_VALUE |
14 |
public static final int |
STRING_VALUE |
1 |
public static final int |
TUPLE_VALUE |
17 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DISTINCT_FIELD_NUMBER |
5 |
public static final int |
FILTER_ARG_FIELD_NUMBER |
4 |
public static final int |
INPUTS_FIELD_NUMBER |
2 |
public static final int |
PAYLOAD_FIELD_NUMBER |
1 |
public static final int |
SPECS_FIELD_NUMBER |
3 |
public static final int |
TAKES_ROW_AS_INPUT_FIELD_NUMBER |
6 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FIELD_INDEX_FIELD_NUMBER |
2 |
public static final int |
LIST_VIEW_FIELD_NUMBER |
3 |
public static final int |
MAP_VIEW_FIELD_NUMBER |
4 |
public static final int |
NAME_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ELEMENT_TYPE_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
KEY_TYPE_FIELD_NUMBER |
1 |
public static final int |
VALUE_TYPE_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COUNT_STAR_INSERTED_FIELD_NUMBER |
11 |
public static final int |
GENERATE_UPDATE_BEFORE_FIELD_NUMBER |
4 |
public static final int |
GROUP_WINDOW_FIELD_NUMBER |
12 |
public static final int |
GROUPING_FIELD_NUMBER |
3 |
public static final int |
INDEX_OF_COUNT_STAR_FIELD_NUMBER |
6 |
public static final int |
JOB_PARAMETERS_FIELD_NUMBER |
14 |
public static final int |
KEY_TYPE_FIELD_NUMBER |
5 |
public static final int |
MAP_STATE_READ_CACHE_SIZE_FIELD_NUMBER |
9 |
public static final int |
MAP_STATE_WRITE_CACHE_SIZE_FIELD_NUMBER |
10 |
public static final int |
METRIC_ENABLED_FIELD_NUMBER |
2 |
public static final int |
PROFILE_ENABLED_FIELD_NUMBER |
13 |
public static final int |
STATE_CACHE_SIZE_FIELD_NUMBER |
8 |
public static final int |
STATE_CLEANING_ENABLED_FIELD_NUMBER |
7 |
public static final int |
UDFS_FIELD_NUMBER |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FUNCTION_TYPE_FIELD_NUMBER |
1 |
public static final int |
HAS_SIDE_OUTPUT_FIELD_NUMBER |
7 |
public static final int |
KEY_TYPE_INFO_FIELD_NUMBER |
5 |
public static final int |
MAP_STATE_READ_CACHE_SIZE_FIELD_NUMBER |
9 |
public static final int |
MAP_STATE_WRITE_CACHE_SIZE_FIELD_NUMBER |
10 |
public static final int |
METRIC_ENABLED_FIELD_NUMBER |
4 |
public static final int |
PAYLOAD_FIELD_NUMBER |
3 |
public static final int |
PROFILE_ENABLED_FIELD_NUMBER |
6 |
public static final int |
RUNTIME_CONTEXT_FIELD_NUMBER |
2 |
public static final int |
STATE_CACHE_SIZE_FIELD_NUMBER |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CO_BROADCAST_PROCESS_VALUE |
5 |
public static final int |
CO_PROCESS_VALUE |
1 |
public static final int |
KEYED_CO_BROADCAST_PROCESS_VALUE |
6 |
public static final int |
KEYED_CO_PROCESS_VALUE |
3 |
public static final int |
KEYED_PROCESS_VALUE |
2 |
public static final int |
PROCESS_VALUE |
0 |
public static final int |
REVISE_OUTPUT_VALUE |
100 |
public static final int |
WINDOW_VALUE |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ATTEMPT_NUMBER_FIELD_NUMBER |
6 |
public static final int |
IN_BATCH_EXECUTION_MODE_FIELD_NUMBER |
8 |
public static final int |
INDEX_OF_THIS_SUBTASK_FIELD_NUMBER |
5 |
public static final int |
JOB_PARAMETERS_FIELD_NUMBER |
7 |
public static final int |
MAX_NUMBER_OF_PARALLEL_SUBTASKS_FIELD_NUMBER |
4 |
public static final int |
NUMBER_OF_PARALLEL_SUBTASKS_FIELD_NUMBER |
3 |
public static final int |
TASK_NAME_FIELD_NUMBER |
1 |
public static final int |
TASK_NAME_WITH_SUBTASKS_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INPUTS_FIELD_NUMBER |
2 |
public static final int |
IS_PANDAS_UDF_FIELD_NUMBER |
5 |
public static final int |
PAYLOAD_FIELD_NUMBER |
1 |
public static final int |
TAKES_ROW_AS_INPUT_FIELD_NUMBER |
4 |
public static final int |
WINDOW_INDEX_FIELD_NUMBER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
JOB_PARAMETERS_FIELD_NUMBER |
5 |
public static final int |
METRIC_ENABLED_FIELD_NUMBER |
2 |
public static final int |
PROFILE_ENABLED_FIELD_NUMBER |
4 |
public static final int |
UDFS_FIELD_NUMBER |
1 |
public static final int |
WINDOWS_FIELD_NUMBER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"avro" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"avro" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"avro-confluent" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"debezium-avro-confluent" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"json" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ISO_8601 |
"ISO-8601" |
public static final String |
JSON_MAP_NULL_KEY_MODE_DROP |
"DROP" |
public static final String |
JSON_MAP_NULL_KEY_MODE_FAIL |
"FAIL" |
public static final String |
JSON_MAP_NULL_KEY_MODE_LITERAL |
"LITERAL" |
public static final String |
SQL |
"SQL" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"canal-json" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"debezium-json" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"maxwell-json" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"ogg-json" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"parquet" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
JULIAN_EPOCH_OFFSET_DAYS |
2440588 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CODEGEN_SPLIT_THRESHOLD |
4000 |
public static final String |
GENERATED_DECODE_METHOD |
"decode" |
public static final String |
GENERATED_ENCODE_METHOD |
"encode" |
public static final String |
PB_MAP_KEY_NAME |
"key" |
public static final String |
PB_MAP_VALUE_NAME |
"value" |
public static final String |
PB_METHOD_GET_DESCRIPTOR |
"getDescriptor" |
public static final String |
PB_METHOD_PARSE_FROM |
"parseFrom" |
public static final String |
PB_OUTER_CLASS_SUFFIX |
"OuterClass" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"protobuf" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"raw" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BIG_ENDIAN |
"big-endian" |
public static final String |
LITTLE_ENDIAN |
"little-endian" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NO_COMPRESSION |
"NO_COMPRESSION" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AZURE_STORAGE_KEY_ENV_VARIABLE |
"AZURE_STORAGE_KEY" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SCHEME |
"gs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COMPOSE_MAX_BLOBS |
32 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MULTIPART_UPLOAD_PART_SIZE_MIN |
10485760L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
S3_MULTIPART_MIN_PART_SIZE |
5242880L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PROVIDER_CONFIG_NAME |
"fs.s3a.aws.credentials.provider" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMPONENT |
"Dynamic session credentials for Flink" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXTERNAL_RESOURCE_KUBERNETES_CONFIG_KEY_SUFFIX |
"kubernetes.config-key" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LEADER_ANNOTATION_KEY |
"control-plane.alpha.kubernetes.io/leader" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HEADLESS_CLUSTER_IP |
"None" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
API_VERSION |
"v1" |
public static final String |
APPS_API_VERSION |
"apps/v1" |
public static final int |
BLOB_SERVER_PORT |
6124 |
public static final String |
BLOB_SERVER_PORT_NAME |
"blobserver" |
public static final String |
CHECKPOINT_COUNTER_KEY |
"counter" |
public static final String |
CHECKPOINT_ID_KEY_PREFIX |
"checkpointID-" |
public static final String |
COMPLETED_CHECKPOINT_FILE_SUFFIX |
"completedCheckpoint" |
public static final String |
CONFIG_FILE_LOG4J_NAME |
"log4j-console.properties" |
public static final String |
CONFIG_FILE_LOGBACK_NAME |
"logback-console.xml" |
public static final String |
CONFIG_MAP_PREFIX |
"flink-config-" |
public static final String |
DNS_POLICY_DEFAULT |
"ClusterFirst" |
public static final String |
DNS_POLICY_HOSTNETWORK |
"ClusterFirstWithHostNet" |
public static final String |
ENV_FLINK_LOG_DIR |
"FLINK_LOG_DIR" |
public static final String |
ENV_FLINK_POD_IP_ADDRESS |
"_POD_IP_ADDRESS" |
public static final String |
ENV_FLINK_POD_NODE_ID |
"_POD_NODE_ID" |
public static final String |
ENV_HADOOP_CONF_DIR |
"HADOOP_CONF_DIR" |
public static final String |
ENV_HADOOP_HOME |
"HADOOP_HOME" |
public static final String |
ENV_TM_JVM_MEM_OPTS |
"FLINK_TM_JVM_MEM_OPTS" |
public static final String |
FLINK_CONF_VOLUME |
"flink-config-volume" |
public static final String |
FLINK_REST_SERVICE_SUFFIX |
"-rest" |
public static final String |
HADOOP_CONF_CONFIG_MAP_PREFIX |
"hadoop-config-" |
public static final String |
HADOOP_CONF_DIR_IN_POD |
"/opt/hadoop/conf" |
public static final String |
HADOOP_CONF_VOLUME |
"hadoop-config-volume" |
public static final String |
JOB_GRAPH_STORE_KEY_PREFIX |
"jobGraph-" |
public static final String |
JOB_MANAGER_RPC_PORT_NAME |
"jobmanager-rpc" |
public static final String |
KERBEROS_KEYTAB_MOUNT_POINT |
"/opt/kerberos/kerberos-keytab" |
public static final String |
KERBEROS_KEYTAB_SECRET_PREFIX |
"kerberos-keytab-" |
public static final String |
KERBEROS_KEYTAB_VOLUME |
"kerberos-keytab-volume" |
public static final String |
KERBEROS_KRB5CONF_CONFIG_MAP_PREFIX |
"kerberos-krb5conf-" |
public static final String |
KERBEROS_KRB5CONF_FILE |
"krb5.conf" |
public static final String |
KERBEROS_KRB5CONF_MOUNT_DIR |
"/etc" |
public static final String |
KERBEROS_KRB5CONF_VOLUME |
"kerberos-krb5conf-volume" |
public static final String |
KUBERNETES_JOB_MANAGER_SCRIPT_PATH |
"kubernetes-jobmanager.sh" |
public static final String |
KUBERNETES_TASK_MANAGER_SCRIPT_PATH |
"kubernetes-taskmanager.sh" |
public static final String |
KUBERNETES_ZERO_RESOURCE_VERSION |
"0" |
public static final String |
LABEL_APP_KEY |
"app" |
public static final String |
LABEL_COMPONENT_JOB_MANAGER |
"jobmanager" |
public static final String |
LABEL_COMPONENT_KEY |
"component" |
public static final String |
LABEL_COMPONENT_TASK_MANAGER |
"taskmanager" |
public static final String |
LABEL_CONFIGMAP_TYPE_HIGH_AVAILABILITY |
"high-availability" |
public static final String |
LABEL_CONFIGMAP_TYPE_KEY |
"configmap-type" |
public static final String |
LABEL_TYPE_KEY |
"type" |
public static final String |
LABEL_TYPE_NATIVE_TYPE |
"flink-native-kubernetes" |
public static final String |
LEADER_ADDRESS_KEY |
"address" |
public static final String |
LEADER_SESSION_ID_KEY |
"sessionId" |
public static final String |
MAIN_CONTAINER_NAME |
"flink-main-container" |
public static final int |
MAXIMUM_CHARACTERS_OF_CLUSTER_ID |
45 |
public static final String |
NAME_SEPARATOR |
"-" |
public static final String |
POD_IP_FIELD_PATH |
"status.podIP" |
public static final String |
POD_NODE_ID_FIELD_PATH |
"spec.nodeName" |
public static final String |
POD_TEMPLATE_CONFIG_MAP_PREFIX |
"pod-template-" |
public static final String |
POD_TEMPLATE_DIR_IN_POD |
"/opt/flink/pod-template" |
public static final String |
POD_TEMPLATE_VOLUME |
"pod-template-volume" |
public static final String |
RESOURCE_NAME_CPU |
"cpu" |
public static final String |
RESOURCE_NAME_MEMORY |
"memory" |
public static final String |
RESOURCE_UNIT_MB |
"Mi" |
public static final int |
REST_PORT |
8081 |
public static final String |
REST_PORT_NAME |
"rest" |
public static final String |
RESTART_POLICY_OF_NEVER |
"Never" |
public static final String |
SUBMITTED_JOBGRAPH_FILE_PREFIX |
"submittedJobGraph" |
public static final String |
TASK_MANAGER_POD_TEMPLATE_FILE_NAME |
"taskmanager-pod-template.yaml" |
public static final int |
TASK_MANAGER_RPC_PORT |
6122 |
public static final String |
TASK_MANAGER_RPC_PORT_NAME |
"taskmanager-rpc" |
public static final String |
USER_ARTIFACTS_VOLUME |
"user-artifacts-volume" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
UPDATE_INTERVAL_SECONDS |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARG_PROTOCOL |
"protocol" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ARG_HOST |
"host" |
public static final String |
ARG_PORT |
"port" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DELIMITER |
"." |
public static final String |
ROOT_METRIC_GROUP_NAME |
"rootMetricGroup" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HINT_LOCAL_STRATEGY |
"LOCAL_STRATEGY" |
public static final String |
HINT_LOCAL_STRATEGY_COMBINING_SORT |
"LOCAL_STRATEGY_COMBINING_SORT" |
public static final String |
HINT_LOCAL_STRATEGY_HASH_BUILD_FIRST |
"LOCAL_STRATEGY_HASH_BUILD_FIRST" |
public static final String |
HINT_LOCAL_STRATEGY_HASH_BUILD_SECOND |
"LOCAL_STRATEGY_HASH_BUILD_SECOND" |
public static final String |
HINT_LOCAL_STRATEGY_MERGE |
"LOCAL_STRATEGY_MERGE" |
public static final String |
HINT_LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_FIRST |
"LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_FIRST" |
public static final String |
HINT_LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_SECOND |
"LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_SECOND" |
public static final String |
HINT_LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_FIRST |
"LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_FIRST" |
public static final String |
HINT_LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_SECOND |
"LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_SECOND" |
public static final String |
HINT_LOCAL_STRATEGY_SORT |
"LOCAL_STRATEGY_SORT" |
public static final String |
HINT_LOCAL_STRATEGY_SORT_BOTH_MERGE |
"LOCAL_STRATEGY_SORT_BOTH_MERGE" |
public static final String |
HINT_LOCAL_STRATEGY_SORT_FIRST_MERGE |
"LOCAL_STRATEGY_SORT_FIRST_MERGE" |
public static final String |
HINT_LOCAL_STRATEGY_SORT_SECOND_MERGE |
"LOCAL_STRATEGY_SORT_SECOND_MERGE" |
public static final String |
HINT_SHIP_STRATEGY |
"INPUT_SHIP_STRATEGY" |
public static final String |
HINT_SHIP_STRATEGY_BROADCAST |
"SHIP_BROADCAST" |
public static final String |
HINT_SHIP_STRATEGY_FIRST_INPUT |
"INPUT_LEFT_SHIP_STRATEGY" |
public static final String |
HINT_SHIP_STRATEGY_FORWARD |
"SHIP_FORWARD" |
public static final String |
HINT_SHIP_STRATEGY_REPARTITION |
"SHIP_REPARTITION" |
public static final String |
HINT_SHIP_STRATEGY_REPARTITION_HASH |
"SHIP_REPARTITION_HASH" |
public static final String |
HINT_SHIP_STRATEGY_REPARTITION_RANGE |
"SHIP_REPARTITION_RANGE" |
public static final String |
HINT_SHIP_STRATEGY_SECOND_INPUT |
"INPUT_RIGHT_SHIP_STRATEGY" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final double |
UNKNOWN |
-1.0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_DYNAMIC_PATH_COST_WEIGHT |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MERGE_ITERATION_AUX_TASKS_KEY |
"compiler.merge-iteration-aux" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"orc" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FLINK_CODER_URN |
"flink:coder:v1" |
public static final String |
INPUT_COLLECTION_ID |
"input" |
public static final String |
MAIN_INPUT_NAME |
"input" |
public static final String |
MAIN_OUTPUT_NAME |
"" |
public static final String |
OUTPUT_COLLECTION_ID |
"" |
public static final String |
SIDE_OUTPUT_CODER_PREFIX |
"side_coder-" |
public static final String |
STATEFUL_FUNCTION_URN |
"flink:transform:ds:stateful_function:v1" |
public static final String |
STATELESS_FUNCTION_URN |
"flink:transform:ds:stateless_function:v1" |
public static final String |
TIMER_CODER_ID |
"timer_coder" |
public static final String |
TIMER_ID |
"timer" |
public static final String |
TRANSFORM_ID |
"transform" |
public static final String |
WINDOW_CODER_ID |
"window_coder" |
public static final String |
WINDOW_STRATEGY |
"windowing_strategy" |
public static final String |
WRAPPER_TIMER_CODER_ID |
"timer_coder_wrapper" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PYFLINK_GATEWAY_DISABLED |
"PYFLINK_GATEWAY_DISABLED" |
public static final String |
PYTHON_ARCHIVES_DIR |
"python-archives" |
public static final String |
PYTHON_FILES_DIR |
"python-files" |
public static final String |
PYTHON_REQUIREMENTS_CACHE |
"_PYTHON_REQUIREMENTS_CACHE" |
public static final String |
PYTHON_REQUIREMENTS_DIR |
"python-requirements" |
public static final String |
PYTHON_REQUIREMENTS_FILE |
"_PYTHON_REQUIREMENTS_FILE" |
public static final String |
PYTHON_REQUIREMENTS_INSTALL_DIR |
"_PYTHON_REQUIREMENTS_INSTALL_DIR" |
public static final String |
PYTHON_WORKING_DIR |
"_PYTHON_WORKING_DIR" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEYED_STREAM_VALUE_OPERATOR_NAME |
"_keyed_stream_values_operator" |
public static final String |
STREAM_KEY_BY_MAP_OPERATOR_NAME |
"_stream_key_by_map_operator" |
public static final String |
STREAM_PARTITION_CUSTOM_MAP_OPERATOR_NAME |
"_partition_custom_map_operator" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CACHE |
"cache" |
public static final String |
FILE |
"file" |
public static final String |
FILE_DELIMITER |
"," |
public static final String |
PARAM_DELIMITER |
"#" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PYFLINK_UDF_RUNNER_DIR |
"PYFLINK_UDF_RUNNER_DIR" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SIZE |
20 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BLOB_PATH_NAME |
"blob" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXCEEDED_CHECKPOINT_TOLERABLE_FAILURE_MESSAGE |
"Exceeded checkpoint tolerable failure threshold." |
public static final int |
UNLIMITED_TOLERABLE_FAILURE_NUMBER |
2147483647 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
INITIAL_CHECKPOINT_ID |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
UNSET |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
NO_ALIGNED_CHECKPOINT_TIME_OUT |
9223372036854775807L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HEADER_MAGIC_NUMBER |
1231054637 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
INVALID_CHECKPOINT_ID |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
UNSET |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SEQUENCE_NUMBER_RESTORED |
-1 |
public static final int |
SEQUENCE_NUMBER_UNKNOWN |
-2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LOGICAL_FILE_COUNT |
"fileMerging.logicalFileCount" |
public static final String |
LOGICAL_FILE_SIZE |
"fileMerging.logicalFileSize" |
public static final String |
PHYSICAL_FILE_COUNT |
"fileMerging.physicalFileCount" |
public static final String |
PHYSICAL_FILE_SIZE |
"fileMerging.physicalFileSize" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DISPATCHER_NAME |
"dispatcher" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
RUNTIME_FAILURE_RETURN_CODE |
2 |
protected static final int |
STARTUP_FAILURE_RETURN_CODE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
NUM_BYTES_UNKNOWN |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FAILURE_LABEL_ATTRIBUTE_PREFIX |
"failureLabel." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FULL_RESTART_STRATEGY_NAME |
"full" |
public static final String |
PIPELINED_REGION_RESTART_STRATEGY_NAME |
"region" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_NAME |
"downtime" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_NAME |
"uptime" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MIN_SKIP_BYTES |
1048576 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CPU_CORES |
"cpuCores" |
public static final String |
FIELD_NAME_SIZE_JVM_HEAP |
"freeMemory" |
public static final String |
FIELD_NAME_SIZE_MANAGED_MEMORY |
"managedMemory" |
public static final String |
FIELD_NAME_SIZE_PHYSICAL_MEMORY |
"physicalMemory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HEADER_LENGTH |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NUM_BYTES_PER_REQUEST |
4194304 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final short |
FLAG_LAST_BLOCK |
1 |
protected static final int |
HEAD_BLOCK_LENGTH_OFFSET |
4 |
protected static final int |
HEADER_FLAGS_OFFSET |
2 |
protected static final int |
HEADER_LENGTH |
8 |
protected static final short |
HEADER_MAGIC_NUMBER |
-16130 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_FILE_BUFFER_SIZE |
2097152 |
public static final int |
DEFAULT_THRESHOLD_FOR_SPILLING |
5242880 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_OUTPUT_FLUSH_THREAD_NAME |
"OutputFlusher" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
UNBOUNDED_POOL_SIZE |
2147483647 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_GROUP_INPUT |
"Input" |
public static final String |
METRIC_GROUP_OUTPUT |
"Output" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HEADER_LENGTH |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CONSERVATIVE_PAGE_SIZE_MULTIPLE |
65536 |
public static final int |
DEFAULT_PAGE_SIZE |
4096 |
public static final int |
PAGE_SIZE_UNKNOWN |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DATA_FILE_SUFFIX |
".shuffle.data" |
public static final int |
INDEX_ENTRY_SIZE |
16 |
public static final String |
INDEX_FILE_SUFFIX |
".shuffle.index" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
ADD_BUFFER_ERROR_CODE |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
INDEX_ENTRY_SIZE |
16 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH |
1000 |
public static final int |
DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM |
2147483647 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DATA_FILE_SUFFIX |
".tier-storage.data" |
public static final String |
INDEX_FILE_SUFFIX |
".tier-storage.index" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
REGION_SIZE |
24 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AGGREGATOR_NAME |
"pact.runtime.workset-empty-aggregator" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_PARALLELISM_DEFAULT |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DISABLED_CHECKPOINT_INTERVAL |
9223372036854775807L |
public static final long |
MINIMAL_CHECKPOINT_TIME |
10L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JOB_MANAGER_NAME |
"jobmanager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_PAGE_SIZE |
32768 |
public static final int |
MIN_PAGE_SIZE |
4096 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SLOTS_AVAILABLE |
"slots-available" |
public static final String |
FIELD_NAME_SLOTS_FREE_AND_BLOCKED |
"slots-free-and-blocked" |
public static final String |
FIELD_NAME_SLOTS_TOTAL |
"slots-total" |
public static final String |
FIELD_NAME_TASKMANAGERS |
"taskmanagers" |
public static final String |
FIELD_NAME_TASKMANAGERS_BLOCKED |
"taskmanagers-blocked" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOBS |
"jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_ID |
"id" |
public static final String |
FIELD_NAME_JOB_STATUS |
"status" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOBS_CANCELLED |
"jobs-cancelled" |
public static final String |
FIELD_NAME_JOBS_FAILED |
"jobs-failed" |
public static final String |
FIELD_NAME_JOBS_FINISHED |
"jobs-finished" |
public static final String |
FIELD_NAME_JOBS_RUNNING |
"jobs-running" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_STATUS |
"status" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOBS |
"jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ACC_TASK_BACK_PRESSURED_TIME |
"accumulateBackPressuredTimeMs" |
public static final String |
ACC_TASK_BUSY_TIME |
"accumulateBusyTimeMs" |
public static final String |
ACC_TASK_IDLE_TIME |
"accumulateIdleTimeMs" |
public static final String |
ALREADY_COMMITTED_COMMITTABLES |
"alreadyCommittedCommittables" |
public static final String |
CHANGELOG_BUSY_TIME |
"changelogBusyTimeMsPerSecond" |
public static final String |
CHECKPOINT_ALIGNMENT_TIME |
"checkpointAlignmentTime" |
public static final String |
CHECKPOINT_START_DELAY_TIME |
"checkpointStartDelayNanos" |
public static final String |
CURRENT_EMIT_EVENT_TIME_LAG |
"currentEmitEventTimeLag" |
public static final String |
CURRENT_FETCH_EVENT_TIME_LAG |
"currentFetchEventTimeLag" |
public static final String |
CURRENT_SEND_TIME |
"currentSendTime" |
public static final String |
DEBLOATED_BUFFER_SIZE |
"debloatedBufferSize" |
public static final String |
DOWNLOAD_STATE_DURATION |
"DownloadStateDurationMs" |
public static final String |
ESTIMATED_TIME_TO_CONSUME_BUFFERS |
"estimatedTimeToConsumeBuffersMs" |
public static final String |
FAILED_COMMITTABLES |
"failedCommittables" |
public static final String |
FULL_RESTARTS |
"fullRestarts" |
public static final String |
GATE_RESTORE_DURATION |
"GateRestoreDurationMs" |
public static final String |
HIT_COUNT |
"hitCount" |
public static final String |
INITIALIZATION_TIME |
"initializationTime" |
public static final String |
INITIALIZE_STATE_DURATION |
"InitializeStateDurationMs" |
public static final String |
IO_CURRENT_INPUT_1_WATERMARK |
"currentInput1Watermark" |
public static final String |
IO_CURRENT_INPUT_2_WATERMARK |
"currentInput2Watermark" |
public static final String |
IO_CURRENT_INPUT_WATERMARK |
"currentInputWatermark" |
public static final String |
IO_CURRENT_INPUT_WATERMARK_PATERN |
"currentInput%dWatermark" |
public static final String |
IO_CURRENT_OUTPUT_WATERMARK |
"currentOutputWatermark" |
public static final String |
IO_NUM_BUFFERS_IN |
"numBuffersIn" |
public static final String |
IO_NUM_BUFFERS_OUT |
"numBuffersOut" |
public static final String |
IO_NUM_BUFFERS_OUT_RATE |
"numBuffersOutPerSecond" |
public static final String |
IO_NUM_BYTES_IN |
"numBytesIn" |
public static final String |
IO_NUM_BYTES_IN_RATE |
"numBytesInPerSecond" |
public static final String |
IO_NUM_BYTES_OUT |
"numBytesOut" |
public static final String |
IO_NUM_BYTES_OUT_RATE |
"numBytesOutPerSecond" |
public static final String |
IO_NUM_RECORDS_IN |
"numRecordsIn" |
public static final String |
IO_NUM_RECORDS_IN_RATE |
"numRecordsInPerSecond" |
public static final String |
IO_NUM_RECORDS_OUT |
"numRecordsOut" |
public static final String |
IO_NUM_RECORDS_OUT_RATE |
"numRecordsOutPerSecond" |
public static final String |
IS_BACK_PRESSURED |
"isBackPressured" |
public static final String |
LATEST_LOAD_TIME |
"latestLoadTime" |
public static final String |
LOAD_COUNT |
"loadCount" |
public static final String |
MAILBOX_LATENCY |
"mailboxLatencyMs" |
public static final String |
MAILBOX_SIZE |
"mailboxQueueSize" |
public static final String |
MAILBOX_START_DURATION |
"MailboxStartDurationMs" |
public static final String |
MAILBOX_THROUGHPUT |
"mailboxMailsPerSecond" |
public static final String |
MEMORY_COMMITTED |
"Committed" |
public static final String |
MEMORY_MAX |
"Max" |
public static final String |
MEMORY_USED |
"Used" |
public static final String |
MISS_COUNT |
"missCount" |
public static final String |
NUM_BYTES_SEND |
"numBytesSend" |
public static final String |
NUM_CACHED_BYTES |
"numCachedBytes" |
public static final String |
NUM_CACHED_RECORDS |
"numCachedRecords" |
public static final String |
NUM_EFFECTIVE_SPECULATIVE_EXECUTIONS |
"numEffectiveSpeculativeExecutions" |
public static final String |
NUM_FIRED_TIMERS |
"numFiredTimers" |
public static final String |
NUM_FIRED_TIMERS_RATE |
"numFiredTimersPerSecond" |
public static final String |
NUM_LOAD_FAILURES |
"numLoadFailures" |
public static final String |
NUM_PENDING_TASK_MANAGERS |
"numPendingTaskManagers" |
public static final String |
NUM_RECORDS_IN_ERRORS |
"numRecordsInErrors" |
public static final String |
NUM_RECORDS_OUT_ERRORS |
"numRecordsOutErrors" |
public static final String |
NUM_RECORDS_SEND |
"numRecordsSend" |
public static final String |
NUM_RECORDS_SEND_ERRORS |
"numRecordsSendErrors" |
public static final String |
NUM_REGISTERED_TASK_MANAGERS |
"numRegisteredTaskManagers" |
public static final String |
NUM_RESTARTS |
"numRestarts" |
public static final String |
NUM_RUNNING_JOBS |
"numRunningJobs" |
public static final String |
NUM_SLOW_EXECUTION_VERTICES |
"numSlowExecutionVertices" |
public static final String |
PENDING_BYTES |
"pendingBytes" |
public static final String |
PENDING_COMMITTABLES |
"pendingCommittables" |
public static final String |
PENDING_RECORDS |
"pendingRecords" |
public static final String |
READ_OUTPUT_DATA_DURATION |
"ReadOutputDataDurationMs" |
public static final String |
RESTORE_ASYNC_COMPACTION_DURATION |
"RestoreAsyncCompactionDurationMs" |
public static final String |
RESTORE_STATE_DURATION |
"RestoreStateDurationMs" |
public static final String |
RESTORED_STATE_SIZE |
"RestoredStateSizeBytes" |
public static final String |
RETRIED_COMMITTABLES |
"retriedCommittables" |
public static final String |
SOURCE_IDLE_TIME |
"sourceIdleTime" |
public static final String |
START_WORKER_FAILURE_RATE |
"startWorkFailurePerSecond" |
public static final String |
SUCCESSFUL_COMMITTABLES |
"successfulCommittables" |
public static final String |
SUFFIX_RATE |
"PerSecond" |
public static final String |
TASK_BACK_PRESSURED_TIME |
"backPressuredTimeMsPerSecond" |
public static final String |
TASK_BUSY_TIME |
"busyTimeMsPerSecond" |
public static final String |
TASK_HARD_BACK_PRESSURED_TIME |
"hardBackPressuredTimeMsPerSecond" |
public static final String |
TASK_IDLE_TIME |
"idleTimeMsPerSecond" |
public static final String |
TASK_MAX_HARD_BACK_PRESSURED_TIME |
"maxHardBackPressureTimeMs" |
public static final String |
TASK_MAX_SOFT_BACK_PRESSURED_TIME |
"maxSoftBackPressureTimeMs" |
public static final String |
TASK_SLOTS_AVAILABLE |
"taskSlotsAvailable" |
public static final String |
TASK_SLOTS_TOTAL |
"taskSlotsTotal" |
public static final String |
TASK_SOFT_BACK_PRESSURED_TIME |
"softBackPressuredTimeMsPerSecond" |
public static final String |
TOTAL_COMMITTABLES |
"totalCommittables" |
public static final String |
UNASSIGNED_SPLITS |
"unassignedSplits" |
public static final String |
WATERMARK_ALIGNMENT_DRIFT |
"watermarkAlignmentDrift" |
public static final String |
WATERMARK_LAG |
"watermarkLag" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
METRIC_CATEGORY_COUNTER |
0 |
public static final byte |
METRIC_CATEGORY_GAUGE |
1 |
public static final byte |
METRIC_CATEGORY_HISTOGRAM |
2 |
public static final byte |
METRIC_CATEGORY_METER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_QUERY_SERVICE_NAME |
"MetricQueryService" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
INFO_CATEGORY_JM |
0 |
public static final byte |
INFO_CATEGORY_JM_OPERATOR |
5 |
public static final byte |
INFO_CATEGORY_JOB |
2 |
public static final byte |
INFO_CATEGORY_OPERATOR |
4 |
public static final byte |
INFO_CATEGORY_TASK |
3 |
public static final byte |
INFO_CATEGORY_TM |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
UNINITIALIZED |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
UNDEFINED |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SCOPE_INHERIT_PARENT |
"*" |
public static final String |
SCOPE_SEPARATOR |
"." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
BATCH_CHECKPOINT_ID |
-1L |
public static final long |
NO_CHECKPOINT |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
RESOURCE_MANAGER_NAME |
"resourcemanager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HTTP_ATTRIBUTE_REQUEST |
"request" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
VERSION_PLACEHOLDER |
"{{VERSION}}" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_OPERATION |
"operation" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HTTP_DATE_FORMAT |
"EEE, dd MMM yyyy HH:mm:ss zzz" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COMMIT |
"flink-commit" |
public static final String |
FIELD_NAME_VERSION |
"flink-version" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_METRICS |
"metrics" |
public static final String |
FIELD_NAME_STATUS_DURATION |
"status-duration" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CLUSTER_CONFIG_REST_PATH |
"/jobmanager/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/overview" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CONFIG_KEY |
"key" |
public static final String |
FIELD_NAME_CONFIG_VALUE |
"value" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_FEATURE_WEB_CANCEL |
"web-cancel" |
public static final String |
FIELD_NAME_FEATURE_WEB_HISTORY |
"web-history" |
public static final String |
FIELD_NAME_FEATURE_WEB_RESCALE |
"web-rescale" |
public static final String |
FIELD_NAME_FEATURE_WEB_SUBMIT |
"web-submit" |
public static final String |
FIELD_NAME_FLINK_FEATURES |
"features" |
public static final String |
FIELD_NAME_FLINK_REVISION |
"flink-revision" |
public static final String |
FIELD_NAME_FLINK_VERSION |
"flink-version" |
public static final String |
FIELD_NAME_REFRESH_INTERVAL |
"refresh-interval" |
public static final String |
FIELD_NAME_TIMEZONE_NAME |
"timezone-name" |
public static final String |
FIELD_NAME_TIMEZONE_OFFSET |
"timezone-offset" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"type" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_ACCUMULATORS |
"job-accumulators" |
public static final String |
FIELD_NAME_SERIALIZED_USER_TASK_ACCUMULATORS |
"serialized-user-task-accumulators" |
public static final String |
FIELD_NAME_USER_TASK_ACCUMULATORS |
"user-task-accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ACC_NAME |
"name" |
public static final String |
FIELD_NAME_ACC_TYPE |
"type" |
public static final String |
FIELD_NAME_ACC_VALUE |
"value" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/clientHeartbeat" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_EXECUTION_CONFIG |
"execution-config" |
public static final String |
FIELD_NAME_JOB_ID |
"jid" |
public static final String |
FIELD_NAME_JOB_NAME |
"name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_GLOBAL_JOB_PARAMETERS |
"user-config" |
public static final String |
FIELD_NAME_OBJECT_REUSE_MODE |
"object-reuse-mode" |
public static final String |
FIELD_NAME_PARALLELISM |
"job-parallelism" |
public static final String |
FIELD_NAME_RESTART_STRATEGY |
"restart-strategy" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/exceptions" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_EXCEPTION_HISTORY |
"exceptionHistory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ENDPOINT |
"endpoint" |
public static final String |
FIELD_NAME_EXCEPTION_NAME |
"exceptionName" |
public static final String |
FIELD_NAME_EXCEPTION_STACKTRACE |
"stacktrace" |
public static final String |
FIELD_NAME_EXCEPTION_TIMESTAMP |
"timestamp" |
public static final String |
FIELD_NAME_FAILURE_LABELS |
"failureLabels" |
public static final String |
FIELD_NAME_TASK_MANAGER_ID |
"taskManagerId" |
public static final String |
FIELD_NAME_TASK_NAME |
"taskName" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ENTRIES |
"entries" |
public static final String |
FIELD_NAME_TRUNCATED |
"truncated" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CONCURRENT_EXCEPTIONS |
"concurrentExceptions" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"jobid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CURRENT_JOB_IDS_REST_PATH |
"/jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JOB_MANAGER_ENV_REST_PATH |
"/jobmanager/environment" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/plan" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/overview" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid/accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_USER_ACCUMULATORS |
"user-accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEPRECATED_FIELD_NAME_BACKPRESSURE_LEVEL |
"backpressure-level" |
public static final String |
FIELD_NAME_BACKPRESSURE_LEVEL |
"backpressureLevel" |
public static final String |
FIELD_NAME_END_TIMESTAMP |
"end-timestamp" |
public static final String |
FIELD_NAME_STATUS |
"status" |
public static final String |
FIELD_NAME_SUBTASKS |
"subtasks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEPRECATED_FIELD_NAME_BACKPRESSURE_LEVEL |
"backpressure-level" |
public static final String |
FIELD_NAME_ATTEMPT_NUMBER |
"attempt-number" |
public static final String |
FIELD_NAME_BACK_PRESSURED_RATIO |
"ratio" |
public static final String |
FIELD_NAME_BACKPRESSURE_LEVEL |
"backpressureLevel" |
public static final String |
FIELD_NAME_BUSY_RATIO |
"busyRatio" |
public static final String |
FIELD_NAME_IDLE_RATIO |
"idleRatio" |
public static final String |
FIELD_NAME_OTHER_CONCURRENT_ATTEMPTS |
"other-concurrent-attempts" |
public static final String |
FIELD_NAME_SUBTASK |
"subtask" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_AGGREGATED |
"aggregated" |
public static final String |
FIELD_NAME_MAX_PARALLELISM |
"maxParallelism" |
public static final String |
FIELD_NAME_NOW |
"now" |
public static final String |
FIELD_NAME_PARALLELISM |
"parallelism" |
public static final String |
FIELD_NAME_SUBTASKS |
"subtasks" |
public static final String |
FIELD_NAME_VERTEX_ID |
"id" |
public static final String |
FIELD_NAME_VERTEX_NAME |
"name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"vertexid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid/taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
VERTEX_TASK_FIELD_ID |
"id" |
public static final String |
VERTEX_TASK_FIELD_NAME |
"name" |
public static final String |
VERTEX_TASK_FIELD_NOW |
"now" |
public static final String |
VERTEX_TASK_FIELD_TASK_MANAGERS |
"taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TASK_MANAGERS_FIELD_AGGREGATED |
"aggregated" |
public static final String |
TASK_MANAGERS_FIELD_DURATION |
"duration" |
public static final String |
TASK_MANAGERS_FIELD_END_TIME |
"end-time" |
public static final String |
TASK_MANAGERS_FIELD_ENDPOINT |
"endpoint" |
public static final String |
TASK_MANAGERS_FIELD_HOST |
"host" |
public static final String |
TASK_MANAGERS_FIELD_METRICS |
"metrics" |
public static final String |
TASK_MANAGERS_FIELD_START_TIME |
"start-time" |
public static final String |
TASK_MANAGERS_FIELD_STATUS |
"status" |
public static final String |
TASK_MANAGERS_FIELD_STATUS_COUNTS |
"status-counts" |
public static final String |
TASK_MANAGERS_FIELD_TASKMANAGER_ID |
"taskmanager-id" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"filename" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MTIME |
"mtime" |
public static final String |
NAME |
"name" |
public static final String |
SIZE |
"size" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_LOGS |
"logs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_LOG_URL |
"url" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"operatorid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"filename" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_FINISHED_TIME |
"finishedTime" |
public static final String |
FIELD_NAME_MESSAGE |
"message" |
public static final String |
FIELD_NAME_MODE |
"mode" |
public static final String |
FIELD_NAME_OUTPUT_FILE |
"outputFile" |
public static final String |
FIELD_NAME_STATUS |
"status" |
public static final String |
FIELD_NAME_TRIGGER_TIME |
"triggerTime" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_FLAME_GRAPHS |
"profilingList" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"parallelism" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CPU |
"cpuCores" |
public static final String |
FIELD_NAME_EXTENDED |
"extendedResources" |
public static final String |
FIELD_NAME_MANAGED |
"managedMemory" |
public static final String |
FIELD_NAME_NETWORK |
"networkMemory" |
public static final String |
FIELD_NAME_TASK_HEAP |
"taskHeapMemory" |
public static final String |
FIELD_NAME_TASK_OFFHEAP |
"taskOffHeapMemory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"subtaskindex" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"subtaskindex" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid/subtasks/accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/vertices/:vertexid/subtasktimes" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_NAME |
"name" |
public static final String |
FIELD_NAME_NOW |
"now" |
public static final String |
FIELD_NAME_SUBTASKS |
"subtasks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_ENDPOINT |
"endpoint" |
public static final String |
FIELD_NAME_HOST |
"host" |
public static final String |
FIELD_NAME_SUBTASK |
"subtask" |
public static final String |
FIELD_NAME_TIMESTAMPS |
"timestamps" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_THREAD_INFOS |
"threadInfos" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_THREAD_INFO |
"stringifiedThreadInfo" |
public static final String |
FIELD_NAME_THREAD_NAME |
"threadName" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"triggerid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/checkpoints/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNED_CHECKPOINT_TIMEOUT |
"aligned_checkpoint_timeout" |
public static final String |
FIELD_NAME_CHANGELOG_STORAGE |
"changelog_storage" |
public static final String |
FIELD_NAME_CHECKPOINT_INTERVAL |
"interval" |
public static final String |
FIELD_NAME_CHECKPOINT_MAX_CONCURRENT |
"max_concurrent" |
public static final String |
FIELD_NAME_CHECKPOINT_MIN_PAUSE |
"min_pause" |
public static final String |
FIELD_NAME_CHECKPOINT_STORAGE |
"checkpoint_storage" |
public static final String |
FIELD_NAME_CHECKPOINT_TIMEOUT |
"timeout" |
public static final String |
FIELD_NAME_CHECKPOINTS_AFTER_TASKS_FINISH |
"checkpoints_after_tasks_finish" |
public static final String |
FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG |
"externalization" |
public static final String |
FIELD_NAME_PERIODIC_MATERIALIZATION_INTERVAL |
"changelog_periodic_materialization_interval" |
public static final String |
FIELD_NAME_PROCESSING_MODE |
"mode" |
public static final String |
FIELD_NAME_STATE_BACKEND |
"state_backend" |
public static final String |
FIELD_NAME_STATE_CHANGELOG |
"state_changelog_enabled" |
public static final String |
FIELD_NAME_TOLERABLE_FAILED_CHECKPOINTS |
"tolerable_failed_checkpoints" |
public static final String |
FIELD_NAME_UNALIGNED_CHECKPOINTS |
"unaligned_checkpoints" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DELETE_ON_CANCELLATION |
"delete_on_cancellation" |
public static final String |
FIELD_NAME_ENABLED |
"enabled" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"checkpointid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COUNTS |
"counts" |
public static final String |
FIELD_NAME_HISTORY |
"history" |
public static final String |
FIELD_NAME_LATEST_CHECKPOINTS |
"latest" |
public static final String |
FIELD_NAME_SUMMARY |
"summary" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COMPLETED_CHECKPOINTS |
"completed" |
public static final String |
FIELD_NAME_FAILED_CHECKPOINTS |
"failed" |
public static final String |
FIELD_NAME_IN_PROGRESS_CHECKPOINTS |
"in_progress" |
public static final String |
FIELD_NAME_RESTORED_CHECKPOINTS |
"restored" |
public static final String |
FIELD_NAME_TOTAL_CHECKPOINTS |
"total" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COMPLETED |
"completed" |
public static final String |
FIELD_NAME_FAILED |
"failed" |
public static final String |
FIELD_NAME_RESTORED |
"restored" |
public static final String |
FIELD_NAME_SAVEPOINT |
"savepoint" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_EXTERNAL_PATH |
"external_path" |
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_IS_SAVEPOINT |
"is_savepoint" |
public static final String |
FIELD_NAME_RESTORE_TIMESTAMP |
"restore_timestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT_BUFFERED |
"alignment_buffered" |
public static final String |
FIELD_NAME_CHECKPOINTED_SIZE |
"checkpointed_size" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_PERSISTED_DATA |
"persisted_data" |
public static final String |
FIELD_NAME_PROCESSED_DATA |
"processed_data" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/checkpoints" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/checkpoints/details/:checkpointid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT_BUFFERED |
"alignment_buffered" |
public static final String |
FIELD_NAME_CHECKPOINT_TYPE |
"checkpoint_type" |
public static final String |
FIELD_NAME_CHECKPOINTED_SIZE |
"checkpointed_size" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_IS_SAVEPOINT |
"is_savepoint" |
public static final String |
FIELD_NAME_LATEST_ACK_TIMESTAMP |
"latest_ack_timestamp" |
public static final String |
FIELD_NAME_NUM_ACK_SUBTASKS |
"num_acknowledged_subtasks" |
public static final String |
FIELD_NAME_NUM_SUBTASKS |
"num_subtasks" |
public static final String |
FIELD_NAME_PERSISTED_DATA |
"persisted_data" |
public static final String |
FIELD_NAME_PROCESSED_DATA |
"processed_data" |
public static final String |
FIELD_NAME_SAVEPOINT_FORMAT |
"savepointFormat" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
public static final String |
FIELD_NAME_STATUS |
"status" |
public static final String |
FIELD_NAME_TASKS |
"tasks" |
public static final String |
FIELD_NAME_TRIGGER_TIMESTAMP |
"trigger_timestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DISCARDED |
"discarded" |
public static final String |
FIELD_NAME_EXTERNAL_PATH |
"external_path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_FAILURE_MESSAGE |
"failure_message" |
public static final String |
FIELD_NAME_FAILURE_TIMESTAMP |
"failure_timestamp" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_AVERAGE |
"avg" |
public static final String |
FIELD_NAME_MAXIMUM |
"max" |
public static final String |
FIELD_NAME_MINIMUM |
"min" |
public static final String |
FIELD_NAME_P50 |
"p50" |
public static final String |
FIELD_NAME_P90 |
"p90" |
public static final String |
FIELD_NAME_P95 |
"p95" |
public static final String |
FIELD_NAME_P99 |
"p99" |
public static final String |
FIELD_NAME_P999 |
"p999" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_CHECKPOINT_STATUS |
"status" |
public static final String |
FIELD_NAME_INDEX |
"index" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ABORTED |
"aborted" |
public static final String |
FIELD_NAME_ACK_TIMESTAMP |
"ack_timestamp" |
public static final String |
FIELD_NAME_ALIGNMENT |
"alignment" |
public static final String |
FIELD_NAME_CHECKPOINT_DURATION |
"checkpoint" |
public static final String |
FIELD_NAME_CHECKPOINTED_SIZE |
"checkpointed_size" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_START_DELAY |
"start_delay" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
public static final String |
FIELD_NAME_UNALIGNED_CHECKPOINT |
"unaligned_checkpoint" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT_BUFFERED |
"buffered" |
public static final String |
FIELD_NAME_ALIGNMENT_DURATION |
"duration" |
public static final String |
FIELD_NAME_ALIGNMENT_PERSISTED |
"persisted" |
public static final String |
FIELD_NAME_ALIGNMENT_PROCESSED |
"processed" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ASYNC_DURATION |
"async" |
public static final String |
FIELD_NAME_SYNC_DURATION |
"sync" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT_BUFFERED |
"alignment_buffered" |
public static final String |
FIELD_NAME_CHECKPOINT_STATUS |
"status" |
public static final String |
FIELD_NAME_CHECKPOINTED_SIZE |
"checkpointed_size" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_LATEST_ACK_TIMESTAMP |
"latest_ack_timestamp" |
public static final String |
FIELD_NAME_NUM_ACK_SUBTASKS |
"num_acknowledged_subtasks" |
public static final String |
FIELD_NAME_NUM_SUBTASKS |
"num_subtasks" |
public static final String |
FIELD_NAME_PERSISTED_DATA |
"persisted_data" |
public static final String |
FIELD_NAME_PROCESSED_DATA |
"processed_data" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SUBTASKS_CHECKPOINT_STATISTICS |
"subtasks" |
public static final String |
FIELD_NAME_SUMMARY |
"summary" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_BUFFERED_DATA |
"buffered" |
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_PERSISTED |
"persisted" |
public static final String |
FIELD_NAME_PROCESSED |
"processed" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ASYNCHRONOUS_DURATION |
"async" |
public static final String |
FIELD_NAME_SYNCHRONOUS_DURATION |
"sync" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALIGNMENT |
"alignment" |
public static final String |
FIELD_NAME_CHECKPOINT_DURATION |
"checkpoint_duration" |
public static final String |
FIELD_NAME_CHECKPOINTED_SIZE |
"checkpointed_size" |
public static final String |
FIELD_NAME_DURATION |
"end_to_end_duration" |
public static final String |
FIELD_NAME_START_DELAY |
"start_delay" |
public static final String |
FIELD_NAME_STATE_SIZE |
"state_size" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"datasetid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"failureLabelFilter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_END_TIME |
"end-time" |
public static final String |
FIELD_NAME_IS_STOPPABLE |
"isStoppable" |
public static final String |
FIELD_NAME_JOB_ID |
"jid" |
public static final String |
FIELD_NAME_JOB_NAME |
"name" |
public static final String |
FIELD_NAME_JOB_STATUS |
"state" |
public static final String |
FIELD_NAME_JOB_TYPE |
"job-type" |
public static final String |
FIELD_NAME_JOB_VERTEX_INFOS |
"vertices" |
public static final String |
FIELD_NAME_JOB_VERTICES_PER_STATE |
"status-counts" |
public static final String |
FIELD_NAME_JSON_PLAN |
"plan" |
public static final String |
FIELD_NAME_MAX_PARALLELISM |
"maxParallelism" |
public static final String |
FIELD_NAME_NOW |
"now" |
public static final String |
FIELD_NAME_START_TIME |
"start-time" |
public static final String |
FIELD_NAME_TIMESTAMPS |
"timestamps" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_VERTEX_DURATION |
"duration" |
public static final String |
FIELD_NAME_JOB_VERTEX_END_TIME |
"end-time" |
public static final String |
FIELD_NAME_JOB_VERTEX_ID |
"id" |
public static final String |
FIELD_NAME_JOB_VERTEX_METRICS |
"metrics" |
public static final String |
FIELD_NAME_JOB_VERTEX_NAME |
"name" |
public static final String |
FIELD_NAME_JOB_VERTEX_START_TIME |
"start-time" |
public static final String |
FIELD_NAME_JOB_VERTEX_STATE |
"status" |
public static final String |
FIELD_NAME_MAX_PARALLELISM |
"maxParallelism" |
public static final String |
FIELD_NAME_PARALLELISM |
"parallelism" |
public static final String |
FIELD_NAME_SLOT_SHARING_GROUP_ID |
"slotSharingGroupId" |
public static final String |
FIELD_NAME_TASKS_PER_STATE |
"tasks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JOBMANAGER_JOB_CONFIG_REST_PATH |
"/jobs/:jobid/jobmanager/config" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JOBMANAGER_JOB_ENV_REST_PATH |
"/jobs/:jobid/jobmanager/environment" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_GRAPH |
"jobGraphFileName" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_URL |
"jobUrl" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"attempt" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ATTEMPT_NUM |
"attempt" |
public static final String |
FIELD_NAME_ID |
"id" |
public static final String |
FIELD_NAME_SUBTASK_INDEX |
"subtask" |
public static final String |
FIELD_NAME_USER_ACCUMULATORS |
"user-accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ATTEMPT |
"attempt" |
public static final String |
FIELD_NAME_COMPATIBLE_START_TIME |
"start_time" |
public static final String |
FIELD_NAME_DURATION |
"duration" |
public static final String |
FIELD_NAME_END_TIME |
"end-time" |
public static final String |
FIELD_NAME_ENDPOINT |
"endpoint" |
public static final String |
FIELD_NAME_HOST |
"host" |
public static final String |
FIELD_NAME_METRICS |
"metrics" |
public static final String |
FIELD_NAME_OTHER_CONCURRENT_ATTEMPTS |
"other-concurrent-attempts" |
public static final String |
FIELD_NAME_START_TIME |
"start-time" |
public static final String |
FIELD_NAME_STATUS |
"status" |
public static final String |
FIELD_NAME_STATUS_DURATION |
"status-duration" |
public static final String |
FIELD_NAME_SUBTASK_INDEX |
"subtask" |
public static final String |
FIELD_NAME_TASKMANAGER_ID |
"taskmanager-id" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_VERTEX_ID |
"id" |
public static final String |
FIELD_NAME_PARALLELISM |
"parallelism" |
public static final String |
FIELD_NAME_SUBTASKS |
"subtasks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ATTEMPT_NUM |
"attempt" |
public static final String |
FIELD_NAME_ENDPOINT |
"endpoint" |
public static final String |
FIELD_NAME_HOST |
"host" |
public static final String |
FIELD_NAME_SUBTASK_INDEX |
"subtask" |
public static final String |
FIELD_NAME_USER_ACCUMULATORS |
"user-accumulators" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"maxExceptions" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ACC_NAME |
"name" |
public static final String |
FIELD_NAME_ACC_TYPE |
"type" |
public static final String |
FIELD_NAME_ACC_VALUE |
"value" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jobs/:jobid/coordinators/:operatorid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SERIALIZED_COORDINATION_REQUEST |
"serializedCoordinationRequest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SERIALIZED_COORDINATION_RESULT |
"serializedCoordinationResult" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ACC_BACK_PRESSURE |
"accumulated-backpressured-time" |
public static final String |
FIELD_NAME_ACC_BUSY |
"accumulated-busy-time" |
public static final String |
FIELD_NAME_ACC_IDLE |
"accumulated-idle-time" |
public static final String |
FIELD_NAME_BYTES_READ |
"read-bytes" |
public static final String |
FIELD_NAME_BYTES_WRITTEN |
"write-bytes" |
public static final String |
FIELD_NAME_RECORDS_READ |
"read-records" |
public static final String |
FIELD_NAME_RECORDS_WRITTEN |
"write-records" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SAVEPOINT_PATH |
"savepoint-path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_TARGET_DIRECTORY |
"target-directory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_FORMAT_TYPE |
"formatType" |
public static final String |
FIELD_NAME_TARGET_DIRECTORY |
"targetDirectory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_SERIALIZED_THROWABLE |
"serialized-throwable" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_JOB_ID |
"jobId" |
public static final String |
FIELD_NAME_RESOURCE |
"resource" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/taskmanagers/:taskmanagerid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ALLOCATED_SLOTS |
"allocatedSlots" |
public static final String |
FIELD_NAME_METRICS |
"metrics" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"taskmanagerid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_ADDRESS |
"path" |
public static final String |
FIELD_NAME_AVAILABLE_RESOURCE |
"freeResource" |
public static final String |
FIELD_NAME_BLOCKED |
"blocked" |
public static final String |
FIELD_NAME_DATA_PORT |
"dataPort" |
public static final String |
FIELD_NAME_HARDWARE |
"hardware" |
public static final String |
FIELD_NAME_JMX_PORT |
"jmxPort" |
public static final String |
FIELD_NAME_LAST_HEARTBEAT |
"timeSinceLastHeartbeat" |
public static final String |
FIELD_NAME_MEMORY |
"memoryConfiguration" |
public static final String |
FIELD_NAME_NUMBER_AVAILABLE_SLOTS |
"freeSlots" |
public static final String |
FIELD_NAME_NUMBER_SLOTS |
"slotsNumber" |
public static final String |
FIELD_NAME_RESOURCE_ID |
"id" |
public static final String |
FIELD_NAME_TOTAL_RESOURCE |
"totalResource" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_DIRECT_COUNT |
"directCount" |
public static final String |
FIELD_NAME_DIRECT_MAX |
"directMax" |
public static final String |
FIELD_NAME_DIRECT_USED |
"directUsed" |
public static final String |
FIELD_NAME_GARBAGE_COLLECTORS |
"garbageCollectors" |
public static final String |
FIELD_NAME_HEAP_COMMITTED |
"heapCommitted" |
public static final String |
FIELD_NAME_HEAP_MAX |
"heapMax" |
public static final String |
FIELD_NAME_HEAP_USED |
"heapUsed" |
public static final String |
FIELD_NAME_MAPPED_COUNT |
"mappedCount" |
public static final String |
FIELD_NAME_MAPPED_MAX |
"mappedMax" |
public static final String |
FIELD_NAME_MAPPED_USED |
"mappedUsed" |
public static final String |
FIELD_NAME_NETWORK_MEMORY_SEGMENTS_AVAILABLE |
"memorySegmentsAvailable" |
public static final String |
FIELD_NAME_NETWORK_MEMORY_SEGMENTS_TOTAL |
"memorySegmentsTotal" |
public static final String |
FIELD_NAME_NON_HEAP_COMMITTED |
"nonHeapCommitted" |
public static final String |
FIELD_NAME_NON_HEAP_MAX |
"nonHeapMax" |
public static final String |
FIELD_NAME_NON_HEAP_USED |
"nonHeapUsed" |
public static final String |
FIELD_NAME_SHUFFLE_MEMORY_AVAILABLE |
"nettyShuffleMemoryAvailable" |
public static final String |
FIELD_NAME_SHUFFLE_MEMORY_SEGMENTS_AVAILABLE |
"nettyShuffleMemorySegmentsAvailable" |
public static final String |
FIELD_NAME_SHUFFLE_MEMORY_SEGMENTS_TOTAL |
"nettyShuffleMemorySegmentsTotal" |
public static final String |
FIELD_NAME_SHUFFLE_MEMORY_SEGMENTS_USED |
"nettyShuffleMemorySegmentsUsed" |
public static final String |
FIELD_NAME_SHUFFLE_MEMORY_TOTAL |
"nettyShuffleMemoryTotal" |
public static final String |
FIELD_NAME_SHUFFLE_MEMORY_USED |
"nettyShuffleMemoryUsed" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_COUNT |
"count" |
public static final String |
FIELD_NAME_NAME |
"name" |
public static final String |
FIELD_NAME_TIME |
"time" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_TASK_MANAGERS |
"taskmanagers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONTENT_TYPE_BINARY |
"application/octet-stream" |
public static final String |
CONTENT_TYPE_JAR |
"application/java-archive" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FAILURE_LABEL_ATTRIBUTE_PREFIX |
"failureLabel." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
SIZE |
20 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NUM_FINISHED_PARTITIONS_AS_CONSUMABLE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NETTY_SHUFFLE_SERVICE_FACTORY_CLASS |
"org.apache.flink.runtime.io.network.NettyShuffleServiceFactory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION_0 |
0 |
public static final int |
VERSION_1 |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_OPERATOR_STATE_NAME |
"_default_" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
END_OF_KEY_GROUP_MARK |
65535 |
public static final int |
FIRST_BIT_IN_BYTE_MASK |
128 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
UNKNOWN_CHECKPOINTED_SIZE |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
6 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NO_CURRENT_KEY_GROUP |
-1 |
public static final long |
NO_OFFSET_SET |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_LOWER_BOUND_MAX_PARALLELISM |
128 |
public static final int |
UPPER_BOUND_MAX_PARALLELISM |
32768 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
VERSION |
6 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FS_STATE_BACKEND_NAME |
"filesystem" |
public static final String |
HASHMAP_STATE_BACKEND_NAME |
"hashmap" |
public static final String |
MEMORY_STATE_BACKEND_NAME |
"jobmanager" |
public static final String |
ROCKSDB_STATE_BACKEND_NAME |
"rocksdb" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ALLOCATION_DIR_PREFIX |
"aid_" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TASK_STATE_SNAPSHOT_FILENAME |
"_task_state_snapshot" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
META_KEY_GROUP |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"memory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CHECKPOINT_DIR_PREFIX |
"chk-" |
public static final String |
CHECKPOINT_SHARED_STATE_DIR |
"shared" |
public static final String |
CHECKPOINT_TASK_OWNED_STATE_DIR |
"taskowned" |
public static final String |
METADATA_FILE_NAME |
"_metadata" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_FILE_STATE_THRESHOLD |
1048576 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_CAPACITY |
128 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NOT_CONTAINED |
-2147483648 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
BUCKET_SIZE |
1048576 |
public static final int |
FOUR_BYTES_BITS |
32 |
public static final long |
FOUR_BYTES_MARK |
4294967295L |
public static final int |
NO_SPACE |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_MAX_STATE_SIZE |
5242880 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXTERNAL_POINTER |
"<checkpoint-not-externally-addressable>" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CURRENT_STATE_META_INFO_SNAPSHOT_VERSION |
7 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_MAX_STATE_SIZE |
5242880 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TASK_MANAGER_NAME |
"taskmanager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_FRAMEWORK_HEAP |
"frameworkHeap" |
public static final String |
FIELD_NAME_FRAMEWORK_OFFHEAP |
"frameworkOffHeap" |
public static final String |
FIELD_NAME_JVM_METASPACE |
"jvmMetaspace" |
public static final String |
FIELD_NAME_JVM_OVERHEAD |
"jvmOverhead" |
public static final String |
FIELD_NAME_MANAGED_MEMORY |
"managedMemory" |
public static final String |
FIELD_NAME_NETWORK_MEMORY |
"networkMemory" |
public static final String |
FIELD_NAME_TASK_HEAP |
"taskHeap" |
public static final String |
FIELD_NAME_TASK_OFFHEAP |
"taskOffHeap" |
public static final String |
FIELD_NAME_TOTAL_FLINK_MEMORY |
"totalFlinkMemory" |
public static final String |
FIELD_NAME_TOTAL_PROCESS_MEMORY |
"totalProcessMemory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FAILURE_EXIT_CODE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
UNKNOWN |
"<unknown>" |
public static final String |
UNKNOWN_COMMIT_ID |
"DecafC0ffeeD0d0F00d" |
public static final String |
UNKNOWN_COMMIT_ID_ABBREV |
"DeadD0d0" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
HA_STORAGE_COMPLETED_CHECKPOINT |
"completedCheckpoint" |
public static final String |
HA_STORAGE_SUBMITTED_JOBGRAPH_PREFIX |
"submittedJobGraph" |
public static final String |
RESOURCE_MANAGER_NODE |
"resource_manager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EXECUTION_PREFIX |
"BASH_JAVA_UTILS_EXEC_RESULT:" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"jarid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jars" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JAR_LIST_FIELD_ADDRESS |
"address" |
public static final String |
JAR_LIST_FIELD_FILES |
"files" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JAR_ENTRY_FIELD_DESC |
"description" |
public static final String |
JAR_ENTRY_FIELD_NAME |
"name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JAR_FILE_FIELD_ENTRY |
"entry" |
public static final String |
JAR_FILE_FIELD_ID |
"id" |
public static final String |
JAR_FILE_FIELD_NAME |
"name" |
public static final String |
JAR_FILE_FIELD_UPLOADED |
"uploaded" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
URL |
"/jars/upload" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
KEY |
"savepointPath" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
NUM_GHOST_SAMPLE_IDS |
10 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_ZOOKEEPER_CLIENT_PORT |
2181 |
public static final int |
DEFAULT_ZOOKEEPER_INIT_LIMIT |
10 |
public static final int |
DEFAULT_ZOOKEEPER_LEADER_PORT |
3888 |
public static final int |
DEFAULT_ZOOKEEPER_PEER_PORT |
2888 |
public static final int |
DEFAULT_ZOOKEEPER_SYNC_LIMIT |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
A |
1 |
public static final int |
ABS |
2 |
public static final int |
ABSENT |
3 |
public static final int |
ABSOLUTE |
4 |
public static final int |
ACTION |
5 |
public static final int |
ADA |
6 |
public static final int |
ADD |
7 |
public static final int |
ADMIN |
8 |
public static final int |
AFTER |
9 |
public static final int |
ALL |
10 |
public static final int |
ALLOCATE |
11 |
public static final int |
ALLOW |
12 |
public static final int |
ALTER |
13 |
public static final int |
ALWAYS |
14 |
public static final int |
ANALYZE |
685 |
public static final int |
AND |
15 |
public static final int |
ANY |
16 |
public static final int |
APPLY |
17 |
public static final int |
APPROX_NUMERIC_LITERAL |
747 |
public static final int |
ARE |
18 |
public static final int |
ARRAY |
19 |
public static final int |
ARRAY_AGG |
20 |
public static final int |
ARRAY_CONCAT_AGG |
21 |
public static final int |
ARRAY_MAX_CARDINALITY |
22 |
public static final int |
AS |
23 |
public static final int |
ASC |
24 |
public static final int |
ASENSITIVE |
25 |
public static final int |
ASSERTION |
26 |
public static final int |
ASSIGNMENT |
27 |
public static final int |
ASYMMETRIC |
28 |
public static final int |
AT |
29 |
public static final int |
ATOMIC |
30 |
public static final int |
ATTRIBUTE |
31 |
public static final int |
ATTRIBUTES |
32 |
public static final int |
AUTHORIZATION |
33 |
public static final int |
AVG |
34 |
public static final int |
BACK_QUOTED_IDENTIFIER |
810 |
public static final int |
BEFORE |
35 |
public static final int |
BEGIN |
36 |
public static final int |
BEGIN_FRAME |
37 |
public static final int |
BEGIN_PARTITION |
38 |
public static final int |
BEL |
818 |
public static final int |
BERNOULLI |
39 |
public static final int |
BETWEEN |
40 |
public static final int |
BIG_QUERY_BACK_QUOTED_IDENTIFIER |
811 |
public static final int |
BIG_QUERY_DOUBLE_QUOTED_STRING |
757 |
public static final int |
BIG_QUERY_QUOTED_STRING |
758 |
public static final int |
BIGINT |
41 |
public static final int |
BINARY |
42 |
public static final int |
BINARY_STRING_LITERAL |
752 |
public static final int |
BIT |
43 |
public static final int |
BLOB |
44 |
public static final int |
BOOLEAN |
45 |
public static final int |
BOTH |
46 |
public static final int |
BQHID |
4 |
public static final int |
BQID |
3 |
public static final int |
BRACKET_QUOTED_IDENTIFIER |
808 |
public static final int |
BREADTH |
47 |
public static final int |
BTID |
2 |
public static final int |
BUCKETS |
686 |
public static final int |
BY |
48 |
public static final int |
BYTES |
687 |
public static final int |
C |
49 |
public static final int |
CALL |
50 |
public static final int |
CALLED |
51 |
public static final int |
CARDINALITY |
52 |
public static final int |
CARET |
793 |
public static final int |
CASCADE |
53 |
public static final int |
CASCADED |
54 |
public static final int |
CASE |
55 |
public static final int |
CAST |
56 |
public static final int |
CATALOG |
57 |
public static final int |
CATALOG_NAME |
58 |
public static final int |
CATALOGS |
688 |
public static final int |
CEIL |
59 |
public static final int |
CEILING |
60 |
public static final int |
CENTURY |
61 |
public static final int |
CHAIN |
62 |
public static final int |
CHANGELOG_MODE |
689 |
public static final int |
CHAR |
63 |
public static final int |
CHAR_LENGTH |
64 |
public static final int |
CHARACTER |
65 |
public static final int |
CHARACTER_LENGTH |
66 |
public static final int |
CHARACTER_SET_CATALOG |
67 |
public static final int |
CHARACTER_SET_NAME |
68 |
public static final int |
CHARACTER_SET_SCHEMA |
69 |
public static final int |
CHARACTERISTICS |
70 |
public static final int |
CHARACTERS |
71 |
public static final int |
CHARSETNAME |
756 |
public static final int |
CHECK |
72 |
public static final int |
CLASS_ORIGIN |
74 |
public static final int |
CLASSIFIER |
73 |
public static final int |
CLOB |
75 |
public static final int |
CLOSE |
76 |
public static final int |
COALESCE |
77 |
public static final int |
COBOL |
78 |
public static final int |
COLLATE |
79 |
public static final int |
COLLATION |
80 |
public static final int |
COLLATION_CATALOG |
81 |
public static final int |
COLLATION_ID |
814 |
public static final int |
COLLATION_NAME |
82 |
public static final int |
COLLATION_SCHEMA |
83 |
public static final int |
COLLECT |
84 |
public static final int |
COLON |
777 |
public static final int |
COLUMN |
85 |
public static final int |
COLUMN_NAME |
86 |
public static final int |
COLUMNS |
690 |
public static final int |
COMMA |
772 |
public static final int |
COMMAND_FUNCTION |
87 |
public static final int |
COMMAND_FUNCTION_CODE |
88 |
public static final int |
COMMENT |
691 |
public static final int |
COMMENT_END |
801 |
public static final int |
COMMIT |
89 |
public static final int |
COMMITTED |
90 |
public static final int |
COMPACT |
692 |
public static final int |
COMPILE |
693 |
public static final int |
COMPUTE |
694 |
public static final int |
CONCAT |
787 |
public static final int |
CONDITION |
91 |
public static final int |
CONDITION_NUMBER |
93 |
public static final int |
CONDITIONAL |
92 |
public static final int |
CONNECT |
94 |
public static final int |
CONNECTION |
95 |
public static final int |
CONNECTION_NAME |
96 |
public static final int |
CONSTRAINT |
97 |
public static final int |
CONSTRAINT_CATALOG |
98 |
public static final int |
CONSTRAINT_NAME |
99 |
public static final int |
CONSTRAINT_SCHEMA |
100 |
public static final int |
CONSTRAINTS |
101 |
public static final int |
CONSTRUCTOR |
102 |
public static final int |
CONTAINS |
103 |
public static final int |
CONTINUE |
104 |
public static final int |
CONTINUOUS |
695 |
public static final int |
CONVERT |
105 |
public static final int |
CORR |
106 |
public static final int |
CORRESPONDING |
107 |
public static final int |
COUNT |
108 |
public static final int |
COVAR_POP |
109 |
public static final int |
COVAR_SAMP |
110 |
public static final int |
CREATE |
111 |
public static final int |
CROSS |
112 |
public static final int |
CUBE |
113 |
public static final int |
CUME_DIST |
114 |
public static final int |
CURRENT |
115 |
public static final int |
CURRENT_CATALOG |
116 |
public static final int |
CURRENT_DATE |
117 |
public static final int |
CURRENT_DEFAULT_TRANSFORM_GROUP |
118 |
public static final int |
CURRENT_PATH |
119 |
public static final int |
CURRENT_ROLE |
120 |
public static final int |
CURRENT_ROW |
121 |
public static final int |
CURRENT_SCHEMA |
122 |
public static final int |
CURRENT_TIME |
123 |
public static final int |
CURRENT_TIMESTAMP |
124 |
public static final int |
CURRENT_TRANSFORM_GROUP_FOR_TYPE |
125 |
public static final int |
CURRENT_USER |
126 |
public static final int |
CURSOR |
127 |
public static final int |
CURSOR_NAME |
128 |
public static final int |
CYCLE |
129 |
public static final int |
DATA |
130 |
public static final int |
DATABASE |
131 |
public static final int |
DATABASES |
696 |
public static final int |
DATE |
132 |
public static final int |
DATETIME_INTERVAL_CODE |
133 |
public static final int |
DATETIME_INTERVAL_PRECISION |
134 |
public static final int |
DAY |
135 |
public static final int |
DAYS |
136 |
public static final int |
DEALLOCATE |
137 |
public static final int |
DEC |
138 |
public static final int |
DECADE |
139 |
public static final int |
DECIMAL |
140 |
public static final int |
DECIMAL_NUMERIC_LITERAL |
748 |
public static final int |
DECLARE |
141 |
public static final int |
DEFAULT |
0 |
public static final int |
DEFAULT_ |
142 |
public static final int |
DEFAULTS |
143 |
public static final int |
DEFERRABLE |
144 |
public static final int |
DEFERRED |
145 |
public static final int |
DEFINE |
146 |
public static final int |
DEFINED |
147 |
public static final int |
DEFINER |
148 |
public static final int |
DEGREE |
149 |
public static final int |
DELETE |
150 |
public static final int |
DENSE_RANK |
151 |
public static final int |
DEPTH |
152 |
public static final int |
DEREF |
153 |
public static final int |
DERIVED |
154 |
public static final int |
DESC |
155 |
public static final int |
DESCRIBE |
156 |
public static final int |
DESCRIPTION |
157 |
public static final int |
DESCRIPTOR |
158 |
public static final int |
DETERMINISTIC |
159 |
public static final int |
DIAGNOSTICS |
160 |
public static final int |
DIGIT |
817 |
public static final int |
DISALLOW |
161 |
public static final int |
DISCONNECT |
162 |
public static final int |
DISPATCH |
163 |
public static final int |
DISTINCT |
164 |
public static final int |
DISTRIBUTED |
697 |
public static final int |
DISTRIBUTION |
698 |
public static final int |
DOLLAR |
794 |
public static final int |
DOMAIN |
165 |
public static final int |
DOT |
771 |
public static final int |
DOT_FORMAT |
166 |
public static final int |
DOUBLE |
167 |
public static final int |
DOUBLE_PERIOD |
789 |
public static final int |
DOUBLE_QUOTE |
791 |
public static final int |
DOW |
168 |
public static final int |
DOY |
169 |
public static final int |
DQID |
1 |
public static final int |
DRAIN |
699 |
public static final int |
DROP |
170 |
public static final int |
DYNAMIC |
171 |
public static final int |
DYNAMIC_FUNCTION |
172 |
public static final int |
DYNAMIC_FUNCTION_CODE |
173 |
public static final int |
EACH |
174 |
public static final int |
ELEMENT |
175 |
public static final int |
ELSE |
176 |
public static final int |
EMPTY |
177 |
public static final int |
ENCODING |
178 |
public static final int |
END |
179 |
public static final int |
END_EXEC |
180 |
public static final int |
END_FRAME |
181 |
public static final int |
END_PARTITION |
182 |
public static final int |
ENFORCED |
700 |
public static final int |
EOF |
0 |
public static final int |
EPOCH |
183 |
public static final int |
EQ |
773 |
public static final int |
EQUALS |
184 |
public static final int |
ERROR |
185 |
public static final int |
ESCAPE |
186 |
public static final int |
ESTIMATED_COST |
701 |
public static final int |
EVERY |
187 |
public static final int |
EXCEPT |
188 |
public static final int |
EXCEPTION |
189 |
public static final int |
EXCLUDE |
190 |
public static final int |
EXCLUDING |
191 |
public static final int |
EXEC |
192 |
public static final int |
EXECUTE |
193 |
public static final int |
EXISTS |
194 |
public static final int |
EXP |
195 |
public static final int |
EXPLAIN |
196 |
public static final int |
EXPONENT |
749 |
public static final int |
EXTEND |
197 |
public static final int |
EXTENDED |
702 |
public static final int |
EXTERNAL |
198 |
public static final int |
EXTRACT |
199 |
public static final int |
FALSE |
200 |
public static final int |
FETCH |
201 |
public static final int |
FILTER |
202 |
public static final int |
FINAL |
203 |
public static final int |
FIRST |
204 |
public static final int |
FIRST_VALUE |
205 |
public static final int |
FLOAT |
206 |
public static final int |
FLOOR |
207 |
public static final int |
FOLLOWING |
208 |
public static final int |
FOR |
209 |
public static final int |
FOREIGN |
211 |
public static final int |
FORMAL_COMMENT |
805 |
public static final int |
FORMAT |
210 |
public static final int |
FORTRAN |
212 |
public static final int |
FOUND |
213 |
public static final int |
FRAC_SECOND |
214 |
public static final int |
FRAME_ROW |
215 |
public static final int |
FREE |
216 |
public static final int |
FRESHNESS |
704 |
public static final int |
FROM |
217 |
public static final int |
FULL |
218 |
public static final int |
FUNCTION |
219 |
public static final int |
FUNCTIONS |
703 |
public static final int |
FUSION |
220 |
public static final int |
G |
221 |
public static final int |
GE |
779 |
public static final int |
GENERAL |
222 |
public static final int |
GENERATED |
223 |
public static final int |
GEOMETRY |
224 |
public static final int |
GET |
225 |
public static final int |
GLOBAL |
226 |
public static final int |
GO |
227 |
public static final int |
GOTO |
228 |
public static final int |
GRANT |
229 |
public static final int |
GRANTED |
230 |
public static final int |
GROUP |
231 |
public static final int |
GROUP_CONCAT |
232 |
public static final int |
GROUPING |
233 |
public static final int |
GROUPS |
234 |
public static final int |
GT |
774 |
public static final int |
HASH |
705 |
public static final int |
HAVING |
235 |
public static final int |
HEXDIGIT |
750 |
public static final int |
HIERARCHY |
236 |
public static final int |
HINT_BEG |
800 |
public static final int |
HOLD |
237 |
public static final int |
HOOK |
776 |
public static final int |
HOP |
238 |
public static final int |
HOUR |
239 |
public static final int |
HOURS |
240 |
public static final int |
HYPHENATED_IDENTIFIER |
812 |
public static final int |
IDENTIFIER |
813 |
public static final int |
IDENTITY |
241 |
public static final int |
IF |
706 |
public static final int |
IGNORE |
242 |
public static final int |
ILIKE |
243 |
public static final int |
IMMEDIATE |
244 |
public static final int |
IMMEDIATELY |
245 |
public static final int |
IMPLEMENTATION |
246 |
public static final int |
IMPORT |
247 |
public static final int |
IN |
248 |
public static final int |
IN_FORMAL_COMMENT |
5 |
public static final int |
IN_MULTI_LINE_COMMENT |
6 |
public static final int |
INCLUDE |
249 |
public static final int |
INCLUDING |
250 |
public static final int |
INCREMENT |
251 |
public static final int |
INDICATOR |
252 |
public static final int |
INITIAL |
253 |
public static final int |
INITIALLY |
254 |
public static final int |
INNER |
255 |
public static final int |
INOUT |
256 |
public static final int |
INPUT |
257 |
public static final int |
INSENSITIVE |
258 |
public static final int |
INSERT |
259 |
public static final int |
INSTANCE |
260 |
public static final int |
INSTANTIABLE |
261 |
public static final int |
INT |
262 |
public static final int |
INTEGER |
263 |
public static final int |
INTERSECT |
264 |
public static final int |
INTERSECTION |
265 |
public static final int |
INTERVAL |
266 |
public static final int |
INTO |
267 |
public static final int |
INVOKER |
268 |
public static final int |
IS |
269 |
public static final int |
ISODOW |
270 |
public static final int |
ISOLATION |
272 |
public static final int |
ISOYEAR |
271 |
public static final int |
JAR |
708 |
public static final int |
JARS |
709 |
public static final int |
JAVA |
273 |
public static final int |
JOB |
710 |
public static final int |
JOBS |
711 |
public static final int |
JOIN |
274 |
public static final int |
JSON |
275 |
public static final int |
JSON_ARRAY |
276 |
public static final int |
JSON_ARRAYAGG |
277 |
public static final int |
JSON_EXECUTION_PLAN |
707 |
public static final int |
JSON_EXISTS |
278 |
public static final int |
JSON_OBJECT |
279 |
public static final int |
JSON_OBJECTAGG |
280 |
public static final int |
JSON_QUERY |
281 |
public static final int |
JSON_VALUE |
282 |
public static final int |
K |
283 |
public static final int |
KEY |
284 |
public static final int |
KEY_MEMBER |
285 |
public static final int |
KEY_TYPE |
286 |
public static final int |
LABEL |
287 |
public static final int |
LAG |
288 |
public static final int |
LANGUAGE |
289 |
public static final int |
LARGE |
290 |
public static final int |
LAST |
291 |
public static final int |
LAST_VALUE |
292 |
public static final int |
LATERAL |
293 |
public static final int |
LBRACE |
766 |
public static final int |
LBRACE_D |
762 |
public static final int |
LBRACE_FN |
765 |
public static final int |
LBRACE_T |
763 |
public static final int |
LBRACE_TS |
764 |
public static final int |
LBRACKET |
768 |
public static final int |
LE |
778 |
public static final int |
LEAD |
294 |
public static final int |
LEADING |
295 |
public static final int |
LEFT |
296 |
public static final int |
LENGTH |
297 |
public static final int |
LETTER |
816 |
public static final int |
LEVEL |
298 |
public static final int |
LIBRARY |
299 |
public static final int |
LIKE |
300 |
public static final int |
LIKE_REGEX |
301 |
public static final int |
LIMIT |
302 |
public static final int |
LN |
303 |
public static final int |
LOAD |
712 |
public static final int |
LOCAL |
304 |
public static final int |
LOCALTIME |
305 |
public static final int |
LOCALTIMESTAMP |
306 |
public static final int |
LOCATOR |
307 |
public static final int |
LOWER |
308 |
public static final int |
LPAREN |
760 |
public static final int |
LT |
775 |
public static final int |
M |
309 |
public static final int |
MAP |
310 |
public static final int |
MATCH |
311 |
public static final int |
MATCH_NUMBER |
314 |
public static final int |
MATCH_RECOGNIZE |
315 |
public static final int |
MATCHED |
312 |
public static final int |
MATCHES |
313 |
public static final int |
MATERIALIZED |
716 |
public static final int |
MAX |
316 |
public static final int |
MAXVALUE |
317 |
public static final int |
MEASURES |
318 |
public static final int |
MEMBER |
319 |
public static final int |
MERGE |
320 |
public static final int |
MESSAGE_LENGTH |
321 |
public static final int |
MESSAGE_OCTET_LENGTH |
322 |
public static final int |
MESSAGE_TEXT |
323 |
public static final int |
METADATA |
713 |
public static final int |
METHOD |
324 |
public static final int |
MICROSECOND |
325 |
public static final int |
MILLENNIUM |
327 |
public static final int |
MILLISECOND |
326 |
public static final int |
MIN |
328 |
public static final int |
MINUS |
783 |
public static final int |
MINUTE |
329 |
public static final int |
MINUTES |
330 |
public static final int |
MINVALUE |
331 |
public static final int |
MOD |
332 |
public static final int |
|