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 int |
OPERAND_AFTER |
6 |
public static final int |
OPERAND_INTERVAL |
11 |
public static final int |
OPERAND_MEASURES |
5 |
public static final int |
OPERAND_ORDER_BY |
10 |
public static final int |
OPERAND_PARTITION_BY |
9 |
public static final int |
OPERAND_PATTERN |
1 |
public static final int |
OPERAND_PATTERN_DEFINES |
4 |
public static final int |
OPERAND_ROWS_PER_MATCH |
8 |
public static final int |
OPERAND_STRICT_END |
3 |
public static final int |
OPERAND_STRICT_START |
2 |
public static final int |
OPERAND_SUBSET |
7 |
public static final int |
OPERAND_TABLE_REF |
0 |
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 |
COMMON_HIGH_AVAILABILITY |
"common_high_availability" |
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_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_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_STATE_BACKENDS |
"expert_state_backends" |
public static final String |
EXPERT_ZOOKEEPER_HIGH_AVAILABILITY |
"expert_high_availability_zk" |
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_SSL |
"security_ssl" |
public static final String |
STATE_BACKEND_ROCKSDB |
"state_backend_rocksdb" |
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 String |
BLOCK_SIZE_PARAMETER_KEY |
"input.block_size" |
public static final long |
NATIVE_BLOCK_SIZE |
-9223372036854775808L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BLOCK_SIZE_PARAMETER_KEY |
"output.block_size" |
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 |
---|---|---|
public static final String |
ENUMERATE_NESTED_FILES_FLAG |
"recursive.file.enumeration" |
protected static final long |
READ_WHOLE_SPLIT_FLAG |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FILE_PARAMETER_KEY |
"flink.output.file" |
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 String |
NAME |
"GPU" |
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 |
---|---|---|
public static final long |
serialVersionUID |
2277251654485371327L |
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 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 |
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 long |
CHECK_INTERVAL |
100L |
public static final long |
TIMEOUT_MILLIS |
10000L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
AKKA_ASK_TIMEOUT |
"akka.ask.timeout" |
public static final String |
AKKA_CLIENT_TIMEOUT |
"akka.client.timeout" |
public static final String |
AKKA_DISPATCHER_THROUGHPUT |
"akka.throughput" |
public static final String |
AKKA_FRAMESIZE |
"akka.framesize" |
public static final String |
AKKA_JVM_EXIT_ON_FATAL_ERROR |
"akka.jvm-exit-on-fatal-error" |
public static final String |
AKKA_LOG_LIFECYCLE_EVENTS |
"akka.log.lifecycle.events" |
public static final String |
AKKA_LOOKUP_TIMEOUT |
"akka.lookup.timeout" |
public static final String |
AKKA_SSL_ENABLED |
"akka.ssl.enabled" |
public static final String |
AKKA_STARTUP_TIMEOUT |
"akka.startup-timeout" |
public static final String |
AKKA_TCP_TIMEOUT |
"akka.tcp.timeout" |
public static final String |
AKKA_TRANSPORT_HEARTBEAT_INTERVAL |
"akka.transport.heartbeat.interval" |
public static final String |
AKKA_TRANSPORT_HEARTBEAT_PAUSE |
"akka.transport.heartbeat.pause" |
public static final String |
AKKA_TRANSPORT_THRESHOLD |
"akka.transport.threshold" |
public static final String |
AKKA_WATCH_HEARTBEAT_INTERVAL |
"akka.watch.heartbeat.interval" |
public static final String |
AKKA_WATCH_HEARTBEAT_PAUSE |
"akka.watch.heartbeat.pause" |
public static final String |
AKKA_WATCH_THRESHOLD |
"akka.watch.threshold" |
public static final String |
BLOB_FETCH_BACKLOG_KEY |
"blob.fetch.backlog" |
public static final String |
BLOB_FETCH_CONCURRENT_KEY |
"blob.fetch.num-concurrent" |
public static final String |
BLOB_FETCH_RETRIES_KEY |
"blob.fetch.retries" |
public static final String |
BLOB_SERVER_PORT |
"blob.server.port" |
public static final String |
BLOB_SERVICE_SSL_ENABLED |
"blob.service.ssl.enabled" |
public static final String |
BLOB_STORAGE_DIRECTORY_KEY |
"blob.storage.directory" |
public static final String |
CHECKPOINTS_DIRECTORY_KEY |
"state.checkpoints.dir" |
public static final String |
CONTAINERIZED_HEAP_CUTOFF_MIN |
"containerized.heap-cutoff-min" |
public static final String |
CONTAINERIZED_HEAP_CUTOFF_RATIO |
"containerized.heap-cutoff-ratio" |
public static final String |
CONTAINERIZED_MASTER_ENV_PREFIX |
"containerized.master.env." |
public static final String |
CONTAINERIZED_TASK_MANAGER_ENV_PREFIX |
"containerized.taskmanager.env." |
public static final String |
DEFAULT_AKKA_ASK_TIMEOUT |
"10 s" |
public static final String |
DEFAULT_AKKA_CLIENT_TIMEOUT |
"60 s" |
public static final int |
DEFAULT_AKKA_DISPATCHER_THROUGHPUT |
15 |
public static final String |
DEFAULT_AKKA_FRAMESIZE |
"10485760b" |
public static final boolean |
DEFAULT_AKKA_LOG_LIFECYCLE_EVENTS |
false |
public static final String |
DEFAULT_AKKA_LOOKUP_TIMEOUT |
"10 s" |
public static final boolean |
DEFAULT_AKKA_SSL_ENABLED |
true |
public static final String |
DEFAULT_AKKA_TRANSPORT_HEARTBEAT_INTERVAL |
"1000 s" |
public static final String |
DEFAULT_AKKA_TRANSPORT_HEARTBEAT_PAUSE |
"6000 s" |
public static final double |
DEFAULT_AKKA_TRANSPORT_THRESHOLD |
300.0 |
public static final double |
DEFAULT_AKKA_WATCH_THRESHOLD |
12.0 |
public static final int |
DEFAULT_BLOB_FETCH_BACKLOG |
1000 |
public static final int |
DEFAULT_BLOB_FETCH_CONCURRENT |
50 |
public static final int |
DEFAULT_BLOB_FETCH_RETRIES |
5 |
public static final String |
DEFAULT_BLOB_SERVER_PORT |
"0" |
public static final boolean |
DEFAULT_BLOB_SERVICE_SSL_ENABLED |
true |
public static final int |
DEFAULT_DELIMITED_FORMAT_MAX_LINE_SAMPLES |
10 |
public static final int |
DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN |
2097152 |
public static final int |
DEFAULT_DELIMITED_FORMAT_MIN_LINE_SAMPLES |
2 |
public static final int |
DEFAULT_EXECUTION_RETRIES |
0 |
public static final boolean |
DEFAULT_FILESYSTEM_ALWAYS_CREATE_DIRECTORY |
false |
public static final boolean |
DEFAULT_FILESYSTEM_OVERWRITE |
false |
public static final String |
DEFAULT_FILESYSTEM_SCHEME |
"file:///" |
public static final String |
DEFAULT_FLINK_PLUGINS_DIRS |
"plugins" |
public static final String |
DEFAULT_FLINK_USR_LIB_DIR |
"usrlib" |
public static final int |
DEFAULT_FS_STREAM_OPENING_TIMEOUT |
0 |
public static final String |
DEFAULT_HA_JOB_MANAGER_PORT |
"0" |
public static final String |
DEFAULT_HA_MODE |
"none" |
public static final String |
DEFAULT_HA_ZOOKEEPER_CLIENT_ACL |
"open" |
public static final int |
DEFAULT_JOB_MANAGER_IPC_PORT |
6123 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_ARCHIVE_COUNT |
5 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL |
600000 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_DELAY |
50 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES |
100 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL |
60000 |
public static final boolean |
DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_DISABLE |
false |
public static final int |
DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE |
10 |
public static final int |
DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT |
8081 |
public static final boolean |
DEFAULT_JOB_MANAGER_WEB_SSL_ENABLED |
true |
public static final boolean |
DEFAULT_JOB_MANAGER_WEB_SUBMIT_ENABLED |
true |
public static final int |
DEFAULT_LOCAL_NUMBER_JOB_MANAGER |
1 |
public static final int |
DEFAULT_LOCAL_NUMBER_RESOURCE_MANAGER |
1 |
public static final int |
DEFAULT_LOCAL_NUMBER_TASK_MANAGER |
1 |
public static final float |
DEFAULT_MEMORY_MANAGER_MEMORY_FRACTION |
0.699999988079071f |
public static final int |
DEFAULT_MESOS_ARTIFACT_SERVER_PORT |
0 |
public static final boolean |
DEFAULT_MESOS_ARTIFACT_SERVER_SSL_ENABLED |
true |
public static final int |
DEFAULT_MESOS_FAILOVER_TIMEOUT_SECS |
600 |
public static final String |
DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_NAME |
"Flink" |
public static final String |
DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE |
"*" |
public static final String |
DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_USER |
"" |
public static final int |
DEFAULT_METRICS_LATENCY_HISTORY_SIZE |
128 |
public static final int |
DEFAULT_PARALLELISM |
1 |
public static final String |
DEFAULT_PARALLELISM_KEY |
"parallelism.default" |
public static final String |
DEFAULT_RECOVERY_JOB_MANAGER_PORT |
"0" |
public static final String |
DEFAULT_RECOVERY_MODE |
"standalone" |
public static final int |
DEFAULT_RESOURCE_MANAGER_IPC_PORT |
0 |
public static final boolean |
DEFAULT_RUNTIME_HASH_JOIN_BLOOM_FILTERS |
false |
public static final String |
DEFAULT_SECURITY_SSL_ALGORITHMS |
"TLS_RSA_WITH_AES_128_CBC_SHA" |
public static final boolean |
DEFAULT_SECURITY_SSL_ENABLED |
false |
public static final String |
DEFAULT_SECURITY_SSL_PROTOCOL |
"TLSv1.2" |
public static final boolean |
DEFAULT_SECURITY_SSL_VERIFY_HOSTNAME |
true |
public static final float |
DEFAULT_SORT_SPILLING_THRESHOLD |
0.800000011920929f |
public static final String |
DEFAULT_SORT_SPILLING_THRESHOLD_KEY |
"taskmanager.runtime.sort-spilling-threshold" |
public static final int |
DEFAULT_SPILLING_MAX_FAN |
128 |
public static final String |
DEFAULT_SPILLING_MAX_FAN_KEY |
"taskmanager.runtime.max-fan" |
public static final String |
DEFAULT_STATE_BACKEND |
"jobmanager" |
public static final long |
DEFAULT_TASK_CANCELLATION_INTERVAL_MILLIS |
30000L |
public static final int |
DEFAULT_TASK_MANAGER_DATA_PORT |
0 |
public static final boolean |
DEFAULT_TASK_MANAGER_DATA_SSL_ENABLED |
true |
public static final long |
DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS |
5000L |
public static final boolean |
DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD |
false |
public static final String |
DEFAULT_TASK_MANAGER_INITIAL_REGISTRATION_PAUSE |
"500 ms" |
public static final int |
DEFAULT_TASK_MANAGER_IPC_PORT |
0 |
public static final String |
DEFAULT_TASK_MANAGER_MAX_REGISTRATION_DURATION |
"Inf" |
public static final String |
DEFAULT_TASK_MANAGER_MAX_REGISTRATION_PAUSE |
"30 s" |
public static final boolean |
DEFAULT_TASK_MANAGER_MEMORY_PRE_ALLOCATE |
false |
public static final int |
DEFAULT_TASK_MANAGER_MEMORY_SEGMENT_SIZE |
32768 |
public static final String |
DEFAULT_TASK_MANAGER_NETWORK_DEFAULT_IO_MODE |
"sync" |
public static final int |
DEFAULT_TASK_MANAGER_NETWORK_NUM_BUFFERS |
2048 |
public static final String |
DEFAULT_TASK_MANAGER_REFUSED_REGISTRATION_PAUSE |
"10 s" |
public static final boolean |
DEFAULT_USE_LARGE_RECORD_HANDLER |
false |
public static final String |
DEFAULT_YARN_APPLICATION_MASTER_PORT |
"deprecated" |
public static final String |
DEFAULT_YARN_CONTAINER_START_COMMAND_TEMPLATE |
"%java% %jvmmem% %jvmopts% %logging% %class% %args% %redirects%" |
public static final int |
DEFAULT_YARN_HEAP_CUTOFF |
600 |
public static final float |
DEFAULT_YARN_HEAP_CUTOFF_RATIO |
0.25f |
public static final String |
DEFAULT_YARN_JOB_MANAGER_PORT |
"0" |
public static final int |
DEFAULT_YARN_MIN_HEAP_CUTOFF |
-1 |
public static final String |
DEFAULT_ZOOKEEPER_CHECKPOINT_COUNTER_PATH |
"/checkpoint-counter" |
public static final String |
DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH |
"/checkpoints" |
public static final int |
DEFAULT_ZOOKEEPER_CLIENT_PORT |
2181 |
public static final int |
DEFAULT_ZOOKEEPER_CONNECTION_TIMEOUT |
15000 |
public static final String |
DEFAULT_ZOOKEEPER_DIR_KEY |
"/flink" |
public static final int |
DEFAULT_ZOOKEEPER_INIT_LIMIT |
10 |
public static final String |
DEFAULT_ZOOKEEPER_JOBGRAPHS_PATH |
"/jobgraphs" |
public static final String |
DEFAULT_ZOOKEEPER_LATCH_PATH |
"/leaderlatch" |
public static final String |
DEFAULT_ZOOKEEPER_LEADER_PATH |
"/leader" |
public static final int |
DEFAULT_ZOOKEEPER_LEADER_PORT |
3888 |
public static final int |
DEFAULT_ZOOKEEPER_MAX_RETRY_ATTEMPTS |
3 |
public static final String |
DEFAULT_ZOOKEEPER_MESOS_WORKERS_PATH |
"/mesos-workers" |
public static final String |
DEFAULT_ZOOKEEPER_NAMESPACE_KEY |
"/default" |
public static final int |
DEFAULT_ZOOKEEPER_PEER_PORT |
2888 |
public static final int |
DEFAULT_ZOOKEEPER_RETRY_WAIT |
5000 |
public static final boolean |
DEFAULT_ZOOKEEPER_SASL_DISABLE |
true |
public static final int |
DEFAULT_ZOOKEEPER_SESSION_TIMEOUT |
60000 |
public static final int |
DEFAULT_ZOOKEEPER_SYNC_LIMIT |
5 |
public static final String |
DELIMITED_FORMAT_MAX_LINE_SAMPLES_KEY |
"compiler.delimited-informat.max-line-samples" |
public static final String |
DELIMITED_FORMAT_MAX_SAMPLE_LENGTH_KEY |
"compiler.delimited-informat.max-sample-len" |
public static final String |
DELIMITED_FORMAT_MIN_LINE_SAMPLES_KEY |
"compiler.delimited-informat.min-line-samples" |
public static final String |
ENV_FLINK_BIN_DIR |
"FLINK_BIN_DIR" |
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 |
EXECUTION_RETRIES_KEY |
"execution-retries.default" |
public static final String |
EXECUTION_RETRY_DELAY_KEY |
"execution-retries.delay" |
public static final String |
FILESYSTEM_DEFAULT_OVERWRITE_KEY |
"fs.overwrite-files" |
public static final String |
FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY_KEY |
"fs.output.always-create-directory" |
public static final String |
FILESYSTEM_SCHEME |
"fs.default-scheme" |
public static final String |
FLINK_BASE_DIR_PATH_KEY |
"flink.base.dir.path" |
public static final String |
FLINK_JVM_OPTIONS |
"env.java.opts" |
public static final String |
FS_STREAM_OPENING_TIMEOUT_KEY |
"taskmanager.runtime.fs_timeout" |
public static final String |
HA_JOB_MANAGER_PORT |
"high-availability.jobmanager.port" |
public static final String |
HA_MODE |
"high-availability" |
public static final String |
HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH |
"high-availability.zookeeper.path.checkpoint-counter" |
public static final String |
HA_ZOOKEEPER_CHECKPOINTS_PATH |
"high-availability.zookeeper.path.checkpoints" |
public static final String |
HA_ZOOKEEPER_CLIENT_ACL |
"high-availability.zookeeper.client.acl" |
public static final String |
HA_ZOOKEEPER_CONNECTION_TIMEOUT |
"high-availability.zookeeper.client.connection-timeout" |
public static final String |
HA_ZOOKEEPER_DIR_KEY |
"high-availability.zookeeper.path.root" |
public static final String |
HA_ZOOKEEPER_JOBGRAPHS_PATH |
"high-availability.zookeeper.path.jobgraphs" |
public static final String |
HA_ZOOKEEPER_LATCH_PATH |
"high-availability.zookeeper.path.latch" |
public static final String |
HA_ZOOKEEPER_LEADER_PATH |
"high-availability.zookeeper.path.leader" |
public static final String |
HA_ZOOKEEPER_MAX_RETRY_ATTEMPTS |
"high-availability.zookeeper.client.max-retry-attempts" |
public static final String |
HA_ZOOKEEPER_MESOS_WORKERS_PATH |
"high-availability.zookeeper.path.mesos-workers" |
public static final String |
HA_ZOOKEEPER_NAMESPACE_KEY |
"high-availability.zookeeper.path.namespace" |
public static final String |
HA_ZOOKEEPER_QUORUM_KEY |
"high-availability.zookeeper.quorum" |
public static final String |
HA_ZOOKEEPER_RETRY_WAIT |
"high-availability.zookeeper.client.retry-wait" |
public static final String |
HA_ZOOKEEPER_SESSION_TIMEOUT |
"high-availability.zookeeper.client.session-timeout" |
public static final String |
HA_ZOOKEEPER_STORAGE_PATH |
"high-availability.zookeeper.storageDir" |
public static final String |
HDFS_DEFAULT_CONFIG |
"fs.hdfs.hdfsdefault" |
public static final String |
HDFS_SITE_CONFIG |
"fs.hdfs.hdfssite" |
public static final String |
JOB_MANAGER_IPC_ADDRESS_KEY |
"jobmanager.rpc.address" |
public static final String |
JOB_MANAGER_IPC_PORT_KEY |
"jobmanager.rpc.port" |
public static final String |
JOB_MANAGER_WEB_ARCHIVE_COUNT |
"jobmanager.web.history" |
public static final String |
JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL |
"jobmanager.web.backpressure.cleanup-interval" |
public static final String |
JOB_MANAGER_WEB_BACK_PRESSURE_DELAY |
"jobmanager.web.backpressure.delay-between-samples" |
public static final String |
JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES |
"jobmanager.web.backpressure.num-samples" |
public static final String |
JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL |
"jobmanager.web.backpressure.refresh-interval" |
public static final String |
JOB_MANAGER_WEB_CHECKPOINTS_DISABLE |
"jobmanager.web.checkpoints.disable" |
public static final String |
JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE |
"jobmanager.web.checkpoints.history" |
public static final String |
JOB_MANAGER_WEB_LOG_PATH_KEY |
"jobmanager.web.log.path" |
public static final String |
JOB_MANAGER_WEB_PORT_KEY |
"jobmanager.web.port" |
public static final String |
JOB_MANAGER_WEB_SSL_ENABLED |
"jobmanager.web.ssl.enabled" |
public static final String |
JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY |
"jobmanager.web.submit.enable" |
public static final String |
JOB_MANAGER_WEB_TMPDIR_KEY |
"jobmanager.web.tmpdir" |
public static final String |
JOB_MANAGER_WEB_UPLOAD_DIR_KEY |
"jobmanager.web.upload.dir" |
public static final String |
LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL |
"library-cache-manager.cleanup.interval" |
public static final String |
LOCAL_NUMBER_JOB_MANAGER |
"local.number-jobmanager" |
public static final String |
LOCAL_NUMBER_RESOURCE_MANAGER |
"local.number-resourcemanager" |
public static final String |
LOCAL_NUMBER_TASK_MANAGER |
"local.number-taskmanager" |
public static final String |
LOCAL_START_WEBSERVER |
"local.start-webserver" |
public static final String |
MESOS_ARTIFACT_SERVER_PORT_KEY |
"mesos.resourcemanager.artifactserver.port" |
public static final String |
MESOS_ARTIFACT_SERVER_SSL_ENABLED |
"mesos.resourcemanager.artifactserver.ssl.enabled" |
public static final String |
MESOS_FAILOVER_TIMEOUT_SECONDS |
"mesos.failover-timeout" |
public static final String |
MESOS_INITIAL_TASKS |
"mesos.initial-tasks" |
public static final String |
MESOS_MASTER_URL |
"mesos.master" |
public static final String |
MESOS_MAX_FAILED_TASKS |
"mesos.maximum-failed-tasks" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_NAME |
"mesos.resourcemanager.framework.name" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_PRINCIPAL |
"mesos.resourcemanager.framework.principal" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE |
"mesos.resourcemanager.framework.role" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_SECRET |
"mesos.resourcemanager.framework.secret" |
public static final String |
MESOS_RESOURCEMANAGER_FRAMEWORK_USER |
"mesos.resourcemanager.framework.user" |
public static final String |
METRICS_LATENCY_HISTORY_SIZE |
"metrics.latency.history-size" |
public static final String |
METRICS_REPORTER_CLASS_SUFFIX |
"class" |
public static final String |
METRICS_REPORTER_EXCLUDED_VARIABLES |
"scope.variables.excludes" |
public static final String |
METRICS_REPORTER_FACTORY_CLASS_SUFFIX |
"factory.class" |
public static final String |
METRICS_REPORTER_INTERVAL_SUFFIX |
"interval" |
public static final String |
METRICS_REPORTER_PREFIX |
"metrics.reporter." |
public static final String |
METRICS_REPORTER_SCOPE_DELIMITER |
"scope.delimiter" |
public static final String |
METRICS_REPORTERS_LIST |
"metrics.reporters" |
public static final String |
METRICS_SCOPE_DELIMITER |
"metrics.scope.delimiter" |
public static final String |
METRICS_SCOPE_NAMING_JM |
"metrics.scope.jm" |
public static final String |
METRICS_SCOPE_NAMING_JM_JOB |
"metrics.scope.jm.job" |
public static final String |
METRICS_SCOPE_NAMING_OPERATOR |
"metrics.scope.operator" |
public static final String |
METRICS_SCOPE_NAMING_TASK |
"metrics.scope.task" |
public static final String |
METRICS_SCOPE_NAMING_TM |
"metrics.scope.tm" |
public static final String |
METRICS_SCOPE_NAMING_TM_JOB |
"metrics.scope.tm.job" |
public static final String |
PATH_HADOOP_CONFIG |
"fs.hdfs.hadoopconf" |
public static final String |
RECOVERY_JOB_DELAY |
"recovery.job.delay" |
public static final String |
RECOVERY_JOB_MANAGER_PORT |
"recovery.jobmanager.port" |
public static final String |
RECOVERY_MODE |
"recovery.mode" |
public static final String |
RESOURCE_MANAGER_IPC_PORT_KEY |
"resourcemanager.rpc.port" |
public static final String |
RESTART_STRATEGY |
"restart-strategy" |
public static final String |
RESTART_STRATEGY_FAILURE_RATE_DELAY |
"restart-strategy.failure-rate.delay" |
public static final String |
RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL |
"restart-strategy.failure-rate.failure-rate-interval" |
public static final String |
RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL |
"restart-strategy.failure-rate.max-failures-per-interval" |
public static final String |
RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS |
"restart-strategy.fixed-delay.attempts" |
public static final String |
RUNTIME_HASH_JOIN_BLOOM_FILTERS_KEY |
"taskmanager.runtime.hashjoin-bloom-filters" |
public static final String |
SAVEPOINT_DIRECTORY_KEY |
"state.savepoints.dir" |
public static final String |
SAVEPOINT_FS_DIRECTORY_KEY |
"savepoints.state.backend.fs.dir" |
public static final String |
SECURITY_SSL_ALGORITHMS |
"security.ssl.algorithms" |
public static final String |
SECURITY_SSL_ENABLED |
"security.ssl.enabled" |
public static final String |
SECURITY_SSL_KEY_PASSWORD |
"security.ssl.key-password" |
public static final String |
SECURITY_SSL_KEYSTORE |
"security.ssl.keystore" |
public static final String |
SECURITY_SSL_KEYSTORE_PASSWORD |
"security.ssl.keystore-password" |
public static final String |
SECURITY_SSL_PROTOCOL |
"security.ssl.protocol" |
public static final String |
SECURITY_SSL_TRUSTSTORE |
"security.ssl.truststore" |
public static final String |
SECURITY_SSL_TRUSTSTORE_PASSWORD |
"security.ssl.truststore-password" |
public static final String |
SECURITY_SSL_VERIFY_HOSTNAME |
"security.ssl.verify-hostname" |
public static final String |
STATE_BACKEND |
"state.backend" |
public static final String |
TASK_CANCELLATION_INTERVAL_MILLIS |
"task.cancellation-interval" |
public static final String |
TASK_MANAGER_DATA_PORT_KEY |
"taskmanager.data.port" |
public static final String |
TASK_MANAGER_DATA_SSL_ENABLED |
"taskmanager.data.ssl.enabled" |
public static final String |
TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS |
"taskmanager.debug.memory.logIntervalMs" |
public static final String |
TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD |
"taskmanager.debug.memory.startLogThread" |
public static final String |
TASK_MANAGER_HOSTNAME_KEY |
"taskmanager.hostname" |
public static final String |
TASK_MANAGER_INITIAL_REGISTRATION_PAUSE |
"taskmanager.initial-registration-pause" |
public static final String |
TASK_MANAGER_IPC_PORT_KEY |
"taskmanager.rpc.port" |
public static final String |
TASK_MANAGER_LOG_PATH_KEY |
"taskmanager.log.path" |
public static final String |
TASK_MANAGER_MAX_REGISTARTION_PAUSE |
"taskmanager.max-registration-pause" |
public static final String |
TASK_MANAGER_MAX_REGISTRATION_DURATION |
"taskmanager.maxRegistrationDuration" |
public static final String |
TASK_MANAGER_MEMORY_FRACTION_KEY |
"taskmanager.memory.fraction" |
public static final String |
TASK_MANAGER_MEMORY_OFF_HEAP_KEY |
"taskmanager.memory.off-heap" |
public static final String |
TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY |
"taskmanager.memory.preallocate" |
public static final String |
TASK_MANAGER_MEMORY_SEGMENT_SIZE_KEY |
"taskmanager.memory.segment-size" |
public static final String |
TASK_MANAGER_MEMORY_SIZE_KEY |
"taskmanager.memory.size" |
public static final String |
TASK_MANAGER_NETWORK_DEFAULT_IO_MODE |
"taskmanager.network.defaultIOMode" |
public static final String |
TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY |
"taskmanager.network.numberOfBuffers" |
public static final String |
TASK_MANAGER_NUM_TASK_SLOTS |
"taskmanager.numberOfTaskSlots" |
public static final String |
TASK_MANAGER_REFUSED_REGISTRATION_PAUSE |
"taskmanager.refused-registration-pause" |
public static final String |
TASK_MANAGER_TMP_DIR_KEY |
"taskmanager.tmp.dirs" |
public static final String |
USE_LARGE_RECORD_HANDLER_KEY |
"taskmanager.runtime.large-record-handler" |
public static final String |
YARN_APPLICATION_ATTEMPTS |
"yarn.application-attempts" |
public static final String |
YARN_APPLICATION_MASTER_ENV_PREFIX |
"yarn.application-master.env." |
public static final String |
YARN_APPLICATION_MASTER_PORT |
"yarn.application-master.port" |
public static final String |
YARN_APPLICATION_TAGS |
"yarn.tags" |
public static final String |
YARN_CONTAINER_START_COMMAND_TEMPLATE |
"yarn.container-start-command-template" |
public static final String |
YARN_HEAP_CUTOFF_MIN |
"yarn.heap-cutoff-min" |
public static final String |
YARN_HEAP_CUTOFF_RATIO |
"yarn.heap-cutoff-ratio" |
public static final String |
YARN_HEARTBEAT_DELAY_SECONDS |
"yarn.heartbeat-delay" |
public static final String |
YARN_MAX_FAILED_CONTAINERS |
"yarn.maximum-failed-containers" |
public static final String |
YARN_PROPERTIES_FILE_LOCATION |
"yarn.properties-file.location" |
public static final String |
YARN_REALLOCATE_FAILED_CONTAINERS |
"yarn.reallocate-failed" |
public static final String |
YARN_TASK_MANAGER_ENV_PREFIX |
"yarn.taskmanager.env." |
public static final String |
YARN_VCORES |
"yarn.containers.vcores" |
public static final String |
ZOOKEEPER_CHECKPOINT_COUNTER_PATH |
"recovery.zookeeper.path.checkpoint-counter" |
public static final String |
ZOOKEEPER_CHECKPOINTS_PATH |
"recovery.zookeeper.path.checkpoints" |
public static final String |
ZOOKEEPER_CONNECTION_TIMEOUT |
"recovery.zookeeper.client.connection-timeout" |
public static final String |
ZOOKEEPER_DIR_KEY |
"recovery.zookeeper.path.root" |
public static final String |
ZOOKEEPER_JOBGRAPHS_PATH |
"recovery.zookeeper.path.jobgraphs" |
public static final String |
ZOOKEEPER_LATCH_PATH |
"recovery.zookeeper.path.latch" |
public static final String |
ZOOKEEPER_LEADER_PATH |
"recovery.zookeeper.path.leader" |
public static final String |
ZOOKEEPER_MAX_RETRY_ATTEMPTS |
"recovery.zookeeper.client.max-retry-attempts" |
public static final String |
ZOOKEEPER_MESOS_WORKERS_PATH |
"recovery.zookeeper.path.mesos-workers" |
public static final String |
ZOOKEEPER_NAMESPACE_KEY |
"recovery.zookeeper.path.namespace" |
public static final String |
ZOOKEEPER_QUORUM_KEY |
"recovery.zookeeper.quorum" |
public static final String |
ZOOKEEPER_RECOVERY_PATH |
"recovery.zookeeper.storageDir" |
public static final String |
ZOOKEEPER_RETRY_WAIT |
"recovery.zookeeper.client.retry-wait" |
public static final String |
ZOOKEEPER_SASL_DISABLE |
"zookeeper.sasl.disable" |
public static final String |
ZOOKEEPER_SASL_SERVICE_NAME |
"zookeeper.sasl.service-name" |
public static final String |
ZOOKEEPER_SESSION_TIMEOUT |
"recovery.zookeeper.client.session-timeout" |
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." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FLINK_CONF_FILENAME |
"flink-conf.yaml" |
public static final String |
HIDDEN_CONTENT |
"******" |
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 |
MANAGED_MEMORY_CONSUMER_NAME_DATAPROC |
"DATAPROC" |
public static final String |
MANAGED_MEMORY_CONSUMER_NAME_PYTHON |
"PYTHON" |
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 |
ENV_HBASE_CONF_DIR |
"HBASE_CONF_DIR" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONNECTOR_VERSION_VALUE_143 |
"1.4.3" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONNECTOR_VERSION_VALUE_223 |
"2.2.3" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_MAX_RETRY_TIMES |
3 |
public static final int |
DEFAULT_SIZE |
5000 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_DATABASE |
"postgres" |
public static final String |
PG_BIGINT |
"int8" |
public static final String |
PG_BIGINT_ARRAY |
"_int8" |
public static final String |
PG_BIGSERIAL |
"bigserial" |
public static final String |
PG_BOOLEAN |
"bool" |
public static final String |
PG_BOOLEAN_ARRAY |
"_bool" |
public static final String |
PG_BYTEA |
"bytea" |
public static final String |
PG_BYTEA_ARRAY |
"_bytea" |
public static final String |
PG_CHAR |
"bpchar" |
public static final String |
PG_CHAR_ARRAY |
"_bpchar" |
public static final String |
PG_CHARACTER |
"character" |
public static final String |
PG_CHARACTER_ARRAY |
"_character" |
public static final String |
PG_CHARACTER_VARYING |
"varchar" |
public static final String |
PG_CHARACTER_VARYING_ARRAY |
"_varchar" |
public static final String |
PG_DATE |
"date" |
public static final String |
PG_DATE_ARRAY |
"_date" |
public static final String |
PG_DOUBLE_PRECISION |
"float8" |
public static final String |
PG_DOUBLE_PRECISION_ARRAY |
"_float8" |
public static final String |
PG_INTEGER |
"int4" |
public static final String |
PG_INTEGER_ARRAY |
"_int4" |
public static final String |
PG_NUMERIC |
"numeric" |
public static final String |
PG_NUMERIC_ARRAY |
"_numeric" |
public static final String |
PG_REAL |
"float4" |
public static final String |
PG_REAL_ARRAY |
"_float4" |
public static final String |
PG_SERIAL |
"serial" |
public static final String |
PG_SMALLINT |
"int2" |
public static final String |
PG_SMALLINT_ARRAY |
"_int2" |
public static final String |
PG_TEXT |
"text" |
public static final String |
PG_TEXT_ARRAY |
"_text" |
public static final String |
PG_TIME |
"time" |
public static final String |
PG_TIME_ARRAY |
"_time" |
public static final String |
PG_TIMESTAMP |
"timestamp" |
public static final String |
PG_TIMESTAMP_ARRAY |
"_timestamp" |
public static final String |
PG_TIMESTAMPTZ |
"timestamptz" |
public static final String |
PG_TIMESTAMPTZ_ARRAY |
"_timestamptz" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_FLUSH_INTERVAL_MILLS |
0L |
public static final int |
DEFAULT_FLUSH_MAX_SIZE |
5000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CONNECTION_CHECK_TIMEOUT_SECONDS |
60 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"jdbc" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
COMMITTED_OFFSET |
-3L |
public static final long |
EARLIEST_OFFSET |
-2L |
public static final long |
LATEST_OFFSET |
-1L |
public static final long |
NO_STOPPING_OFFSET |
-9223372036854775808L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
NUM_RECORDS_PER_SPLIT |
10 |
protected static final int |
NUM_SPLITS |
10 |
protected static final int |
TOTAL_NUM_RECORDS |
100 |
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 |
---|---|---|
public static final int |
END_OF_KEY_GROUP_MARK |
65535 |
public static final int |
FIRST_BIT_IN_BYTE_MASK |
128 |
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 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 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 |
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 |
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 |
FIELD_FIELD_NUMBER |
1 |
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 |
COLLECTION_ELEMENT_TYPE_FIELD_NUMBER |
2 |
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 |
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 |
INT_VALUE |
5 |
public static final int |
LONG_VALUE |
6 |
public static final int |
PICKLED_BYTES_VALUE |
16 |
public static final int |
PRIMITIVE_ARRAY_VALUE |
18 |
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 |
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 |
GROUPING_FIELD_NUMBER |
3 |
public static final int |
INDEX_OF_COUNT_STAR_FIELD_NUMBER |
6 |
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 |
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 |
KEY_TYPE_INFO_FIELD_NUMBER |
5 |
public static final int |
METRIC_ENABLED_FIELD_NUMBER |
4 |
public static final int |
PAYLOAD_FIELD_NUMBER |
3 |
public static final int |
RUNTIME_CONTEXT_FIELD_NUMBER |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
CO_FLAT_MAP_VALUE |
4 |
public static final int |
CO_MAP_VALUE |
3 |
public static final int |
FLAT_MAP_VALUE |
1 |
public static final int |
KEYED_PROCESS_VALUE |
6 |
public static final int |
MAP_VALUE |
0 |
public static final int |
PROCESS_VALUE |
5 |
public static final int |
REDUCE_VALUE |
2 |
public static final int |
TIMESTAMP_ASSIGNER_VALUE |
7 |
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 |
ATTEMPT_NUMBER_FIELD_NUMBER |
6 |
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 |
WINDOW_INDEX_FIELD_NUMBER |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
METRIC_ENABLED_FIELD_NUMBER |
2 |
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" |
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 |
"csv" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
IDENTIFIER |
"csv" |
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 |
"parquet" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PARQUET_SKIP_CORRUPTED_RECORD |
"skip.corrupted.record" |
public static final String |
PARQUET_SKIP_WRONG_SCHEMA_SPLITS |
"skip.splits.wrong.schema" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LIST_ARRAY_TYPE |
"array" |
public static final String |
LIST_ELEMENT |
"element" |
public static final String |
LIST_GROUP_NAME |
"list" |
public static final String |
MAP_VALUE |
"value" |
public static final String |
MESSAGE_ROOT |
"root" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
JULIAN_EPOCH_OFFSET_DAYS |
2440588 |
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 long |
S3_MULTIPART_MIN_PART_SIZE |
5242880L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
BUFFER_SIZE |
4096 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MAX_VERTEX_COUNT |
4294967296L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
MAX_VERTEX_COUNT |
4294967296L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMMUNITIES_SINGLE_ITERATION |
"1,5\n2,6\n3,1\n4,1\n5,1\n6,8\n7,8\n8,7" |
public static final String |
COMMUNITIES_WITH_TIE |
"1,2\n2,1\n3,1\n4,1\n5,1" |
public static final double |
DELTA |
0.5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1\t2\n2\t3\n2\t4\n3\t4" |
public static final String |
VERTICES_WITH_MIN_ID |
"1,1\n2,1\n3,1\n4,1" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1,2\n1,4\n2,3\n2,4\n2,5\n3,5\n4,5\n4,6\n5,7\n5,9\n6,7\n6,8\n7,8\n7,9\n8,9" |
public static final int |
NUM_VERTICES |
9 |
public static final String |
RESULTED_WEIGHTED_EDGES |
"1,2,1.4142135623730951\n1,4,4.242640687119285\n2,3,1.4142135623730951\n2,4,2.8284271247461903\n2,5,4.242640687119285\n3,5,2.8284271247461903\n4,5,1.4142135623730951\n4,6,2.8284271247461903\n5,7,2.8284271247461903\n5,9,5.656854249492381\n6,7,1.4142135623730951\n6,8,2.8284271247461903\n7,8,1.4142135623730951\n7,9,2.8284271247461903\n8,9,1.4142135623730951" |
public static final String |
VERTICES |
"1,1.0,1.0\n2,2.0,2.0\n3,3.0,3.0\n4,4.0,4.0\n5,5.0,5.0\n6,6.0,6.0\n7,7.0,7.0\n8,8.0,8.0\n9,9.0,9.0" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1,3,3.0\n2,4,3.0\n2,5,2.0\n3,2,1.0\n3,5,5.0\n4,5,1.0" |
public static final String |
EDGES_IN_SSSP |
"1,3,3.0\n2,5,2.0\n3,2,1.0\n4,5,1.0" |
public static final int |
NUM_VERTICES |
5 |
public static final String |
RESULTED_VERTICES |
"1,1.7976931348623157E308\n2,1.7976931348623157E308\n3,1.7976931348623157E308\n4,1.0\n5,0.0" |
public static final String |
SRC_EDGE_TO_BE_REMOVED |
"2" |
public static final String |
TRG_EDGE_TO_BE_REMOVED |
"5" |
public static final String |
VAL_EDGE_TO_BE_REMOVED |
"2.0" |
public static final String |
VERTICES |
"1,6.0\n2,2.0\n3,3.0\n4,1.0\n5,0.0" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LABELS_AFTER_1_ITERATION |
"1,10\n2,10\n3,10\n4,40\n5,40\n6,40\n7,40\n" |
public static final String |
LABELS_WITH_TIE |
"1,10\n2,10\n3,10\n4,10\n5,20\n6,20\n7,20\n8,20\n9,20\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMMUNITIES_RESULT |
"user_1\t1\nuser_2\t1\nuser_3\t3\nuser_4\t3\nuser_5\t4" |
public static final String |
MAX_ITERATIONS |
"2" |
public static final String |
MISMATCHES |
"ERROR: <song_5 track_8> Angie" |
public static final String |
TOP_SONGS_RESULT |
"user_1\tsong_1\nuser_2\tsong_4\nuser_3\tsong_2\nuser_4\tsong_3\nuser_5\tsong_3" |
public static final String |
USER_SONG_TRIPLETS |
"user_1\tsong_1\t100\nuser_1\tsong_5\t200\nuser_2\tsong_1\t10\nuser_2\tsong_4\t20\nuser_3\tsong_2\t3\nuser_4\tsong_2\t1\nuser_4\tsong_3\t2\nuser_5\tsong_3\t30" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"2\t1\n5\t2\n5\t4\n4\t3\n4\t2\n1\t4\n1\t2\n1\t3\n3\t5\n" |
public static final String |
RANKS_AFTER_3_ITERATIONS |
"1,0.237\n2,0.248\n3,0.173\n4,0.175\n5,0.165\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1\t2\t12.0\n1\t3\t13.0\n2\t3\t23.0\n3\t4\t34.0\n3\t5\t35.0\n4\t5\t45.0\n5\t1\t51.0" |
public static final String |
RESULTED_SINGLE_SOURCE_SHORTEST_PATHS |
"1,0.0\n2,12.0\n3,13.0\n4,47.0\n5,48.0" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EDGES |
"1\t2\n1\t3\n2\t3\n2\t6\n3\t4\n3\t5\n3\t6\n4\t5\n6\t7\n" |
public static final String |
RESULTED_NUMBER_OF_TRIANGLES |
"3" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_OFFSET |
1 |
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
public static final int |
MINIMUM_VERTEX_DEGREE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_DIMENSIONS |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final float |
DEFAULT_A |
0.5699999928474426f |
public static final float |
DEFAULT_B |
0.1899999976158142f |
public static final float |
DEFAULT_C |
0.1899999976158142f |
public static final float |
DEFAULT_NOISE |
0.10000000149011612f |
public static final int |
MINIMUM_EDGE_COUNT |
1 |
public static final int |
MINIMUM_VERTEX_COUNT |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_PAIR_COUNT |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MINIMUM_VERTEX_COUNT |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAXIMUM_BLOCK_COUNT |
32768 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_SEED |
5435701917232523172L |
public static final int |
MINIMUM_CYCLES_PER_BLOCK |
1048576 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_SEED |
8415200798306848441L |
public static final int |
MINIMUM_CYCLES_PER_BLOCK |
1048576 |
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 int |
HASH_SEED |
933365956 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
138865185 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
-1036437567 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
-744500821 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
1074835241 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
1074835241 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
-469371183 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_GROUP_SIZE |
64 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
HASH_SEED |
1931441127 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
4096 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
4 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
4096 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
1024 |
protected static final int |
ELEMENT_LENGTH_IN_BYTES |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
DEFAULT_CAPACITY_IN_BYTES |
4096 |
protected static final int |
HIGH_BIT |
128 |
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 |
JOB_MANAGER_MAIN_CONTAINER_NAME |
"flink-job-manager" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TASK_MANAGER_MAIN_CONTAINER_NAME |
"flink-task-manager" |
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 |
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 |
ENV_FLINK_CLASSPATH |
"FLINK_CLASSPATH" |
public static final String |
ENV_FLINK_POD_IP_ADDRESS |
"_POD_IP_ADDRESS" |
public static final String |
ENV_HADOOP_CONF_DIR |
"HADOOP_CONF_DIR" |
public static final String |
ENV_HADOOP_HOME |
"HADOOP_HOME" |
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 |
HEADLESS_SERVICE_CLUSTER_IP |
"None" |
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_MOUNT_DIR |
"/etc" |
public static final String |
KERBEROS_KRB5CONF_VOLUME |
"kerberos-krb5conf-volume" |
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 int |
MAXIMUM_CHARACTERS_OF_CLUSTER_ID |
45 |
public static final String |
NAME_SEPARATOR |
"-" |
public static final String |
NATIVE_KUBERNETES_COMMAND |
"native-k8s" |
public static final String |
POD_IP_FIELD_PATH |
"status.podIP" |
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 |
RUNNING_JOBS_REGISTRY_KEY_PREFIX |
"runningJobsRegistry-" |
public static final String |
SUBMITTED_JOBGRAPH_FILE_PREFIX |
"submittedJobGraph" |
public static final int |
TASK_MANAGER_RPC_PORT |
6122 |
public static final String |
TASK_MANAGER_RPC_PORT_NAME |
"taskmanager-rpc" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
UNRESERVED_ROLE |
"*" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ENV_FLINK_TMP_DIR |
"_FLINK_TMP_DIR" |
public static final String |
ENV_FRAMEWORK_NAME |
"FRAMEWORK_NAME" |
public static final String |
ENV_JVM_ARGS |
"JVM_ARGS" |
public static final String |
ENV_TASK_NAME |
"TASK_NAME" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_DOCKER |
"docker" |
public static final String |
MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_MESOS |
"mesos" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
UPDATE_INTERVAL_SECONDS |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
API_KEY |
"apikey" |
public static final String |
DATA_CENTER |
"dataCenter" |
public static final String |
MAX_METRICS_PER_REQUEST |
"maxMetricsPerRequest" |
public static final String |
PROXY_HOST |
"proxyHost" |
public static final String |
PROXY_PORT |
"proxyPort" |
public static final String |
TAGS |
"tags" |
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 |
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 |
PYTHON_REQUIREMENTS_CACHE |
"_PYTHON_REQUIREMENTS_CACHE" |
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 long |
NO_ALIGNMENT_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 int |
SEQUENCE_NUMBER_RESTORED |
-1 |
public static final int |
SEQUENCE_NUMBER_UNKNOWN |
-2 |
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 String |
DISPATCHER_NAME |
"dispatcher" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SCHEDULER_TYPE_NG |
"ng" |
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 int |
VALUE_NOT_SET |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_DISTINCT_LOCATIONS_TO_CONSIDER |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FULL_RESTART_STRATEGY_NAME |
"full" |
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 |
"restartingTime" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
METRIC_NAME |
"uptime" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_RESTART_ATTEMPTS |
2147483647 |
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 |
---|---|---|
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 String |
DEFAULT_OUTPUT_FLUSH_THREAD_NAME |
"OutputFlusher" |
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 |
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 |
12 |
public static final String |
INDEX_FILE_SUFFIX |
".shuffle.index" |
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 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_TOTAL |
"slots-total" |
public static final String |
FIELD_NAME_TASKMANAGERS |
"taskmanagers" |
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_JOBS |
"jobs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CHECKPOINT_ALIGNMENT_TIME |
"checkpointAlignmentTime" |
public static final String |
CHECKPOINT_START_DELAY_TIME |
"checkpointStartDelayNanos" |
public static final String |
FULL_RESTARTS |
"fullRestarts" |
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_BACKPRESSURED |
"isBackPressured" |
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 |
NUM_REGISTERED_TASK_MANAGERS |
"numRegisteredTaskManagers" |
public static final String |
NUM_RESTARTS |
"numRestarts" |
public static final String |
NUM_RUNNING_JOBS |
"numRunningJobs" |
public static final String |
SUFFIX_RATE |
"PerSecond" |
public static final String |
TASK_IDLE_TIME |
"idleTimeMsPerSecond" |
public static final String |
TASK_SLOTS_AVAILABLE |
"taskSlotsAvailable" |
public static final String |
TASK_SLOTS_TOTAL |
"taskSlotsTotal" |
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_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 String |
SCOPE_INHERIT_PARENT |
"*" |
public static final String |
SCOPE_SEPARATOR |
"." |
Modifier and Type | Constant Field | Value |
---|---|---|
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 |
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_CONFIG_KEY |
"key" |
public static final String |
FIELD_NAME_CONFIG_VALUE |
"value" |
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_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 |
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/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_EXECUTION_MODE |
"execution-mode" |
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_ALL_EXCEPTIONS |
"all-exceptions" |
public static final String |
FIELD_NAME_ROOT_EXCEPTION |
"root-exception" |
public static final String |
FIELD_NAME_TIMESTAMP |
"timestamp" |
public static final String |
FIELD_NAME_TRUNCATED |
"truncated" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME_EXCEPTION |
"exception" |
public static final String |
FIELD_NAME_LOCATION |
"location" |
public static final String |
FIELD_NAME_TASK |
"task" |
public static final String |
FIELD_NAME_TIMESTAMP |
"timestamp" |
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 |
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 |
FIELD_NAME_BACKPRESSURE_LEVEL |
"backpressure-level" |
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 |
FIELD_NAME_BACKPRESSURE_LEVEL |
"backpressure-level" |
public static final String |
FIELD_NAME_RATIO |
"ratio" |
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_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_DURATION |
"duration" |
public static final String |
TASK_MANAGERS_FIELD_END_TIME |
"end-time" |
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 |
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 |
KEY |
"operatorid" |
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 |
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_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 |
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_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_TIMEOUT |
"timeout" |
public static final String |
FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG |
"externalization" |
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_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_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_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_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" |
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_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_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 |
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_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_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 |
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_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_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_PARALLELISM |
"parallelism" |
public static final String |
FIELD_NAME_TASKS_PER_STATE |
"tasks" |
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_HOST |
"host" |
public static final String |
FIELD_NAME_METRICS |
"metrics" |
public static final String |
FIELD_NAME_START_TIME |
"start-time" |
public static final String |
FIELD_NAME_STATUS |
"status" |
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_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_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_TARGET_DIRECTORY |
"targetDirectory" |
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_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_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 |
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 |
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 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 |
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 |
5 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FS_STATE_BACKEND_NAME |
"filesystem" |
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 |
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 |
6 |
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 String |
LOCAL_STATE_SUB_DIRECTORY_ROOT |
"localState" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
UNKNOWN |
"<unknown>" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
EXIT_CODE |
-17 |
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" |
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 |
---|---|---|
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 String |
COL_DELIMITER |
";" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ALTER_DATABASE_OP |
"hive.alter.database.op" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DATABASE_OWNER_NAME |
"hive.database.owner.name" |
public static final String |
DATABASE_OWNER_TYPE |
"hive.database.owner.type" |
public static final String |
ROLE_OWNER |
"role" |
public static final String |
USER_OWNER |
"user" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ALTER_COL_CASCADE |
"alter.column.cascade" |
public static final String |
ALTER_TABLE_OP |
"alter.table.op" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DATABASE_LOCATION_URI |
"hive.database.location-uri" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NOT_NULL_COLS |
"hive.not.null.cols" |
public static final String |
NOT_NULL_CONSTRAINT_TRAITS |
"hive.not.null.constraint.traits" |
public static final String |
PK_CONSTRAINT_TRAIT |
"hive.pk.constraint.trait" |
public static final String |
TABLE_IS_EXTERNAL |
"hive.is-external" |
public static final String |
TABLE_LOCATION_URI |
"hive.location-uri" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COLLECTION_DELIM |
"hive.serde.info.prop.collection.delim" |
public static final String |
SERDE_INFO_PROP_PREFIX |
"hive.serde.info.prop." |
public static final String |
SERDE_LIB_CLASS_NAME |
"hive.serde.lib.class.name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
STORED_AS_FILE_FORMAT |
"hive.storage.file-format" |
public static final String |
STORED_AS_INPUT_FORMAT |
"hive.stored.as.input.format" |
public static final String |
STORED_AS_OUTPUT_FORMAT |
"hive.stored.as.output.format" |
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 |
AND |
15 |
public static final int |
ANY |
16 |
public static final int |
APPLY |
17 |
public static final int |
APPROX_NUMERIC_LITERAL |
720 |
public static final int |
ARE |
18 |
public static final int |
ARRAY |
19 |
public static final int |
ARRAY_MAX_CARDINALITY |
20 |
public static final int |
AS |
21 |
public static final int |
ASC |
22 |
public static final int |
ASENSITIVE |
23 |
public static final int |
ASSERTION |
24 |
public static final int |
ASSIGNMENT |
25 |
public static final int |
ASYMMETRIC |
26 |
public static final int |
AT |
27 |
public static final int |
ATOMIC |
28 |
public static final int |
ATTRIBUTE |
29 |
public static final int |
ATTRIBUTES |
30 |
public static final int |
AUTHORIZATION |
31 |
public static final int |
AVG |
32 |
public static final int |
BACK_QUOTED_IDENTIFIER |
783 |
public static final int |
BEFORE |
33 |
public static final int |
BEGIN |
34 |
public static final int |
BEGIN_FRAME |
35 |
public static final int |
BEGIN_PARTITION |
36 |
public static final int |
BEL |
790 |
public static final int |
BERNOULLI |
37 |
public static final int |
BETWEEN |
38 |
public static final int |
BIG_QUERY_DOUBLE_QUOTED_STRING |
730 |
public static final int |
BIG_QUERY_QUOTED_STRING |
731 |
public static final int |
BIGINT |
39 |
public static final int |
BINARY |
40 |
public static final int |
BINARY_STRING_LITERAL |
725 |
public static final int |
BIT |
41 |
public static final int |
BLOB |
42 |
public static final int |
BOOLEAN |
43 |
public static final int |
BOTH |
44 |
public static final int |
BQHID |
4 |
public static final int |
BQID |
3 |
public static final int |
BRACKET_QUOTED_IDENTIFIER |
781 |
public static final int |
BREADTH |
45 |
public static final int |
BTID |
2 |
public static final int |
BY |
46 |
public static final int |
BYTES |
675 |
public static final int |
C |
47 |
public static final int |
CALL |
48 |
public static final int |
CALLED |
49 |
public static final int |
CARDINALITY |
50 |
public static final int |
CARET |
766 |
public static final int |
CASCADE |
51 |
public static final int |
CASCADED |
52 |
public static final int |
CASE |
53 |
public static final int |
CAST |
54 |
public static final int |
CATALOG |
55 |
public static final int |
CATALOG_NAME |
56 |
public static final int |
CATALOGS |
676 |
public static final int |
CEIL |
57 |
public static final int |
CEILING |
58 |
public static final int |
CENTURY |
59 |
public static final int |
CHAIN |
60 |
public static final int |
CHANGE |
677 |
public static final int |
CHAR |
61 |
public static final int |
CHAR_LENGTH |
62 |
public static final int |
CHARACTER |
63 |
public static final int |
CHARACTER_LENGTH |
64 |
public static final int |
CHARACTER_SET_CATALOG |
65 |
public static final int |
CHARACTER_SET_NAME |
66 |
public static final int |
CHARACTER_SET_SCHEMA |
67 |
public static final int |
CHARACTERISTICS |
68 |
public static final int |
CHARACTERS |
69 |
public static final int |
CHARSETNAME |
729 |
public static final int |
CHECK |
70 |
public static final int |
CLASS_ORIGIN |
72 |
public static final int |
CLASSIFIER |
71 |
public static final int |
CLOB |
73 |
public static final int |
CLOSE |
74 |
public static final int |
COALESCE |
75 |
public static final int |
COBOL |
76 |
public static final int |
COLLATE |
77 |
public static final int |
COLLATION |
78 |
public static final int |
COLLATION_CATALOG |
79 |
public static final int |
COLLATION_ID |
786 |
public static final int |
COLLATION_NAME |
80 |
public static final int |
COLLATION_SCHEMA |
81 |
public static final int |
COLLECT |
82 |
public static final int |
COLLECTION |
678 |
public static final int |
COLON |
750 |
public static final int |
COLUMN |
83 |
public static final int |
COLUMN_NAME |
84 |
public static final int |
COLUMNS |
679 |
public static final int |
COMMA |
745 |
public static final int |
COMMAND_FUNCTION |
85 |
public static final int |
COMMAND_FUNCTION_CODE |
86 |
public static final int |
COMMENT |
680 |
public static final int |
COMMENT_END |
774 |
public static final int |
COMMIT |
87 |
public static final int |
COMMITTED |
88 |
public static final int |
CONCAT |
760 |
public static final int |
CONDITION |
89 |
public static final int |
CONDITION_NUMBER |
91 |
public static final int |
CONDITIONAL |
90 |
public static final int |
CONNECT |
92 |
public static final int |
CONNECTION |
93 |
public static final int |
CONNECTION_NAME |
94 |
public static final int |
CONSTRAINT |
95 |
public static final int |
CONSTRAINT_CATALOG |
96 |
public static final int |
CONSTRAINT_NAME |
97 |
public static final int |
CONSTRAINT_SCHEMA |
98 |
public static final int |
CONSTRAINTS |
99 |
public static final int |
CONSTRUCTOR |
100 |
public static final int |
CONTAINS |
101 |
public static final int |
CONTINUE |
102 |
public static final int |
CONVERT |
103 |
public static final int |
CORR |
104 |
public static final int |
CORRESPONDING |
105 |
public static final int |
COUNT |
106 |
public static final int |
COVAR_POP |
107 |
public static final int |
COVAR_SAMP |
108 |
public static final int |
CREATE |
109 |
public static final int |
CROSS |
110 |
public static final int |
CUBE |
111 |
public static final int |
CUME_DIST |
112 |
public static final int |
CURRENT |
113 |
public static final int |
CURRENT_CATALOG |
114 |
public static final int |
CURRENT_DATE |
115 |
public static final int |
CURRENT_DEFAULT_TRANSFORM_GROUP |
116 |
public static final int |
CURRENT_PATH |
117 |
public static final int |
CURRENT_ROLE |
118 |
public static final int |
CURRENT_ROW |
119 |
public static final int |
CURRENT_SCHEMA |
120 |
public static final int |
CURRENT_TIME |
121 |
public static final int |
CURRENT_TIMESTAMP |
122 |
public static final int |
CURRENT_TRANSFORM_GROUP_FOR_TYPE |
123 |
public static final int |
CURRENT_USER |
124 |
public static final int |
CURSOR |
125 |
public static final int |
CURSOR_NAME |
126 |
public static final int |
CYCLE |
127 |
public static final int |
DATA |
128 |
public static final int |
DATABASE |
129 |
public static final int |
DATABASES |
681 |
public static final int |
DATE |
130 |
public static final int |
DATETIME_INTERVAL_CODE |
131 |
public static final int |
DATETIME_INTERVAL_PRECISION |
132 |
public static final int |
DAY |
133 |
public static final int |
DAYS |
134 |
public static final int |
DBPROPERTIES |
682 |
public static final int |
DEALLOCATE |
135 |
public static final int |
DEC |
136 |
public static final int |
DECADE |
137 |
public static final int |
DECIMAL |
138 |
public static final int |
DECIMAL_NUMERIC_LITERAL |
721 |
public static final int |
DECLARE |
139 |
public static final int |
DEFAULT |
0 |
public static final int |
DEFAULT_ |
140 |
public static final int |
DEFAULTS |
141 |
public static final int |
DEFERRABLE |
142 |
public static final int |
DEFERRED |
143 |
public static final int |
DEFINE |
144 |
public static final int |
DEFINED |
145 |
public static final int |
DEFINER |
146 |
public static final int |
DEGREE |
147 |
public static final int |
DELETE |
148 |
public static final int |
DELIMITED |
683 |
public static final int |
DENSE_RANK |
149 |
public static final int |
DEPTH |
150 |
public static final int |
DEREF |
151 |
public static final int |
DERIVED |
152 |
public static final int |
DESC |
153 |
public static final int |
DESCRIBE |
154 |
public static final int |
DESCRIPTION |
155 |
public static final int |
DESCRIPTOR |
156 |
public static final int |
DETERMINISTIC |
157 |
public static final int |
DIAGNOSTICS |
158 |
public static final int |
DIGIT |
789 |
public static final int |
DISABLE |
684 |
public static final int |
DISALLOW |
159 |
public static final int |
DISCONNECT |
160 |
public static final int |
DISPATCH |
161 |
public static final int |
DISTINCT |
162 |
public static final int |
DOLLAR |
767 |
public static final int |
DOMAIN |
163 |
public static final int |
DOT |
744 |
public static final int |
DOUBLE |
164 |
public static final int |
DOUBLE_PERIOD |
762 |
public static final int |
DOUBLE_QUOTE |
764 |
public static final int |
DOW |
165 |
public static final int |
DOY |
166 |
public static final int |
DQID |
1 |
public static final int |
DROP |
167 |
public static final int |
DYNAMIC |
168 |
public static final int |
DYNAMIC_FUNCTION |
169 |
public static final int |
DYNAMIC_FUNCTION_CODE |
170 |
public static final int |
EACH |
171 |
public static final int |
ELEMENT |
172 |
public static final int |
ELSE |
173 |
public static final int |
EMPTY |
174 |
public static final int |
ENABLE |
685 |
public static final int |
ENCODING |
175 |
public static final int |
END |
176 |
public static final int |
END_EXEC |
177 |
public static final int |
END_FRAME |
178 |
public static final int |
END_PARTITION |
179 |
public static final int |
EOF |
0 |
public static final int |
EPOCH |
180 |
public static final int |
EQ |
746 |
public static final int |
EQUALS |
181 |
public static final int |
ERROR |
182 |
public static final int |
ESCAPE |
183 |
public static final int |
ESCAPED |
686 |
public static final int |
EVERY |
184 |
public static final int |
EXCEPT |
185 |
public static final int |
EXCEPTION |
186 |
public static final int |
EXCLUDE |
187 |
public static final int |
EXCLUDING |
188 |
public static final int |
EXEC |
189 |
public static final int |
EXECUTE |
190 |
public static final int |
EXISTS |
191 |
public static final int |
EXP |
192 |
public static final int |
EXPLAIN |
193 |
public static final int |
EXPONENT |
722 |
public static final int |
EXTEND |
194 |
public static final int |
EXTENDED |
687 |
public static final int |
EXTERNAL |
195 |
public static final int |
EXTRACT |
196 |
public static final int |
FALSE |
197 |
public static final int |
FETCH |
198 |
public static final int |
FIELDS |
688 |
public static final int |
FILEFORMAT |
689 |
public static final int |
FILTER |
199 |
public static final int |
FINAL |
200 |
public static final int |
FIRST |
201 |
public static final int |
FIRST_VALUE |
202 |
public static final int |
FLOAT |
203 |
public static final int |
FLOOR |
204 |
public static final int |
FOLLOWING |
205 |
public static final int |
FOR |
206 |
public static final int |
FOREIGN |
208 |
public static final int |
FORMAL_COMMENT |
778 |
public static final int |
FORMAT |
207 |
public static final int |
FORMATTED |
690 |
public static final int |
FORTRAN |
209 |
public static final int |
FOUND |
210 |
public static final int |
FRAC_SECOND |
211 |
public static final int |
FRAME_ROW |
212 |
public static final int |
FREE |
213 |
public static final int |
FROM |
214 |
public static final int |
FULL |
215 |
public static final int |
FUNCTION |
216 |
public static final int |
FUNCTIONS |
691 |
public static final int |
FUSION |
217 |
public static final int |
G |
218 |
public static final int |
GE |
752 |
public static final int |
GENERAL |
219 |
public static final int |
GENERATED |
220 |
public static final int |
GEOMETRY |
221 |
public static final int |
GET |
222 |
public static final int |
GLOBAL |
223 |
public static final int |
GO |
224 |
public static final int |
GOTO |
225 |
public static final int |
GRANT |
226 |
public static final int |
GRANTED |
227 |
public static final int |
GROUP |
228 |
public static final int |
GROUPING |
229 |
public static final int |
GROUPS |
230 |
public static final int |
GT |
747 |
public static final int |
HAVING |
231 |
public static final int |
HEXDIGIT |
723 |
public static final int |
HIERARCHY |
232 |
public static final int |
HINT_BEG |
773 |
public static final int |
HOLD |
233 |
public static final int |
HOOK |
749 |
public static final int |
HOP |
234 |
public static final int |
HOUR |
235 |
public static final int |
HOURS |
236 |
public static final int |
HYPHENATED_IDENTIFIER |
784 |
public static final int |
IDENTIFIER |
785 |
public static final int |
IDENTITY |
237 |
public static final int |
IF |
692 |
public static final int |
IGNORE |
238 |
public static final int |
IMMEDIATE |
239 |
public static final int |
IMMEDIATELY |
240 |
public static final int |
IMPLEMENTATION |
241 |
public static final int |
IMPORT |
242 |
public static final int |
IN |
243 |
public static final int |
IN_FORMAL_COMMENT |
5 |
public static final int |
IN_MULTI_LINE_COMMENT |
6 |
public static final int |
INCLUDING |
244 |
public static final int |
INCREMENT |
245 |
public static final int |
INDICATOR |
246 |
public static final int |
INITIAL |
247 |
public static final int |
INITIALLY |
248 |
public static final int |
INNER |
249 |
public static final int |
INOUT |
250 |
public static final int |
INPUT |
251 |
public static final int |
INPUTFORMAT |
693 |
public static final int |
INSENSITIVE |
252 |
public static final int |
INSERT |
253 |
public static final int |
INSTANCE |
254 |
public static final int |
INSTANTIABLE |
255 |
public static final int |
INT |
256 |
public static final int |
INTEGER |
257 |
public static final int |
INTERSECT |
258 |
public static final int |
INTERSECTION |
259 |
public static final int |
INTERVAL |
260 |
public static final int |
INTO |
261 |
public static final int |
INVOKER |
262 |
public static final int |
IS |
263 |
public static final int |
ISODOW |
264 |
public static final int |
ISOLATION |
266 |
public static final int |
ISOYEAR |
265 |
public static final int |
ITEMS |
694 |
public static final int |
JAVA |
267 |
public static final int |
JOIN |
268 |
public static final int |
JSON |
269 |
public static final int |
JSON_ARRAY |
270 |
public static final int |
JSON_ARRAYAGG |
271 |
public static final int |
JSON_EXISTS |
272 |
public static final int |
JSON_OBJECT |
273 |
public static final int |
JSON_OBJECTAGG |
274 |
public static final int |
JSON_QUERY |
275 |
public static final int |
JSON_VALUE |
276 |
public static final int |
K |
277 |
public static final int |
KEY |
278 |
public static final int |
KEY_MEMBER |
279 |
public static final int |
KEY_TYPE |
280 |
public static final int |
KEYS |
695 |
public static final int |
LABEL |
281 |
public static final int |
LAG |
282 |
public static final int |
LANGUAGE |
283 |
public static final int |
LARGE |
284 |
public static final int |
LAST |
285 |
public static final int |
LAST_VALUE |
286 |
public static final int |
LATERAL |
287 |
public static final int |
LBRACE |
739 |
public static final int |
LBRACE_D |
735 |
public static final int |
LBRACE_FN |
738 |
public static final int |
LBRACE_T |
736 |
public static final int |
LBRACE_TS |
737 |
public static final int |
LBRACKET |
741 |
public static final int |
LE |
751 |
public static final int |
LEAD |
288 |
public static final int |
LEADING |
289 |
public static final int |
LEFT |
290 |
public static final int |
LENGTH |
291 |
public static final int |
LETTER |
788 |
public static final int |
LEVEL |
292 |
public static final int |
LIBRARY |
293 |
public static final int |
LIKE |
294 |
public static final int |
LIKE_REGEX |
295 |
public static final int |
LIMIT |
296 |
public static final int |
LINES |
696 |
public static final int |
LN |
297 |
< |