Constant Field Values
Contents
com.amazonaws.*
-
com.amazonaws.services.s3.model.transform.XmlResponsesSaxParser.GetBucketInventoryConfigurationHandler Modifier and Type Constant Field Value public static final String
SSE_KMS
"SSE-KMS"
public static final String
SSE_S3
"SSE-S3"
org.apache.*
-
org.apache.calcite.sql.validate.SqlValidatorImpl Modifier and Type Constant Field Value public static final String
UPDATE_ANON_PREFIX
"SYS$ANON"
public static final String
UPDATE_SRC_ALIAS
"SYS$SRC"
public static final String
UPDATE_TGT_ALIAS
"SYS$TGT"
-
org.apache.calcite.sql2rel.SqlToRelConverter Modifier and Type Constant Field Value public static final int
DEFAULT_IN_SUB_QUERY_THRESHOLD
20
public static final int
DEFAULT_IN_SUBQUERY_THRESHOLD
20
-
org.apache.flink.annotation.docs.Documentation.Sections Modifier and Type Constant Field Value public static final String
ALL_JOB_MANAGER
"all_jobmanager"
public static final String
ALL_TASK_MANAGER
"all_taskmanager"
public static final String
ALL_TASK_MANAGER_NETWORK
"all_taskmanager_network"
public static final String
CHECKPOINT_FILE_MERGING
"checkpoint_file_merging"
public static final String
COMMON_CHECKPOINTING
"common_checkpointing"
public static final String
COMMON_HIGH_AVAILABILITY
"common_high_availability"
public static final String
COMMON_HIGH_AVAILABILITY_JOB_RESULT_STORE
"common_high_availability_jrs"
public static final String
COMMON_HIGH_AVAILABILITY_ZOOKEEPER
"common_high_availability_zk"
public static final String
COMMON_HOST_PORT
"common_host_port"
public static final String
COMMON_MEMORY
"common_memory"
public static final String
COMMON_MISCELLANEOUS
"common_miscellaneous"
public static final String
COMMON_STATE_BACKENDS
"common_state_backends"
public static final String
DEPRECATED_FILE_SINKS
"deprecated_file_sinks"
public static final String
EXPERT_CHECKPOINTING
"expert_checkpointing"
public static final String
EXPERT_CLASS_LOADING
"expert_class_loading"
public static final String
EXPERT_CLUSTER
"expert_cluster"
public static final String
EXPERT_DEBUGGING_AND_TUNING
"expert_debugging_and_tuning"
public static final String
EXPERT_FAULT_TOLERANCE
"expert_fault_tolerance"
public static final String
EXPERT_HIGH_AVAILABILITY
"expert_high_availability"
public static final String
EXPERT_JOB_MANAGER
"expert_jobmanager"
public static final String
EXPERT_KUBERNETES_HIGH_AVAILABILITY
"expert_high_availability_k8s"
public static final String
EXPERT_REST
"expert_rest"
public static final String
EXPERT_ROCKSDB
"expert_rocksdb"
public static final String
EXPERT_SCHEDULING
"expert_scheduling"
public static final String
EXPERT_SECURITY_SSL
"expert_security_ssl"
public static final String
EXPERT_ZOOKEEPER_HIGH_AVAILABILITY
"expert_high_availability_zk"
public static final String
METRIC_REPORTERS
"metric_reporters"
public static final String
SECURITY_AUTH_KERBEROS
"security_auth_kerberos"
public static final String
SECURITY_AUTH_ZOOKEEPER
"security_auth_zk"
public static final String
SECURITY_DELEGATION_TOKEN
"security_delegation_token"
public static final String
SECURITY_SSL
"security_ssl"
public static final String
STATE_BACKEND_ROCKSDB
"state_backend_rocksdb"
public static final String
STATE_CHANGELOG
"state_changelog"
public static final String
STATE_LATENCY_TRACKING
"state_latency_tracking"
public static final String
TRACE_REPORTERS
"trace_reporters"
-
org.apache.flink.api.common.ExecutionConfig Modifier and Type Constant Field Value public static final int
PARALLELISM_DEFAULT
-1
public static final int
PARALLELISM_UNKNOWN
-2
-
org.apache.flink.api.common.eventtime.TimestampAssigner<T> Modifier and Type Constant Field Value public static final long
NO_TIMESTAMP
-9223372036854775808L
-
org.apache.flink.api.common.io.BinaryInputFormat<T> Modifier and Type Constant Field Value public static final long
NATIVE_BLOCK_SIZE
-9223372036854775808L
-
org.apache.flink.api.common.io.BinaryOutputFormat<T> Modifier and Type Constant Field Value public static final long
NATIVE_BLOCK_SIZE
-9223372036854775808L
-
org.apache.flink.api.common.io.DelimitedInputFormat<OT> Modifier and Type Constant Field Value protected static final String
RECORD_DELIMITER
"delimited-format.delimiter"
-
org.apache.flink.api.common.io.FileInputFormat<OT> Modifier and Type Constant Field Value protected static final long
READ_WHOLE_SPLIT_FLAG
-1L
-
org.apache.flink.api.common.io.FilePathFilter Modifier and Type Constant Field Value public static final String
HADOOP_COPYING
"_COPYING_"
-
org.apache.flink.api.common.io.statistics.BaseStatistics 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
-
org.apache.flink.api.common.operators.Keys.ExpressionKeys<T> Modifier and Type Constant Field Value public static final String
SELECT_ALL_CHAR
"*"
public static final String
SELECT_ALL_CHAR_SCALA
"_"
-
org.apache.flink.api.common.operators.Keys.IncompatibleKeysException Modifier and Type Constant Field Value public static final String
SIZE_MISMATCH_MESSAGE
"The number of specified keys is different."
-
org.apache.flink.api.common.operators.base.BulkIterationBase<T> Modifier and Type Constant Field Value public static final String
TERMINATION_CRITERION_AGGREGATOR_NAME
"terminationCriterion.aggregator"
-
org.apache.flink.api.common.resources.CPUResource Modifier and Type Constant Field Value public static final String
NAME
"CPU"
-
org.apache.flink.api.connector.sink2.InitContext Modifier and Type Constant Field Value public static final long
INITIAL_CHECKPOINT_ID
1L
-
org.apache.flink.api.dag.Transformation<T> Modifier and Type Constant Field Value public static final int
UPPER_BOUND_MAX_PARALLELISM
32768
-
org.apache.flink.api.java.tuple.Tuple Modifier and Type Constant Field Value public static final int
MAX_ARITY
25
-
org.apache.flink.api.java.typeutils.AvroUtils Modifier and Type Constant Field Value protected static final String
AVRO_SPECIFIC_RECORD_BASE_CLASS
"org.apache.avro.specific.SpecificRecordBase"
-
org.apache.flink.api.java.typeutils.runtime.RowSerializer Modifier and Type Constant Field Value public static final int
ROW_KIND_OFFSET
2
-
org.apache.flink.architecture.rules.TableApiRules Modifier and Type Constant Field Value public static final String
CONFIG_OPTIONS_FQ_NAME
"org.apache.flink.configuration.ConfigOption"
-
org.apache.flink.cep.EventComparator<T> Modifier and Type Constant Field Value public static final long
serialVersionUID
1L
-
org.apache.flink.cep.nfa.compiler.NFACompiler Modifier and Type Constant Field Value protected static final String
ENDING_STATE_NAME
"$endState$"
-
org.apache.flink.cep.nfa.compiler.NFAStateNameHandler Modifier and Type Constant Field Value public static final String
STATE_NAME_DELIM
":"
-
org.apache.flink.changelog.fs.ChangelogStorageMetricGroup Modifier and Type Constant Field Value public static final String
CHANGELOG_STORAGE_ATTEMPTS_PER_UPLOAD
"ChangelogStorage.attemptsPerUpload"
public static final String
CHANGELOG_STORAGE_NUM_UPLOAD_FAILURES
"ChangelogStorage.numberOfUploadFailures"
public static final String
CHANGELOG_STORAGE_NUM_UPLOAD_REQUESTS
"ChangelogStorage.numberOfUploadRequests"
public static final String
CHANGELOG_STORAGE_TOTAL_ATTEMPTS_PER_UPLOAD
"ChangelogStorage.totalAttemptsPerUpload"
public static final String
CHANGELOG_STORAGE_UPLOAD_BATCH_SIZES
"ChangelogStorage.uploadBatchSizes"
public static final String
CHANGELOG_STORAGE_UPLOAD_LATENCIES_NANOS
"ChangelogStorage.uploadLatenciesNanos"
public static final String
CHANGELOG_STORAGE_UPLOAD_QUEUE_SIZE
"ChangelogStorage.uploadQueueSize"
public static final String
CHANGELOG_STORAGE_UPLOAD_SIZES
"ChangelogStorage.uploadSizes"
-
org.apache.flink.changelog.fs.FsStateChangelogStorageFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"filesystem"
-
org.apache.flink.changelog.fs.StateChangeFsUploader Modifier and Type Constant Field Value public static final String
PATH_SUB_DIR
"dstl"
-
org.apache.flink.client.cli.DefaultCLI Modifier and Type Constant Field Value public static final String
ID
"default"
-
org.apache.flink.client.deployment.application.executors.EmbeddedExecutor Modifier and Type Constant Field Value public static final String
NAME
"embedded"
-
org.apache.flink.client.deployment.executors.LocalExecutor Modifier and Type Constant Field Value public static final String
NAME
"local"
-
org.apache.flink.client.deployment.executors.RemoteExecutor Modifier and Type Constant Field Value public static final String
NAME
"remote"
-
org.apache.flink.client.program.PackagedProgram 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"
-
org.apache.flink.configuration.CleanupOptions Modifier and Type Constant Field Value public static final String
EXPONENTIAL_DELAY_LABEL
"exponential-delay"
public static final String
FIXED_DELAY_LABEL
"fixed-delay"
-
org.apache.flink.configuration.ConfigConstants Modifier and Type Constant Field Value public static final String
DEFAULT_FLINK_LIB_DIR
"lib"
public static final String
DEFAULT_FLINK_OPT_DIR
"opt"
public static final String
DEFAULT_FLINK_PLUGINS_DIRS
"plugins"
public static final String
DEFAULT_FLINK_USR_LIB_DIR
"usrlib"
public static final int
DEFAULT_LOCAL_NUMBER_TASK_MANAGER
1
public static final String
DEFAULT_YARN_CONTAINER_START_COMMAND_TEMPLATE
"%java% %jvmmem% %jvmopts% %logging% %class% %args% %redirects%"
public static final String
ENV_FLINK_CONF_DIR
"FLINK_CONF_DIR"
public static final String
ENV_FLINK_HOME_DIR
"FLINK_HOME"
public static final String
ENV_FLINK_LIB_DIR
"FLINK_LIB_DIR"
public static final String
ENV_FLINK_OPT_DIR
"FLINK_OPT_DIR"
public static final String
ENV_FLINK_PLUGINS_DIR
"FLINK_PLUGINS_DIR"
public static final String
FLINK_REST_CLIENT_HEADERS
"FLINK_REST_CLIENT_HEADERS"
public static final String
METRICS_REPORTER_PREFIX
"metrics.reporter."
public static final String
TRACES_REPORTER_PREFIX
"traces.reporter."
-
org.apache.flink.configuration.ConfigurationFileMigrationUtils Modifier and Type Constant Field Value public static final String
LEGACY_FLINK_CONF_FILENAME
"flink-conf.yaml"
-
org.apache.flink.configuration.ExecutionOptions Modifier and Type Constant Field Value public static final long
DISABLED_NETWORK_BUFFER_TIMEOUT
-1L
public static final long
FLUSH_AFTER_EVERY_RECORD
0L
-
org.apache.flink.configuration.ExternalResourceOptions Modifier and Type Constant Field Value public static final String
EXTERNAL_RESOURCE_AMOUNT_SUFFIX
"amount"
public static final String
EXTERNAL_RESOURCE_DRIVER_FACTORY_SUFFIX
"driver-factory.class"
public static final String
EXTERNAL_RESOURCE_DRIVER_PARAM_SUFFIX
"param."
public static final String
NONE
"none"
-
org.apache.flink.configuration.GlobalConfiguration Modifier and Type Constant Field Value public static final String
FLINK_CONF_FILENAME
"config.yaml"
public static final String
HIDDEN_CONTENT
"******"
-
org.apache.flink.configuration.HeartbeatManagerOptions Modifier and Type Constant Field Value public static final int
FAILED_RPC_DETECTION_DISABLED
-1
-
org.apache.flink.configuration.ResourceManagerOptions 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."
-
org.apache.flink.configuration.RestartStrategyOptions Modifier and Type Constant Field Value public static final String
RESTART_STRATEGY_CONFIG_PREFIX
"restart-strategy"
-
org.apache.flink.configuration.SecurityOptions Modifier and Type Constant Field Value public static final String
DELEGATION_TOKEN_PROVIDER_PREFIX
"security.delegation.token.provider.<serviceName>"
-
org.apache.flink.configuration.TaskManagerOptions Modifier and Type Constant Field Value public static final String
MANAGED_MEMORY_CONSUMER_NAME_OPERATOR
"OPERATOR"
public static final String
MANAGED_MEMORY_CONSUMER_NAME_PYTHON
"PYTHON"
public static final String
MANAGED_MEMORY_CONSUMER_NAME_STATE_BACKEND
"STATE_BACKEND"
-
org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration Modifier and Type Constant Field Value public static final boolean
DEFAULT_FAIL_ON_TIMEOUT
false
-
org.apache.flink.connector.blackhole.table.BlackHoleTableSinkFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"blackhole"
-
org.apache.flink.connector.datagen.table.DataGenConnectorOptionsUtil Modifier and Type Constant Field Value public static final String
END
"end"
public static final String
FIELDS
"fields"
public static final String
KIND
"kind"
public static final String
LENGTH
"length"
public static final String
MAX
"max"
public static final String
MAX_PAST
"max-past"
public static final String
MIN
"min"
public static final String
NULL_RATE
"null-rate"
public static final String
RANDOM
"random"
public static final String
SEQUENCE
"sequence"
public static final String
START
"start"
public static final String
VAR_LEN
"var-len"
-
org.apache.flink.connector.datagen.table.DataGenTableSourceFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"datagen"
-
org.apache.flink.connector.datagen.table.RandomGeneratorVisitor Modifier and Type Constant Field Value public static final int
RANDOM_BYTES_LENGTH_DEFAULT
100
public static final int
RANDOM_STRING_LENGTH_DEFAULT
100
-
org.apache.flink.connector.file.src.reader.TextLineInputFormat Modifier and Type Constant Field Value public static final String
DEFAULT_CHARSET_NAME
"UTF-8"
-
org.apache.flink.connector.file.src.util.CheckpointedPosition Modifier and Type Constant Field Value public static final long
NO_OFFSET
-1L
-
org.apache.flink.connector.file.src.util.RecordAndPosition<E> Modifier and Type Constant Field Value public static final long
NO_OFFSET
-1L
-
org.apache.flink.connector.file.table.FileSystemTableFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"filesystem"
-
org.apache.flink.connector.file.table.PartitionCommitPolicy Modifier and Type Constant Field Value public static final String
CUSTOM
"custom"
public static final String
METASTORE
"metastore"
public static final String
SUCCESS_FILE
"success-file"
-
org.apache.flink.connector.file.table.PartitionTimeExtractor Modifier and Type Constant Field Value public static final String
CUSTOM
"custom"
public static final String
DEFAULT
"default"
-
org.apache.flink.connector.file.table.batch.BatchSink Modifier and Type Constant Field Value public static final String
COMPACT_OP_NAME
"compact-operator"
public static final String
COORDINATOR_OP_NAME
"compact-coordinator"
-
org.apache.flink.connector.file.table.batch.compact.BatchCompactOperator<T> Modifier and Type Constant Field Value public static final String
ATTEMPT_PREFIX
"attempt-"
public static final String
COMPACTED_PREFIX
"compacted-"
public static final String
UNCOMPACTED_PREFIX
"uncompacted-"
-
org.apache.flink.connector.file.table.stream.compact.CompactOperator<T> Modifier and Type Constant Field Value public static final String
COMPACTED_PREFIX
"compacted-"
public static final String
UNCOMPACTED_PREFIX
".uncompacted-"
-
org.apache.flink.connector.print.table.PrintTableSinkFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"print"
-
org.apache.flink.connector.testframe.junit.extensions.ConnectorTestingExtension Modifier and Type Constant Field Value public static final String
EXTERNAL_CONTEXT_FACTORIES_STORE_KEY
"externalContext"
public static final String
EXTERNAL_SYSTEM_STORE_KEY
"externalSystem"
public static final String
SUPPORTED_SEMANTIC_STORE_KEY
"supportedSemantic"
public static final String
TEST_ENV_STORE_KEY
"testEnvironment"
-
org.apache.flink.connector.testframe.source.split.FromElementsSplit Modifier and Type Constant Field Value public static final String
SPLIT_ID
"fakeSplitId"
-
org.apache.flink.connector.testframe.utils.ConnectorTestConstants Modifier and Type Constant Field Value public static final long
HEARTBEAT_INTERVAL_MS
1000L
public static final long
HEARTBEAT_TIMEOUT_MS
5000L
public static final long
METRIC_FETCHER_UPDATE_INTERVAL_MS
1000L
public static final long
SLOT_REQUEST_TIMEOUT_MS
10000L
-
org.apache.flink.connector.testutils.source.reader.SourceReaderTestBase<SplitT extends SourceSplit> Modifier and Type Constant Field Value protected static final int
NUM_RECORDS_PER_SPLIT
10
-
org.apache.flink.connector.upserttest.table.UpsertTestDynamicTableSinkFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"upsert-files"
-
org.apache.flink.core.execution.DetachedJobExecutionResult 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. "
-
org.apache.flink.core.fs.Path Modifier and Type Constant Field Value public static final String
CUR_DIR
"."
public static final String
SEPARATOR
"/"
public static final char
SEPARATOR_CHAR
47
-
org.apache.flink.core.fs.RefCountedBufferingFileStream Modifier and Type Constant Field Value public static final int
BUFFER_SIZE
4096
-
org.apache.flink.core.memory.MemorySegment Modifier and Type Constant Field Value public static final String
CHECK_MULTIPLE_FREE_PROPERTY
"flink.tests.check-segment-multiple-free"
-
org.apache.flink.core.security.token.DelegationTokenProvider Modifier and Type Constant Field Value public static final String
CONFIG_PREFIX
"security.delegation.token.provider"
-
org.apache.flink.core.security.token.DelegationTokenReceiver Modifier and Type Constant Field Value public static final String
CONFIG_PREFIX
"security.delegation.token.receiver"
-
org.apache.flink.dropwizard.ScheduledDropwizardReporter 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"
-
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor Modifier and Type Constant Field Value public static final int
ARROW_TYPE_FIELD_NUMBER
3
public static final int
FLATTEN_ROW_TYPE_FIELD_NUMBER
1
public static final int
MODE_FIELD_NUMBER
6
public static final int
OVER_WINDOW_ARROW_TYPE_FIELD_NUMBER
4
public static final int
RAW_TYPE_FIELD_NUMBER
5
public static final int
ROW_TYPE_FIELD_NUMBER
2
public static final int
SEPARATED_WITH_END_MESSAGE_FIELD_NUMBER
7
-
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.ArrowType Modifier and Type Constant Field Value public static final int
SCHEMA_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.FlattenRowType Modifier and Type Constant Field Value public static final int
SCHEMA_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.Mode Modifier and Type Constant Field Value public static final int
MULTIPLE_VALUE
1
public static final int
SINGLE_VALUE
0
-
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType Modifier and Type Constant Field Value public static final int
SCHEMA_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.RawType Modifier and Type Constant Field Value public static final int
TYPE_INFO_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.RowType Modifier and Type Constant Field Value public static final int
SCHEMA_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow Modifier and Type Constant Field Value public static final int
ALLOWEDLATENESS_FIELD_NUMBER
8
public static final int
IS_ROW_TIME_FIELD_NUMBER
6
public static final int
IS_TIME_WINDOW_FIELD_NUMBER
2
public static final int
NAMEDPROPERTIES_FIELD_NUMBER
9
public static final int
SHIFT_TIMEZONE_FIELD_NUMBER
10
public static final int
TIME_FIELD_INDEX_FIELD_NUMBER
7
public static final int
WINDOW_GAP_FIELD_NUMBER
5
public static final int
WINDOW_SIZE_FIELD_NUMBER
4
public static final int
WINDOW_SLIDE_FIELD_NUMBER
3
public static final int
WINDOW_TYPE_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.WindowProperty Modifier and Type Constant Field Value public static final int
PROC_TIME_ATTRIBUTE_VALUE
3
public static final int
ROW_TIME_ATTRIBUTE_VALUE
2
public static final int
WINDOW_END_VALUE
1
public static final int
WINDOW_START_VALUE
0
-
org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.WindowType Modifier and Type Constant Field Value public static final int
SESSION_GROUP_WINDOW_VALUE
2
public static final int
SLIDING_GROUP_WINDOW_VALUE
1
public static final int
TUMBLING_GROUP_WINDOW_VALUE
0
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Input 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
-
org.apache.flink.fnexecution.v1.FlinkFnApi.JobParameter Modifier and Type Constant Field Value public static final int
KEY_FIELD_NUMBER
1
public static final int
VALUE_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.OverWindow 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
-
org.apache.flink.fnexecution.v1.FlinkFnApi.OverWindow.WindowType 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
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema Modifier and Type Constant Field Value public static final int
FIELDS_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.BinaryInfo Modifier and Type Constant Field Value public static final int
LENGTH_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.CharInfo Modifier and Type Constant Field Value public static final int
LENGTH_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.DecimalInfo Modifier and Type Constant Field Value public static final int
PRECISION_FIELD_NUMBER
1
public static final int
SCALE_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.Field 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
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.FieldType 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
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.LocalZonedTimestampInfo Modifier and Type Constant Field Value public static final int
PRECISION_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.MapInfo Modifier and Type Constant Field Value public static final int
KEY_TYPE_FIELD_NUMBER
1
public static final int
VALUE_TYPE_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TimeInfo Modifier and Type Constant Field Value public static final int
PRECISION_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TimestampInfo Modifier and Type Constant Field Value public static final int
PRECISION_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TypeName Modifier and Type Constant Field Value public static final int
BASIC_ARRAY_VALUE
16
public static final int
BIGINT_VALUE
4
public static final int
BINARY_VALUE
12
public static final int
BOOLEAN_VALUE
11
public static final int
CHAR_VALUE
14
public static final int
DATE_VALUE
8
public static final int
DECIMAL_VALUE
5
public static final int
DOUBLE_VALUE
7
public static final int
FLOAT_VALUE
6
public static final int
INT_VALUE
3
public static final int
LOCAL_ZONED_TIMESTAMP_VALUE
19
public static final int
MAP_VALUE
17
public static final int
MULTISET_VALUE
18
public static final int
NULL_VALUE
21
public static final int
ROW_VALUE
0
public static final int
SMALLINT_VALUE
2
public static final int
TIME_VALUE
9
public static final int
TIMESTAMP_VALUE
10
public static final int
TINYINT_VALUE
1
public static final int
VARBINARY_VALUE
13
public static final int
VARCHAR_VALUE
15
public static final int
ZONED_TIMESTAMP_VALUE
20
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.VarBinaryInfo Modifier and Type Constant Field Value public static final int
LENGTH_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.VarCharInfo Modifier and Type Constant Field Value public static final int
LENGTH_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.ZonedTimestampInfo Modifier and Type Constant Field Value public static final int
PRECISION_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor Modifier and Type Constant Field Value public static final int
STATE_NAME_FIELD_NUMBER
1
public static final int
STATE_TTL_CONFIG_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig Modifier and Type Constant Field Value public static final int
CLEANUP_STRATEGIES_FIELD_NUMBER
5
public static final int
STATE_VISIBILITY_FIELD_NUMBER
2
public static final int
TTL_FIELD_NUMBER
4
public static final int
TTL_TIME_CHARACTERISTIC_FIELD_NUMBER
3
public static final int
UPDATE_TYPE_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies Modifier and Type Constant Field Value public static final int
IS_CLEANUP_IN_BACKGROUND_FIELD_NUMBER
1
public static final int
STRATEGIES_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.EmptyCleanupStrategy Modifier and Type Constant Field Value public static final int
EMPTY_STRATEGY_VALUE
0
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.IncrementalCleanupStrategy Modifier and Type Constant Field Value public static final int
CLEANUP_SIZE_FIELD_NUMBER
1
public static final int
RUN_CLEANUP_FOR_EVERY_RECORD_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry Modifier and Type Constant Field Value public static final int
EMPTY_STRATEGY_FIELD_NUMBER
2
public static final int
INCREMENTAL_CLEANUP_STRATEGY_FIELD_NUMBER
3
public static final int
ROCKSDB_COMPACT_FILTER_CLEANUP_STRATEGY_FIELD_NUMBER
4
public static final int
STRATEGY_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.RocksdbCompactFilterCleanupStrategy Modifier and Type Constant Field Value public static final int
QUERY_TIME_AFTER_NUM_ENTRIES_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Strategies Modifier and Type Constant Field Value public static final int
FULL_STATE_SCAN_SNAPSHOT_VALUE
0
public static final int
INCREMENTAL_CLEANUP_VALUE
1
public static final int
ROCKSDB_COMPACTION_FILTER_VALUE
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.StateVisibility Modifier and Type Constant Field Value public static final int
NeverReturnExpired_VALUE
1
public static final int
ReturnExpiredIfNotCleanedUp_VALUE
0
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.TtlTimeCharacteristic Modifier and Type Constant Field Value public static final int
ProcessingTime_VALUE
0
-
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.UpdateType Modifier and Type Constant Field Value public static final int
Disabled_VALUE
0
public static final int
OnCreateAndWrite_VALUE
1
public static final int
OnReadAndWrite_VALUE
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo Modifier and Type Constant Field Value public static final int
AVRO_TYPE_INFO_FIELD_NUMBER
6
public static final int
COLLECTION_ELEMENT_TYPE_FIELD_NUMBER
2
public static final int
MAP_TYPE_INFO_FIELD_NUMBER
5
public static final int
ROW_TYPE_INFO_FIELD_NUMBER
3
public static final int
TUPLE_TYPE_INFO_FIELD_NUMBER
4
public static final int
TYPE_NAME_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.AvroTypeInfo Modifier and Type Constant Field Value public static final int
SCHEMA_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.MapTypeInfo Modifier and Type Constant Field Value public static final int
KEY_TYPE_FIELD_NUMBER
1
public static final int
VALUE_TYPE_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo Modifier and Type Constant Field Value public static final int
FIELDS_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.RowTypeInfo.Field Modifier and Type Constant Field Value public static final int
FIELD_NAME_FIELD_NUMBER
1
public static final int
FIELD_TYPE_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TupleTypeInfo Modifier and Type Constant Field Value public static final int
FIELD_TYPES_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TypeName Modifier and Type Constant Field Value public static final int
AVRO_VALUE
23
public static final int
BASIC_ARRAY_VALUE
15
public static final int
BIG_DEC_VALUE
11
public static final int
BIG_INT_VALUE
10
public static final int
BOOLEAN_VALUE
3
public static final int
BYTE_VALUE
2
public static final int
CHAR_VALUE
9
public static final int
DOUBLE_VALUE
8
public static final int
FLOAT_VALUE
7
public static final int
INSTANT_VALUE
22
public static final int
INT_VALUE
5
public static final int
LIST_VALUE
18
public static final int
LOCAL_DATE_VALUE
24
public static final int
LOCAL_DATETIME_VALUE
26
public static final int
LOCAL_TIME_VALUE
25
public static final int
LOCAL_ZONED_TIMESTAMP_VALUE
27
public static final int
LONG_VALUE
6
public static final int
MAP_VALUE
19
public static final int
OBJECT_ARRAY_VALUE
21
public static final int
PICKLED_BYTES_VALUE
20
public static final int
PRIMITIVE_ARRAY_VALUE
16
public static final int
ROW_VALUE
0
public static final int
SHORT_VALUE
4
public static final int
SQL_DATE_VALUE
12
public static final int
SQL_TIME_VALUE
13
public static final int
SQL_TIMESTAMP_VALUE
14
public static final int
STRING_VALUE
1
public static final int
TUPLE_VALUE
17
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction Modifier and Type Constant Field Value public static final int
DISTINCT_FIELD_NUMBER
5
public static final int
FILTER_ARG_FIELD_NUMBER
4
public static final int
INPUTS_FIELD_NUMBER
2
public static final int
PAYLOAD_FIELD_NUMBER
1
public static final int
SPECS_FIELD_NUMBER
3
public static final int
TAKES_ROW_AS_INPUT_FIELD_NUMBER
6
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec 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
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView Modifier and Type Constant Field Value public static final int
ELEMENT_TYPE_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView Modifier and Type Constant Field Value public static final int
KEY_TYPE_FIELD_NUMBER
1
public static final int
VALUE_TYPE_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions Modifier and Type Constant Field Value public static final int
COUNT_STAR_INSERTED_FIELD_NUMBER
11
public static final int
GENERATE_UPDATE_BEFORE_FIELD_NUMBER
4
public static final int
GROUP_WINDOW_FIELD_NUMBER
12
public static final int
GROUPING_FIELD_NUMBER
3
public static final int
INDEX_OF_COUNT_STAR_FIELD_NUMBER
6
public static final int
JOB_PARAMETERS_FIELD_NUMBER
14
public static final int
KEY_TYPE_FIELD_NUMBER
5
public static final int
MAP_STATE_READ_CACHE_SIZE_FIELD_NUMBER
9
public static final int
MAP_STATE_WRITE_CACHE_SIZE_FIELD_NUMBER
10
public static final int
METRIC_ENABLED_FIELD_NUMBER
2
public static final int
PROFILE_ENABLED_FIELD_NUMBER
13
public static final int
STATE_CACHE_SIZE_FIELD_NUMBER
8
public static final int
STATE_CLEANING_ENABLED_FIELD_NUMBER
7
public static final int
UDFS_FIELD_NUMBER
1
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction Modifier and Type Constant Field Value public static final int
FUNCTION_TYPE_FIELD_NUMBER
1
public static final int
HAS_SIDE_OUTPUT_FIELD_NUMBER
7
public static final int
KEY_TYPE_INFO_FIELD_NUMBER
5
public static final int
MAP_STATE_READ_CACHE_SIZE_FIELD_NUMBER
9
public static final int
MAP_STATE_WRITE_CACHE_SIZE_FIELD_NUMBER
10
public static final int
METRIC_ENABLED_FIELD_NUMBER
4
public static final int
PAYLOAD_FIELD_NUMBER
3
public static final int
PROFILE_ENABLED_FIELD_NUMBER
6
public static final int
RUNTIME_CONTEXT_FIELD_NUMBER
2
public static final int
STATE_CACHE_SIZE_FIELD_NUMBER
8
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.FunctionType Modifier and Type Constant Field Value public static final int
CO_BROADCAST_PROCESS_VALUE
5
public static final int
CO_PROCESS_VALUE
1
public static final int
KEYED_CO_BROADCAST_PROCESS_VALUE
6
public static final int
KEYED_CO_PROCESS_VALUE
3
public static final int
KEYED_PROCESS_VALUE
2
public static final int
PROCESS_VALUE
0
public static final int
REVISE_OUTPUT_VALUE
100
public static final int
WINDOW_VALUE
4
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext Modifier and Type Constant Field Value public static final int
ATTEMPT_NUMBER_FIELD_NUMBER
6
public static final int
IN_BATCH_EXECUTION_MODE_FIELD_NUMBER
8
public static final int
INDEX_OF_THIS_SUBTASK_FIELD_NUMBER
5
public static final int
JOB_PARAMETERS_FIELD_NUMBER
7
public static final int
MAX_NUMBER_OF_PARALLEL_SUBTASKS_FIELD_NUMBER
4
public static final int
NUMBER_OF_PARALLEL_SUBTASKS_FIELD_NUMBER
3
public static final int
TASK_NAME_FIELD_NUMBER
1
public static final int
TASK_NAME_WITH_SUBTASKS_FIELD_NUMBER
2
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunction Modifier and Type Constant Field Value public static final int
INPUTS_FIELD_NUMBER
2
public static final int
IS_PANDAS_UDF_FIELD_NUMBER
5
public static final int
PAYLOAD_FIELD_NUMBER
1
public static final int
TAKES_ROW_AS_INPUT_FIELD_NUMBER
4
public static final int
WINDOW_INDEX_FIELD_NUMBER
3
-
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions Modifier and Type Constant Field Value public static final int
JOB_PARAMETERS_FIELD_NUMBER
5
public static final int
METRIC_ENABLED_FIELD_NUMBER
2
public static final int
PROFILE_ENABLED_FIELD_NUMBER
4
public static final int
UDFS_FIELD_NUMBER
1
public static final int
WINDOWS_FIELD_NUMBER
3
-
org.apache.flink.formats.avro.AvroFileFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"avro"
-
org.apache.flink.formats.avro.AvroFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"avro"
-
org.apache.flink.formats.avro.registry.confluent.RegistryAvroFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"avro-confluent"
-
org.apache.flink.formats.avro.registry.confluent.debezium.DebeziumAvroFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"debezium-avro-confluent"
-
org.apache.flink.formats.json.JsonFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"json"
-
org.apache.flink.formats.json.JsonFormatOptionsUtil 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"
-
org.apache.flink.formats.json.canal.CanalJsonFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"canal-json"
-
org.apache.flink.formats.json.debezium.DebeziumJsonFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"debezium-json"
-
org.apache.flink.formats.json.maxwell.MaxwellJsonFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"maxwell-json"
-
org.apache.flink.formats.json.ogg.OggJsonFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"ogg-json"
-
org.apache.flink.formats.parquet.ParquetFileFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"parquet"
-
org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader Modifier and Type Constant Field Value public static final int
JULIAN_EPOCH_OFFSET_DAYS
2440588
-
org.apache.flink.formats.protobuf.PbConstant Modifier and Type Constant Field Value public static final int
CODEGEN_SPLIT_THRESHOLD
4000
public static final String
GENERATED_DECODE_METHOD
"decode"
public static final String
GENERATED_ENCODE_METHOD
"encode"
public static final String
PB_MAP_KEY_NAME
"key"
public static final String
PB_MAP_VALUE_NAME
"value"
public static final String
PB_METHOD_GET_DESCRIPTOR
"getDescriptor"
public static final String
PB_METHOD_PARSE_FROM
"parseFrom"
public static final String
PB_OUTER_CLASS_SUFFIX
"OuterClass"
-
org.apache.flink.formats.protobuf.PbFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"protobuf"
-
org.apache.flink.formats.protobuf.serialize.PbRowDataSerializationSchema Modifier and Type Constant Field Value public static final long
serialVersionUID
1L
-
org.apache.flink.formats.raw.RawFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"raw"
-
org.apache.flink.formats.raw.RawFormatOptions Modifier and Type Constant Field Value public static final String
BIG_ENDIAN
"big-endian"
public static final String
LITTLE_ENDIAN
"little-endian"
-
org.apache.flink.formats.sequencefile.SequenceFileWriterFactory<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> Modifier and Type Constant Field Value public static final String
NO_COMPRESSION
"NO_COMPRESSION"
-
org.apache.flink.fs.azurefs.EnvironmentVariableKeyProvider Modifier and Type Constant Field Value public static final String
AZURE_STORAGE_KEY_ENV_VARIABLE
"AZURE_STORAGE_KEY"
-
org.apache.flink.fs.gs.GSFileSystemFactory Modifier and Type Constant Field Value public static final String
SCHEME
"gs"
-
org.apache.flink.fs.gs.utils.BlobUtils Modifier and Type Constant Field Value public static final int
COMPOSE_MAX_BLOBS
32
-
org.apache.flink.fs.osshadoop.FlinkOSSFileSystem Modifier and Type Constant Field Value public static final long
MULTIPART_UPLOAD_PART_SIZE_MIN
10485760L
-
org.apache.flink.fs.s3.common.FlinkS3FileSystem Modifier and Type Constant Field Value public static final long
S3_MULTIPART_MIN_PART_SIZE
5242880L
-
org.apache.flink.fs.s3.common.token.AbstractS3DelegationTokenReceiver Modifier and Type Constant Field Value public static final String
PROVIDER_CONFIG_NAME
"fs.s3a.aws.credentials.provider"
-
org.apache.flink.fs.s3.common.token.DynamicTemporaryAWSCredentialsProvider Modifier and Type Constant Field Value public static final String
COMPONENT
"Dynamic session credentials for Flink"
-
org.apache.flink.kubernetes.configuration.KubernetesConfigOptions Modifier and Type Constant Field Value public static final String
EXTERNAL_RESOURCE_KUBERNETES_CONFIG_KEY_SUFFIX
"kubernetes.config-key"
-
org.apache.flink.kubernetes.kubeclient.resources.KubernetesLeaderElector Modifier and Type Constant Field Value public static final String
LEADER_ANNOTATION_KEY
"control-plane.alpha.kubernetes.io/leader"
-
org.apache.flink.kubernetes.kubeclient.services.HeadlessClusterIPService Modifier and Type Constant Field Value public static final String
HEADLESS_CLUSTER_IP
"None"
-
org.apache.flink.kubernetes.utils.Constants Modifier and Type Constant Field Value public static final String
API_VERSION
"v1"
public static final String
APPS_API_VERSION
"apps/v1"
public static final int
BLOB_SERVER_PORT
6124
public static final String
BLOB_SERVER_PORT_NAME
"blobserver"
public static final String
CHECKPOINT_COUNTER_KEY
"counter"
public static final String
CHECKPOINT_ID_KEY_PREFIX
"checkpointID-"
public static final String
COMPLETED_CHECKPOINT_FILE_SUFFIX
"completedCheckpoint"
public static final String
CONFIG_FILE_LOG4J_NAME
"log4j-console.properties"
public static final String
CONFIG_FILE_LOGBACK_NAME
"logback-console.xml"
public static final String
CONFIG_MAP_PREFIX
"flink-config-"
public static final String
DNS_POLICY_DEFAULT
"ClusterFirst"
public static final String
DNS_POLICY_HOSTNETWORK
"ClusterFirstWithHostNet"
public static final String
ENV_FLINK_LOG_DIR
"FLINK_LOG_DIR"
public static final String
ENV_FLINK_POD_IP_ADDRESS
"_POD_IP_ADDRESS"
public static final String
ENV_FLINK_POD_NODE_ID
"_POD_NODE_ID"
public static final String
ENV_HADOOP_CONF_DIR
"HADOOP_CONF_DIR"
public static final String
ENV_HADOOP_HOME
"HADOOP_HOME"
public static final String
ENV_TM_JVM_MEM_OPTS
"FLINK_TM_JVM_MEM_OPTS"
public static final String
EXECUTION_PLAN_STORE_KEY_PREFIX
"executionPlan-"
public static final String
FLINK_CONF_VOLUME
"flink-config-volume"
public static final String
FLINK_REST_SERVICE_SUFFIX
"-rest"
public static final String
HADOOP_CONF_CONFIG_MAP_PREFIX
"hadoop-config-"
public static final String
HADOOP_CONF_DIR_IN_POD
"/opt/hadoop/conf"
public static final String
HADOOP_CONF_VOLUME
"hadoop-config-volume"
public static final String
JOB_MANAGER_RPC_PORT_NAME
"jobmanager-rpc"
public static final String
KERBEROS_KEYTAB_MOUNT_POINT
"/opt/kerberos/kerberos-keytab"
public static final String
KERBEROS_KEYTAB_SECRET_PREFIX
"kerberos-keytab-"
public static final String
KERBEROS_KEYTAB_VOLUME
"kerberos-keytab-volume"
public static final String
KERBEROS_KRB5CONF_CONFIG_MAP_PREFIX
"kerberos-krb5conf-"
public static final String
KERBEROS_KRB5CONF_FILE
"krb5.conf"
public static final String
KERBEROS_KRB5CONF_MOUNT_DIR
"/etc"
public static final String
KERBEROS_KRB5CONF_VOLUME
"kerberos-krb5conf-volume"
public static final String
KUBERNETES_JOB_MANAGER_SCRIPT_PATH
"kubernetes-jobmanager.sh"
public static final String
KUBERNETES_TASK_MANAGER_SCRIPT_PATH
"kubernetes-taskmanager.sh"
public static final String
KUBERNETES_ZERO_RESOURCE_VERSION
"0"
public static final String
LABEL_APP_KEY
"app"
public static final String
LABEL_COMPONENT_JOB_MANAGER
"jobmanager"
public static final String
LABEL_COMPONENT_KEY
"component"
public static final String
LABEL_COMPONENT_TASK_MANAGER
"taskmanager"
public static final String
LABEL_TYPE_KEY
"type"
public static final String
LABEL_TYPE_NATIVE_TYPE
"flink-native-kubernetes"
public static final String
LEADER_ADDRESS_KEY
"address"
public static final String
LEADER_SESSION_ID_KEY
"sessionId"
public static final String
MAIN_CONTAINER_NAME
"flink-main-container"
public static final int
MAXIMUM_CHARACTERS_OF_CLUSTER_ID
45
public static final String
NAME_SEPARATOR
"-"
public static final String
POD_IP_FIELD_PATH
"status.podIP"
public static final String
POD_NODE_ID_FIELD_PATH
"spec.nodeName"
public static final String
POD_TEMPLATE_CONFIG_MAP_PREFIX
"pod-template-"
public static final String
POD_TEMPLATE_DIR_IN_POD
"/opt/flink/pod-template"
public static final String
POD_TEMPLATE_VOLUME
"pod-template-volume"
public static final String
RESOURCE_NAME_CPU
"cpu"
public static final String
RESOURCE_NAME_MEMORY
"memory"
public static final String
RESOURCE_UNIT_MB
"Mi"
public static final int
REST_PORT
8081
public static final String
REST_PORT_NAME
"rest"
public static final String
RESTART_POLICY_OF_NEVER
"Never"
public static final String
SUBMITTED_EXECUTION_PLAN_FILE_PREFIX
"submittedExecutionPlan"
public static final String
TASK_MANAGER_POD_TEMPLATE_FILE_NAME
"taskmanager-pod-template.yaml"
public static final int
TASK_MANAGER_RPC_PORT
6122
public static final String
TASK_MANAGER_RPC_PORT_NAME
"taskmanager-rpc"
public static final String
USER_ARTIFACTS_VOLUME
"user-artifacts-volume"
-
org.apache.flink.metrics.View Modifier and Type Constant Field Value public static final int
UPDATE_INTERVAL_SECONDS
5
-
org.apache.flink.metrics.graphite.GraphiteReporter Modifier and Type Constant Field Value public static final String
ARG_PROTOCOL
"protocol"
-
org.apache.flink.metrics.statsd.StatsDReporter Modifier and Type Constant Field Value public static final String
ARG_HOST
"host"
public static final String
ARG_PORT
"port"
-
org.apache.flink.metrics.testutils.MetricListener Modifier and Type Constant Field Value public static final String
DELIMITER
"."
public static final String
ROOT_METRIC_GROUP_NAME
"rootMetricGroup"
-
org.apache.flink.orc.OrcFileFormatFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"orc"
-
org.apache.flink.python.Constants Modifier and Type Constant Field Value public static final String
FLINK_CODER_URN
"flink:coder:v1"
public static final String
INPUT_COLLECTION_ID
"input"
public static final String
MAIN_INPUT_NAME
"input"
public static final String
MAIN_OUTPUT_NAME
""
public static final String
OUTPUT_COLLECTION_ID
""
public static final String
SIDE_OUTPUT_CODER_PREFIX
"side_coder-"
public static final String
STATEFUL_FUNCTION_URN
"flink:transform:ds:stateful_function:v1"
public static final String
STATELESS_FUNCTION_URN
"flink:transform:ds:stateless_function:v1"
public static final String
TIMER_CODER_ID
"timer_coder"
public static final String
TIMER_ID
"timer"
public static final String
TRANSFORM_ID
"transform"
public static final String
WINDOW_CODER_ID
"window_coder"
public static final String
WINDOW_STRATEGY
"windowing_strategy"
public static final String
WRAPPER_TIMER_CODER_ID
"timer_coder_wrapper"
-
org.apache.flink.python.env.AbstractPythonEnvironmentManager Modifier and Type Constant Field Value public static final String
PYFLINK_GATEWAY_DISABLED
"PYFLINK_GATEWAY_DISABLED"
public static final String
PYTHON_ARCHIVES_DIR
"python-archives"
public static final String
PYTHON_FILES_DIR
"python-files"
public static final String
PYTHON_REQUIREMENTS_CACHE
"_PYTHON_REQUIREMENTS_CACHE"
public static final String
PYTHON_REQUIREMENTS_DIR
"python-requirements"
public static final String
PYTHON_REQUIREMENTS_FILE
"_PYTHON_REQUIREMENTS_FILE"
public static final String
PYTHON_REQUIREMENTS_INSTALL_DIR
"_PYTHON_REQUIREMENTS_INSTALL_DIR"
public static final String
PYTHON_WORKING_DIR
"_PYTHON_WORKING_DIR"
-
org.apache.flink.python.util.PythonConfigUtil 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"
-
org.apache.flink.python.util.PythonDependencyUtils 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
"#"
-
org.apache.flink.python.util.PythonEnvironmentManagerUtils Modifier and Type Constant Field Value public static final String
PYFLINK_UDF_RUNNER_DIR
"PYFLINK_UDF_RUNNER_DIR"
-
org.apache.flink.runtime.blob.BlobKey Modifier and Type Constant Field Value public static final int
SIZE
20
-
org.apache.flink.runtime.blob.FileSystemBlobStore Modifier and Type Constant Field Value public static final String
BLOB_PATH_NAME
"blob"
-
org.apache.flink.runtime.checkpoint.CheckpointFailureManager 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
-
org.apache.flink.runtime.checkpoint.CheckpointIDCounter Modifier and Type Constant Field Value public static final int
INITIAL_CHECKPOINT_ID
1
-
org.apache.flink.runtime.checkpoint.CheckpointMetrics Modifier and Type Constant Field Value public static final long
UNSET
-1L
-
org.apache.flink.runtime.checkpoint.CheckpointOptions Modifier and Type Constant Field Value public static final long
NO_ALIGNED_CHECKPOINT_TIME_OUT
9223372036854775807L
-
org.apache.flink.runtime.checkpoint.Checkpoints Modifier and Type Constant Field Value public static final int
HEADER_MAGIC_NUMBER
1231054637
-
org.apache.flink.runtime.checkpoint.CheckpointStoreUtil Modifier and Type Constant Field Value public static final long
INVALID_CHECKPOINT_ID
-1L
-
org.apache.flink.runtime.checkpoint.SubTaskInitializationMetrics Modifier and Type Constant Field Value public static final long
UNSET
-1L
-
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter Modifier and Type Constant Field Value public static final int
SEQUENCE_NUMBER_RESTORED
-1
public static final int
SEQUENCE_NUMBER_UNKNOWN
-2
-
org.apache.flink.runtime.checkpoint.filemerging.FileMergingMetricGroup Modifier and Type Constant Field Value public static final String
LOGICAL_FILE_COUNT
"fileMerging.logicalFileCount"
public static final String
LOGICAL_FILE_SIZE
"fileMerging.logicalFileSize"
public static final String
PHYSICAL_FILE_COUNT
"fileMerging.physicalFileCount"
public static final String
PHYSICAL_FILE_SIZE
"fileMerging.physicalFileSize"
-
org.apache.flink.runtime.checkpoint.metadata.MetadataV1Serializer Modifier and Type Constant Field Value public static final int
VERSION
1
-
org.apache.flink.runtime.checkpoint.metadata.MetadataV2Serializer Modifier and Type Constant Field Value public static final int
VERSION
2
-
org.apache.flink.runtime.checkpoint.metadata.MetadataV3Serializer Modifier and Type Constant Field Value public static final int
VERSION
3
-
org.apache.flink.runtime.checkpoint.metadata.MetadataV4Serializer Modifier and Type Constant Field Value public static final int
VERSION
4
-
org.apache.flink.runtime.checkpoint.metadata.MetadataV5Serializer Modifier and Type Constant Field Value public static final int
VERSION
5
-
org.apache.flink.runtime.dispatcher.Dispatcher Modifier and Type Constant Field Value public static final String
DISPATCHER_NAME
"dispatcher"
-
org.apache.flink.runtime.entrypoint.ClusterEntrypoint Modifier and Type Constant Field Value protected static final int
RUNTIME_FAILURE_RETURN_CODE
2
protected static final int
STARTUP_FAILURE_RETURN_CODE
1
-
org.apache.flink.runtime.executiongraph.ExecutionVertex Modifier and Type Constant Field Value public static final long
NUM_BYTES_UNKNOWN
-1L
-
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler Modifier and Type Constant Field Value public static final String
FAILURE_LABEL_ATTRIBUTE_PREFIX
"failureLabel."
-
org.apache.flink.runtime.executiongraph.failover.FailoverStrategyFactoryLoader 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"
-
org.apache.flink.runtime.executiongraph.metrics.DownTimeGauge Modifier and Type Constant Field Value public static final String
METRIC_NAME
"downtime"
-
org.apache.flink.runtime.executiongraph.metrics.UpTimeGauge Modifier and Type Constant Field Value public static final String
METRIC_NAME
"uptime"
-
org.apache.flink.runtime.fs.hdfs.HadoopDataInputStream Modifier and Type Constant Field Value public static final int
MIN_SKIP_BYTES
1048576
-
org.apache.flink.runtime.instance.HardwareDescription 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"
-
org.apache.flink.runtime.io.compression.CompressorUtils Modifier and Type Constant Field Value public static final int
HEADER_LENGTH
8
-
org.apache.flink.runtime.io.disk.BatchShuffleReadBufferPool Modifier and Type Constant Field Value public static final int
NUM_BYTES_PER_REQUEST
4194304
-
org.apache.flink.runtime.io.disk.iomanager.ChannelWriterOutputView 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
-
org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer<T extends IOReadableWritable> Modifier and Type Constant Field Value public static final int
DEFAULT_FILE_BUFFER_SIZE
2097152
public static final int
DEFAULT_THRESHOLD_FOR_SPILLING
5242880
-
org.apache.flink.runtime.io.network.api.writer.RecordWriter<T extends IOReadableWritable> Modifier and Type Constant Field Value public static final String
DEFAULT_OUTPUT_FLUSH_THREAD_NAME
"OutputFlusher"
-
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool Modifier and Type Constant Field Value public static final int
UNBOUNDED_POOL_SIZE
2147483647
-
org.apache.flink.runtime.io.network.metrics.NettyShuffleMetricFactory Modifier and Type Constant Field Value public static final String
METRIC_GROUP_INPUT
"Input"
public static final String
METRIC_GROUP_OUTPUT
"Output"
-
org.apache.flink.runtime.io.network.partition.BufferReaderWriterUtil Modifier and Type Constant Field Value public static final int
HEADER_LENGTH
8
-
org.apache.flink.runtime.io.network.partition.PageSizeUtil 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
-
org.apache.flink.runtime.io.network.partition.PartitionedFile Modifier and Type Constant Field Value public static final String
DATA_FILE_SUFFIX
".shuffle.data"
public static final int
INDEX_ENTRY_SIZE
16
public static final String
INDEX_FILE_SUFFIX
".shuffle.index"
-
org.apache.flink.runtime.io.network.partition.ResultSubpartition Modifier and Type Constant Field Value public static final int
ADD_BUFFER_ERROR_CODE
-1
-
org.apache.flink.runtime.io.network.partition.SortBuffer Modifier and Type Constant Field Value protected static final int
INDEX_ENTRY_SIZE
16
-
org.apache.flink.runtime.io.network.partition.consumer.InputGateSpecUtils Modifier and Type Constant Field Value public static final int
DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_BATCH
1000
public static final int
DEFAULT_MAX_REQUIRED_BUFFERS_PER_GATE_FOR_STREAM
2147483647
-
org.apache.flink.runtime.io.network.partition.hybrid.tiered.file.ProducerMergedPartitionFile Modifier and Type Constant Field Value public static final String
DATA_FILE_SUFFIX
".tier-storage.data"
public static final String
INDEX_FILE_SUFFIX
".tier-storage.index"
-
org.apache.flink.runtime.io.network.partition.hybrid.tiered.file.ProducerMergedPartitionFileIndex.FixedSizeRegion Modifier and Type Constant Field Value public static final int
REGION_SIZE
24
-
org.apache.flink.runtime.iterative.convergence.WorksetEmptyConvergenceCriterion Modifier and Type Constant Field Value public static final String
AGGREGATOR_NAME
"pact.runtime.workset-empty-aggregator"
-
org.apache.flink.runtime.jobgraph.JobVertex Modifier and Type Constant Field Value public static final int
MAX_PARALLELISM_DEFAULT
-1
-
org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration Modifier and Type Constant Field Value public static final long
DISABLED_CHECKPOINT_INTERVAL
9223372036854775807L
public static final long
MINIMAL_CHECKPOINT_TIME
10L
-
org.apache.flink.runtime.jobmaster.JobMaster Modifier and Type Constant Field Value public static final String
JOB_MANAGER_NAME
"jobmanager"
-
org.apache.flink.runtime.memory.MemoryManager Modifier and Type Constant Field Value public static final int
DEFAULT_PAGE_SIZE
32768
public static final int
MIN_PAGE_SIZE
4096
-
org.apache.flink.runtime.messages.webmonitor.ClusterOverview Modifier and Type Constant Field Value public static final String
FIELD_NAME_SLOTS_AVAILABLE
"slots-available"
public static final String
FIELD_NAME_SLOTS_FREE_AND_BLOCKED
"slots-free-and-blocked"
public static final String
FIELD_NAME_SLOTS_TOTAL
"slots-total"
public static final String
FIELD_NAME_TASKMANAGERS
"taskmanagers"
public static final String
FIELD_NAME_TASKMANAGERS_BLOCKED
"taskmanagers-blocked"
-
org.apache.flink.runtime.messages.webmonitor.JobIdsWithStatusOverview Modifier and Type Constant Field Value public static final String
FIELD_NAME_JOBS
"jobs"
-
org.apache.flink.runtime.messages.webmonitor.JobIdsWithStatusOverview.JobIdWithStatus Modifier and Type Constant Field Value public static final String
FIELD_NAME_JOB_ID
"id"
public static final String
FIELD_NAME_JOB_STATUS
"status"
-
org.apache.flink.runtime.messages.webmonitor.JobsOverview 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"
-
org.apache.flink.runtime.messages.webmonitor.JobStatusInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_STATUS
"status"
-
org.apache.flink.runtime.messages.webmonitor.MultipleJobsDetails Modifier and Type Constant Field Value public static final String
FIELD_NAME_JOBS
"jobs"
-
org.apache.flink.runtime.metrics.MetricNames Modifier and Type Constant Field Value public static final String
ACC_TASK_BACK_PRESSURED_TIME
"accumulateBackPressuredTimeMs"
public static final String
ACC_TASK_BUSY_TIME
"accumulateBusyTimeMs"
public static final String
ACC_TASK_IDLE_TIME
"accumulateIdleTimeMs"
public static final String
ALREADY_COMMITTED_COMMITTABLES
"alreadyCommittedCommittables"
public static final String
CHANGELOG_BUSY_TIME
"changelogBusyTimeMsPerSecond"
public static final String
CHECKPOINT_ALIGNMENT_TIME
"checkpointAlignmentTime"
public static final String
CHECKPOINT_START_DELAY_TIME
"checkpointStartDelayNanos"
public static final String
CURRENT_EMIT_EVENT_TIME_LAG
"currentEmitEventTimeLag"
public static final String
CURRENT_FETCH_EVENT_TIME_LAG
"currentFetchEventTimeLag"
public static final String
CURRENT_SEND_TIME
"currentSendTime"
public static final String
DEBLOATED_BUFFER_SIZE
"debloatedBufferSize"
public static final String
DOWNLOAD_STATE_DURATION
"DownloadStateDurationMs"
public static final String
ESTIMATED_TIME_TO_CONSUME_BUFFERS
"estimatedTimeToConsumeBuffersMs"
public static final String
FAILED_COMMITTABLES
"failedCommittables"
public static final String
GATE_RESTORE_DURATION
"GateRestoreDurationMs"
public static final String
HIT_COUNT
"hitCount"
public static final String
INITIALIZATION_TIME
"initializationTime"
public static final String
INITIALIZE_STATE_DURATION
"InitializeStateDurationMs"
public static final String
IO_CURRENT_INPUT_WATERMARK
"currentInputWatermark"
public static final String
IO_CURRENT_INPUT_WATERMARK_PATERN
"currentInput%dWatermark"
public static final String
IO_CURRENT_OUTPUT_WATERMARK
"currentOutputWatermark"
public static final String
IO_NUM_BUFFERS_IN
"numBuffersIn"
public static final String
IO_NUM_BUFFERS_OUT
"numBuffersOut"
public static final String
IO_NUM_BUFFERS_OUT_RATE
"numBuffersOutPerSecond"
public static final String
IO_NUM_BYTES_IN
"numBytesIn"
public static final String
IO_NUM_BYTES_IN_RATE
"numBytesInPerSecond"
public static final String
IO_NUM_BYTES_OUT
"numBytesOut"
public static final String
IO_NUM_BYTES_OUT_RATE
"numBytesOutPerSecond"
public static final String
IO_NUM_RECORDS_IN
"numRecordsIn"
public static final String
IO_NUM_RECORDS_IN_RATE
"numRecordsInPerSecond"
public static final String
IO_NUM_RECORDS_OUT
"numRecordsOut"
public static final String
IO_NUM_RECORDS_OUT_RATE
"numRecordsOutPerSecond"
public static final String
IS_BACK_PRESSURED
"isBackPressured"
public static final String
LATEST_LOAD_TIME
"latestLoadTime"
public static final String
LOAD_COUNT
"loadCount"
public static final String
MAILBOX_LATENCY
"mailboxLatencyMs"
public static final String
MAILBOX_SIZE
"mailboxQueueSize"
public static final String
MAILBOX_START_DURATION
"MailboxStartDurationMs"
public static final String
MAILBOX_THROUGHPUT
"mailboxMailsPerSecond"
public static final String
MEMORY_COMMITTED
"Committed"
public static final String
MEMORY_MAX
"Max"
public static final String
MEMORY_USED
"Used"
public static final String
MISS_COUNT
"missCount"
public static final String
NUM_BYTES_SEND
"numBytesSend"
public static final String
NUM_CACHED_BYTES
"numCachedBytes"
public static final String
NUM_CACHED_RECORDS
"numCachedRecords"
public static final String
NUM_EFFECTIVE_SPECULATIVE_EXECUTIONS
"numEffectiveSpeculativeExecutions"
public static final String
NUM_FIRED_TIMERS
"numFiredTimers"
public static final String
NUM_FIRED_TIMERS_RATE
"numFiredTimersPerSecond"
public static final String
NUM_LOAD_FAILURES
"numLoadFailures"
public static final String
NUM_PENDING_TASK_MANAGERS
"numPendingTaskManagers"
public static final String
NUM_RECORDS_IN_ERRORS
"numRecordsInErrors"
public static final String
NUM_RECORDS_OUT_ERRORS
"numRecordsOutErrors"
public static final String
NUM_RECORDS_SEND
"numRecordsSend"
public static final String
NUM_RECORDS_SEND_ERRORS
"numRecordsSendErrors"
public static final String
NUM_REGISTERED_TASK_MANAGERS
"numRegisteredTaskManagers"
public static final String
NUM_RESTARTS
"numRestarts"
public static final String
NUM_RUNNING_JOBS
"numRunningJobs"
public static final String
NUM_SLOW_EXECUTION_VERTICES
"numSlowExecutionVertices"
public static final String
PENDING_BYTES
"pendingBytes"
public static final String
PENDING_COMMITTABLES
"pendingCommittables"
public static final String
PENDING_RECORDS
"pendingRecords"
public static final String
READ_OUTPUT_DATA_DURATION
"ReadOutputDataDurationMs"
public static final String
RESTORE_ASYNC_COMPACTION_DURATION
"RestoreAsyncCompactionDurationMs"
public static final String
RESTORE_STATE_DURATION
"RestoreStateDurationMs"
public static final String
RESTORED_STATE_SIZE
"RestoredStateSizeBytes"
public static final String
RETRIED_COMMITTABLES
"retriedCommittables"
public static final String
SOURCE_IDLE_TIME
"sourceIdleTime"
public static final String
START_WORKER_FAILURE_RATE
"startWorkFailurePerSecond"
public static final String
SUCCESSFUL_COMMITTABLES
"successfulCommittables"
public static final String
SUFFIX_RATE
"PerSecond"
public static final String
TASK_BACK_PRESSURED_TIME
"backPressuredTimeMsPerSecond"
public static final String
TASK_BUSY_TIME
"busyTimeMsPerSecond"
public static final String
TASK_HARD_BACK_PRESSURED_TIME
"hardBackPressuredTimeMsPerSecond"
public static final String
TASK_IDLE_TIME
"idleTimeMsPerSecond"
public static final String
TASK_MAX_HARD_BACK_PRESSURED_TIME
"maxHardBackPressureTimeMs"
public static final String
TASK_MAX_SOFT_BACK_PRESSURED_TIME
"maxSoftBackPressureTimeMs"
public static final String
TASK_SLOTS_AVAILABLE
"taskSlotsAvailable"
public static final String
TASK_SLOTS_TOTAL
"taskSlotsTotal"
public static final String
TASK_SOFT_BACK_PRESSURED_TIME
"softBackPressuredTimeMsPerSecond"
public static final String
TOTAL_COMMITTABLES
"totalCommittables"
public static final String
UNASSIGNED_SPLITS
"unassignedSplits"
public static final String
WATERMARK_ALIGNMENT_DRIFT
"watermarkAlignmentDrift"
public static final String
WATERMARK_LAG
"watermarkLag"
-
org.apache.flink.runtime.metrics.dump.MetricDump 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
-
org.apache.flink.runtime.metrics.dump.MetricQueryService Modifier and Type Constant Field Value public static final String
METRIC_QUERY_SERVICE_NAME
"MetricQueryService"
-
org.apache.flink.runtime.metrics.dump.QueryScopeInfo Modifier and Type Constant Field Value public static final byte
INFO_CATEGORY_JM
0
public static final byte
INFO_CATEGORY_JM_OPERATOR
5
public static final byte
INFO_CATEGORY_JOB
2
public static final byte
INFO_CATEGORY_OPERATOR
4
public static final byte
INFO_CATEGORY_TASK
3
public static final byte
INFO_CATEGORY_TM
1
-
org.apache.flink.runtime.metrics.groups.InternalCacheMetricGroup Modifier and Type Constant Field Value public static final long
UNINITIALIZED
-1L
-
org.apache.flink.runtime.metrics.groups.InternalSourceReaderMetricGroup Modifier and Type Constant Field Value public static final long
UNDEFINED
-1L
-
org.apache.flink.runtime.metrics.scope.ScopeFormat Modifier and Type Constant Field Value public static final String
SCOPE_INHERIT_PARENT
"*"
public static final String
SCOPE_SEPARATOR
"."
-
org.apache.flink.runtime.operators.coordination.OperatorCoordinator Modifier and Type Constant Field Value public static final long
BATCH_CHECKPOINT_ID
-1L
public static final long
NO_CHECKPOINT
-1L
-
org.apache.flink.runtime.resourcemanager.ResourceManager<WorkerType extends ResourceIDRetrievable> Modifier and Type Constant Field Value public static final String
RESOURCE_MANAGER_NAME
"resourcemanager"
-
org.apache.flink.runtime.rest.FileUploadHandler Modifier and Type Constant Field Value public static final String
HTTP_ATTRIBUTE_REQUEST
"request"
-
org.apache.flink.runtime.rest.RestClient Modifier and Type Constant Field Value public static final String
VERSION_PLACEHOLDER
"{{VERSION}}"
-
org.apache.flink.runtime.rest.handler.async.AsynchronousOperationResult<V> Modifier and Type Constant Field Value public static final String
FIELD_NAME_OPERATION
"operation"
-
org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler<T extends RestfulGateway> Modifier and Type Constant Field Value public static final String
HTTP_DATE_FORMAT
"EEE, dd MMM yyyy HH:mm:ss zzz"
-
org.apache.flink.runtime.rest.handler.legacy.messages.ClusterOverviewWithVersion Modifier and Type Constant Field Value public static final String
FIELD_NAME_COMMIT
"flink-commit"
public static final String
FIELD_NAME_VERSION
"flink-version"
-
org.apache.flink.runtime.rest.messages.AggregatedTaskDetailsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_METRICS
"metrics"
public static final String
FIELD_NAME_STATUS_DURATION
"status-duration"
-
org.apache.flink.runtime.rest.messages.ClusterConfigurationInfoHeaders Modifier and Type Constant Field Value public static final String
CLUSTER_CONFIG_REST_PATH
"/jobmanager/config"
-
org.apache.flink.runtime.rest.messages.ClusterOverviewHeaders Modifier and Type Constant Field Value public static final String
URL
"/overview"
-
org.apache.flink.runtime.rest.messages.ConfigurationInfoEntry Modifier and Type Constant Field Value public static final String
FIELD_NAME_CONFIG_KEY
"key"
public static final String
FIELD_NAME_CONFIG_VALUE
"value"
-
org.apache.flink.runtime.rest.messages.DashboardConfiguration Modifier and Type Constant Field Value public static final String
FIELD_NAME_FEATURE_WEB_CANCEL
"web-cancel"
public static final String
FIELD_NAME_FEATURE_WEB_HISTORY
"web-history"
public static final String
FIELD_NAME_FEATURE_WEB_RESCALE
"web-rescale"
public static final String
FIELD_NAME_FEATURE_WEB_SUBMIT
"web-submit"
public static final String
FIELD_NAME_FLINK_FEATURES
"features"
public static final String
FIELD_NAME_FLINK_REVISION
"flink-revision"
public static final String
FIELD_NAME_FLINK_VERSION
"flink-version"
public static final String
FIELD_NAME_REFRESH_INTERVAL
"refresh-interval"
public static final String
FIELD_NAME_TIMEZONE_NAME
"timezone-name"
public static final String
FIELD_NAME_TIMEZONE_OFFSET
"timezone-offset"
-
org.apache.flink.runtime.rest.messages.FlameGraphTypeQueryParameter Modifier and Type Constant Field Value public static final String
KEY
"type"
-
org.apache.flink.runtime.rest.messages.JobAccumulatorsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/accumulators"
-
org.apache.flink.runtime.rest.messages.JobAccumulatorsInfo 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"
-
org.apache.flink.runtime.rest.messages.JobAccumulatorsInfo.UserTaskAccumulator 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"
-
org.apache.flink.runtime.rest.messages.JobCancellationHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid"
-
org.apache.flink.runtime.rest.messages.JobClientHeartbeatHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/clientHeartbeat"
-
org.apache.flink.runtime.rest.messages.JobConfigHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/config"
-
org.apache.flink.runtime.rest.messages.JobConfigInfo 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"
-
org.apache.flink.runtime.rest.messages.JobConfigInfo.ExecutionConfigInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_GLOBAL_JOB_PARAMETERS
"user-config"
public static final String
FIELD_NAME_OBJECT_REUSE_MODE
"object-reuse-mode"
public static final String
FIELD_NAME_PARALLELISM
"job-parallelism"
public static final String
FIELD_NAME_RESTART_STRATEGY
"restart-strategy"
-
org.apache.flink.runtime.rest.messages.JobExceptionsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/exceptions"
-
org.apache.flink.runtime.rest.messages.JobExceptionsInfoWithHistory Modifier and Type Constant Field Value public static final String
FIELD_NAME_EXCEPTION_HISTORY
"exceptionHistory"
-
org.apache.flink.runtime.rest.messages.JobExceptionsInfoWithHistory.ExceptionInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_ENDPOINT
"endpoint"
public static final String
FIELD_NAME_EXCEPTION_NAME
"exceptionName"
public static final String
FIELD_NAME_EXCEPTION_STACKTRACE
"stacktrace"
public static final String
FIELD_NAME_EXCEPTION_TIMESTAMP
"timestamp"
public static final String
FIELD_NAME_FAILURE_LABELS
"failureLabels"
public static final String
FIELD_NAME_TASK_MANAGER_ID
"taskManagerId"
public static final String
FIELD_NAME_TASK_NAME
"taskName"
-
org.apache.flink.runtime.rest.messages.JobExceptionsInfoWithHistory.JobExceptionHistory Modifier and Type Constant Field Value public static final String
FIELD_NAME_ENTRIES
"entries"
public static final String
FIELD_NAME_TRUNCATED
"truncated"
-
org.apache.flink.runtime.rest.messages.JobExceptionsInfoWithHistory.RootExceptionInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_CONCURRENT_EXCEPTIONS
"concurrentExceptions"
-
org.apache.flink.runtime.rest.messages.JobIDPathParameter Modifier and Type Constant Field Value public static final String
KEY
"jobid"
-
org.apache.flink.runtime.rest.messages.JobIdsWithStatusesOverviewHeaders Modifier and Type Constant Field Value public static final String
CURRENT_JOB_IDS_REST_PATH
"/jobs"
-
org.apache.flink.runtime.rest.messages.JobManagerEnvironmentHeaders Modifier and Type Constant Field Value public static final String
JOB_MANAGER_ENV_REST_PATH
"/jobmanager/environment"
-
org.apache.flink.runtime.rest.messages.JobPlanHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/plan"
-
org.apache.flink.runtime.rest.messages.JobsOverviewHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/overview"
-
org.apache.flink.runtime.rest.messages.JobVertexAccumulatorsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/vertices/:vertexid/accumulators"
-
org.apache.flink.runtime.rest.messages.JobVertexAccumulatorsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_ID
"id"
public static final String
FIELD_NAME_USER_ACCUMULATORS
"user-accumulators"
-
org.apache.flink.runtime.rest.messages.JobVertexBackPressureInfo Modifier and Type Constant Field Value public static final String
DEPRECATED_FIELD_NAME_BACKPRESSURE_LEVEL
"backpressure-level"
public static final String
FIELD_NAME_BACKPRESSURE_LEVEL
"backpressureLevel"
public static final String
FIELD_NAME_END_TIMESTAMP
"end-timestamp"
public static final String
FIELD_NAME_STATUS
"status"
public static final String
FIELD_NAME_SUBTASKS
"subtasks"
-
org.apache.flink.runtime.rest.messages.JobVertexBackPressureInfo.SubtaskBackPressureInfo Modifier and Type Constant Field Value public static final String
DEPRECATED_FIELD_NAME_BACKPRESSURE_LEVEL
"backpressure-level"
public static final String
FIELD_NAME_ATTEMPT_NUMBER
"attempt-number"
public static final String
FIELD_NAME_BACK_PRESSURED_RATIO
"ratio"
public static final String
FIELD_NAME_BACKPRESSURE_LEVEL
"backpressureLevel"
public static final String
FIELD_NAME_BUSY_RATIO
"busyRatio"
public static final String
FIELD_NAME_IDLE_RATIO
"idleRatio"
public static final String
FIELD_NAME_OTHER_CONCURRENT_ATTEMPTS
"other-concurrent-attempts"
public static final String
FIELD_NAME_SUBTASK
"subtask"
-
org.apache.flink.runtime.rest.messages.JobVertexDetailsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/vertices/:vertexid"
-
org.apache.flink.runtime.rest.messages.JobVertexDetailsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_AGGREGATED
"aggregated"
public static final String
FIELD_NAME_MAX_PARALLELISM
"maxParallelism"
public static final String
FIELD_NAME_NOW
"now"
public static final String
FIELD_NAME_PARALLELISM
"parallelism"
public static final String
FIELD_NAME_SUBTASKS
"subtasks"
public static final String
FIELD_NAME_VERTEX_ID
"id"
public static final String
FIELD_NAME_VERTEX_NAME
"name"
-
org.apache.flink.runtime.rest.messages.JobVertexIdPathParameter Modifier and Type Constant Field Value public static final String
KEY
"vertexid"
-
org.apache.flink.runtime.rest.messages.JobVertexTaskManagersHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/vertices/:vertexid/taskmanagers"
-
org.apache.flink.runtime.rest.messages.JobVertexTaskManagersInfo 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"
-
org.apache.flink.runtime.rest.messages.JobVertexTaskManagersInfo.TaskManagersInfo Modifier and Type Constant Field Value public static final String
TASK_MANAGERS_FIELD_AGGREGATED
"aggregated"
public static final String
TASK_MANAGERS_FIELD_DURATION
"duration"
public static final String
TASK_MANAGERS_FIELD_END_TIME
"end-time"
public static final String
TASK_MANAGERS_FIELD_ENDPOINT
"endpoint"
public static final String
TASK_MANAGERS_FIELD_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"
-
org.apache.flink.runtime.rest.messages.LogFileNamePathParameter Modifier and Type Constant Field Value public static final String
KEY
"filename"
-
org.apache.flink.runtime.rest.messages.LogInfo Modifier and Type Constant Field Value public static final String
MTIME
"mtime"
public static final String
NAME
"name"
public static final String
SIZE
"size"
-
org.apache.flink.runtime.rest.messages.LogListInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_LOGS
"logs"
-
org.apache.flink.runtime.rest.messages.LogUrlResponse Modifier and Type Constant Field Value public static final String
FIELD_NAME_LOG_URL
"url"
-
org.apache.flink.runtime.rest.messages.OperatorUidPathParameter Modifier and Type Constant Field Value public static final String
KEY
"operatorUid"
-
org.apache.flink.runtime.rest.messages.ProfilingFileNamePathParameter Modifier and Type Constant Field Value public static final String
KEY
"filename"
-
org.apache.flink.runtime.rest.messages.ProfilingInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_DURATION
"duration"
public static final String
FIELD_NAME_FINISHED_TIME
"finishedTime"
public static final String
FIELD_NAME_MESSAGE
"message"
public static final String
FIELD_NAME_MODE
"mode"
public static final String
FIELD_NAME_OUTPUT_FILE
"outputFile"
public static final String
FIELD_NAME_STATUS
"status"
public static final String
FIELD_NAME_TRIGGER_TIME
"triggerTime"
-
org.apache.flink.runtime.rest.messages.ProfilingInfoList Modifier and Type Constant Field Value public static final String
FIELD_NAME_FLAME_GRAPHS
"profilingList"
-
org.apache.flink.runtime.rest.messages.RescalingParallelismQueryParameter Modifier and Type Constant Field Value public static final String
KEY
"parallelism"
-
org.apache.flink.runtime.rest.messages.ResourceProfileInfo 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"
-
org.apache.flink.runtime.rest.messages.SubtaskIndexPathParameter Modifier and Type Constant Field Value public static final String
KEY
"subtaskindex"
-
org.apache.flink.runtime.rest.messages.SubtaskIndexQueryParameter Modifier and Type Constant Field Value public static final String
KEY
"subtaskindex"
-
org.apache.flink.runtime.rest.messages.SubtasksAllAccumulatorsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/vertices/:vertexid/subtasks/accumulators"
-
org.apache.flink.runtime.rest.messages.SubtasksTimesHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/vertices/:vertexid/subtasktimes"
-
org.apache.flink.runtime.rest.messages.SubtasksTimesInfo 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"
-
org.apache.flink.runtime.rest.messages.SubtasksTimesInfo.SubtaskTimeInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_DURATION
"duration"
public static final String
FIELD_NAME_ENDPOINT
"endpoint"
public static final String
FIELD_NAME_SUBTASK
"subtask"
public static final String
FIELD_NAME_TIMESTAMPS
"timestamps"
-
org.apache.flink.runtime.rest.messages.ThreadDumpInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_THREAD_INFOS
"threadInfos"
-
org.apache.flink.runtime.rest.messages.ThreadDumpInfo.ThreadInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_THREAD_INFO
"stringifiedThreadInfo"
public static final String
FIELD_NAME_THREAD_NAME
"threadName"
-
org.apache.flink.runtime.rest.messages.TriggerIdPathParameter Modifier and Type Constant Field Value public static final String
KEY
"triggerid"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointConfigHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/checkpoints/config"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointConfigInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_ALIGNED_CHECKPOINT_TIMEOUT
"aligned_checkpoint_timeout"
public static final String
FIELD_NAME_CHANGELOG_STORAGE
"changelog_storage"
public static final String
FIELD_NAME_CHECKPOINT_INTERVAL
"interval"
public static final String
FIELD_NAME_CHECKPOINT_MAX_CONCURRENT
"max_concurrent"
public static final String
FIELD_NAME_CHECKPOINT_MIN_PAUSE
"min_pause"
public static final String
FIELD_NAME_CHECKPOINT_STORAGE
"checkpoint_storage"
public static final String
FIELD_NAME_CHECKPOINT_TIMEOUT
"timeout"
public static final String
FIELD_NAME_CHECKPOINTS_AFTER_TASKS_FINISH
"checkpoints_after_tasks_finish"
public static final String
FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG
"externalization"
public static final String
FIELD_NAME_PERIODIC_MATERIALIZATION_INTERVAL
"changelog_periodic_materialization_interval"
public static final String
FIELD_NAME_PROCESSING_MODE
"mode"
public static final String
FIELD_NAME_STATE_BACKEND
"state_backend"
public static final String
FIELD_NAME_STATE_CHANGELOG
"state_changelog_enabled"
public static final String
FIELD_NAME_TOLERABLE_FAILED_CHECKPOINTS
"tolerable_failed_checkpoints"
public static final String
FIELD_NAME_UNALIGNED_CHECKPOINTS
"unaligned_checkpoints"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointConfigInfo.ExternalizedCheckpointInfo 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"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointIdPathParameter Modifier and Type Constant Field Value public static final String
KEY
"checkpointid"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics 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"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.Counts 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"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints 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"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.RestoredCheckpointStatistics 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"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.Summary Modifier and Type Constant Field Value public static final String
FIELD_NAME_ALIGNMENT_BUFFERED
"alignment_buffered"
public static final String
FIELD_NAME_CHECKPOINTED_SIZE
"checkpointed_size"
public static final String
FIELD_NAME_DURATION
"end_to_end_duration"
public static final String
FIELD_NAME_PERSISTED_DATA
"persisted_data"
public static final String
FIELD_NAME_PROCESSED_DATA
"processed_data"
public static final String
FIELD_NAME_STATE_SIZE
"state_size"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatisticsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/checkpoints"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatisticDetailsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/checkpoints/details/:checkpointid"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics Modifier and Type Constant Field Value public static final String
FIELD_NAME_ALIGNMENT_BUFFERED
"alignment_buffered"
public static final String
FIELD_NAME_CHECKPOINT_TYPE
"checkpoint_type"
public static final String
FIELD_NAME_CHECKPOINTED_SIZE
"checkpointed_size"
public static final String
FIELD_NAME_DURATION
"end_to_end_duration"
public static final String
FIELD_NAME_ID
"id"
public static final String
FIELD_NAME_IS_SAVEPOINT
"is_savepoint"
public static final String
FIELD_NAME_LATEST_ACK_TIMESTAMP
"latest_ack_timestamp"
public static final String
FIELD_NAME_NUM_ACK_SUBTASKS
"num_acknowledged_subtasks"
public static final String
FIELD_NAME_NUM_SUBTASKS
"num_subtasks"
public static final String
FIELD_NAME_PERSISTED_DATA
"persisted_data"
public static final String
FIELD_NAME_PROCESSED_DATA
"processed_data"
public static final String
FIELD_NAME_SAVEPOINT_FORMAT
"savepointFormat"
public static final String
FIELD_NAME_STATE_SIZE
"state_size"
public static final String
FIELD_NAME_STATUS
"status"
public static final String
FIELD_NAME_TASKS
"tasks"
public static final String
FIELD_NAME_TRIGGER_TIMESTAMP
"trigger_timestamp"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.CompletedCheckpointStatistics Modifier and Type Constant Field Value public static final String
FIELD_NAME_DISCARDED
"discarded"
public static final String
FIELD_NAME_EXTERNAL_PATH
"external_path"
-
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.FailedCheckpointStatistics 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"
-
org.apache.flink.runtime.rest.messages.checkpoints.StatsSummaryDto Modifier and Type Constant Field Value public static final String
FIELD_NAME_AVERAGE
"avg"
public static final String
FIELD_NAME_MAXIMUM
"max"
public static final String
FIELD_NAME_MINIMUM
"min"
public static final String
FIELD_NAME_P50
"p50"
public static final String
FIELD_NAME_P90
"p90"
public static final String
FIELD_NAME_P95
"p95"
public static final String
FIELD_NAME_P99
"p99"
public static final String
FIELD_NAME_P999
"p999"
-
org.apache.flink.runtime.rest.messages.checkpoints.SubtaskCheckpointStatistics Modifier and Type Constant Field Value public static final String
FIELD_NAME_CHECKPOINT_STATUS
"status"
public static final String
FIELD_NAME_INDEX
"index"
-
org.apache.flink.runtime.rest.messages.checkpoints.SubtaskCheckpointStatistics.CompletedSubtaskCheckpointStatistics Modifier and Type Constant Field Value public static final String
FIELD_NAME_ABORTED
"aborted"
public static final String
FIELD_NAME_ACK_TIMESTAMP
"ack_timestamp"
public static final String
FIELD_NAME_ALIGNMENT
"alignment"
public static final String
FIELD_NAME_CHECKPOINT_DURATION
"checkpoint"
public static final String
FIELD_NAME_CHECKPOINTED_SIZE
"checkpointed_size"
public static final String
FIELD_NAME_DURATION
"end_to_end_duration"
public static final String
FIELD_NAME_START_DELAY
"start_delay"
public static final String
FIELD_NAME_STATE_SIZE
"state_size"
public static final String
FIELD_NAME_UNALIGNED_CHECKPOINT
"unaligned_checkpoint"
-
org.apache.flink.runtime.rest.messages.checkpoints.SubtaskCheckpointStatistics.CompletedSubtaskCheckpointStatistics.CheckpointAlignment 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"
-
org.apache.flink.runtime.rest.messages.checkpoints.SubtaskCheckpointStatistics.CompletedSubtaskCheckpointStatistics.CheckpointDuration Modifier and Type Constant Field Value public static final String
FIELD_NAME_ASYNC_DURATION
"async"
public static final String
FIELD_NAME_SYNC_DURATION
"sync"
-
org.apache.flink.runtime.rest.messages.checkpoints.TaskCheckpointStatistics Modifier and Type Constant Field Value public static final String
FIELD_NAME_ALIGNMENT_BUFFERED
"alignment_buffered"
public static final String
FIELD_NAME_CHECKPOINT_STATUS
"status"
public static final String
FIELD_NAME_CHECKPOINTED_SIZE
"checkpointed_size"
public static final String
FIELD_NAME_DURATION
"end_to_end_duration"
public static final String
FIELD_NAME_ID
"id"
public static final String
FIELD_NAME_LATEST_ACK_TIMESTAMP
"latest_ack_timestamp"
public static final String
FIELD_NAME_NUM_ACK_SUBTASKS
"num_acknowledged_subtasks"
public static final String
FIELD_NAME_NUM_SUBTASKS
"num_subtasks"
public static final String
FIELD_NAME_PERSISTED_DATA
"persisted_data"
public static final String
FIELD_NAME_PROCESSED_DATA
"processed_data"
public static final String
FIELD_NAME_STATE_SIZE
"state_size"
-
org.apache.flink.runtime.rest.messages.checkpoints.TaskCheckpointStatisticsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid"
-
org.apache.flink.runtime.rest.messages.checkpoints.TaskCheckpointStatisticsWithSubtaskDetails Modifier and Type Constant Field Value public static final String
FIELD_NAME_SUBTASKS_CHECKPOINT_STATISTICS
"subtasks"
public static final String
FIELD_NAME_SUMMARY
"summary"
-
org.apache.flink.runtime.rest.messages.checkpoints.TaskCheckpointStatisticsWithSubtaskDetails.CheckpointAlignment 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"
-
org.apache.flink.runtime.rest.messages.checkpoints.TaskCheckpointStatisticsWithSubtaskDetails.CheckpointDuration Modifier and Type Constant Field Value public static final String
FIELD_NAME_ASYNCHRONOUS_DURATION
"async"
public static final String
FIELD_NAME_SYNCHRONOUS_DURATION
"sync"
-
org.apache.flink.runtime.rest.messages.checkpoints.TaskCheckpointStatisticsWithSubtaskDetails.Summary Modifier and Type Constant Field Value public static final String
FIELD_NAME_ALIGNMENT
"alignment"
public static final String
FIELD_NAME_CHECKPOINT_DURATION
"checkpoint_duration"
public static final String
FIELD_NAME_CHECKPOINTED_SIZE
"checkpointed_size"
public static final String
FIELD_NAME_DURATION
"end_to_end_duration"
public static final String
FIELD_NAME_START_DELAY
"start_delay"
public static final String
FIELD_NAME_STATE_SIZE
"state_size"
-
org.apache.flink.runtime.rest.messages.dataset.ClusterDataSetIdPathParameter Modifier and Type Constant Field Value public static final String
KEY
"datasetid"
-
org.apache.flink.runtime.rest.messages.job.FailureLabelFilterParameter Modifier and Type Constant Field Value public static final String
KEY
"failureLabelFilter"
-
org.apache.flink.runtime.rest.messages.job.JobDetailsHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid"
-
org.apache.flink.runtime.rest.messages.job.JobDetailsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_DURATION
"duration"
public static final String
FIELD_NAME_END_TIME
"end-time"
public static final String
FIELD_NAME_IS_STOPPABLE
"isStoppable"
public static final String
FIELD_NAME_JOB_ID
"jid"
public static final String
FIELD_NAME_JOB_NAME
"name"
public static final String
FIELD_NAME_JOB_STATUS
"state"
public static final String
FIELD_NAME_JOB_TYPE
"job-type"
public static final String
FIELD_NAME_JOB_VERTEX_INFOS
"vertices"
public static final String
FIELD_NAME_JOB_VERTICES_PER_STATE
"status-counts"
public static final String
FIELD_NAME_JSON_PLAN
"plan"
public static final String
FIELD_NAME_MAX_PARALLELISM
"maxParallelism"
public static final String
FIELD_NAME_NOW
"now"
public static final String
FIELD_NAME_START_TIME
"start-time"
public static final String
FIELD_NAME_TIMESTAMPS
"timestamps"
-
org.apache.flink.runtime.rest.messages.job.JobDetailsInfo.JobVertexDetailsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_JOB_VERTEX_DURATION
"duration"
public static final String
FIELD_NAME_JOB_VERTEX_END_TIME
"end-time"
public static final String
FIELD_NAME_JOB_VERTEX_ID
"id"
public static final String
FIELD_NAME_JOB_VERTEX_METRICS
"metrics"
public static final String
FIELD_NAME_JOB_VERTEX_NAME
"name"
public static final String
FIELD_NAME_JOB_VERTEX_START_TIME
"start-time"
public static final String
FIELD_NAME_JOB_VERTEX_STATE
"status"
public static final String
FIELD_NAME_MAX_PARALLELISM
"maxParallelism"
public static final String
FIELD_NAME_PARALLELISM
"parallelism"
public static final String
FIELD_NAME_SLOT_SHARING_GROUP_ID
"slotSharingGroupId"
public static final String
FIELD_NAME_TASKS_PER_STATE
"tasks"
-
org.apache.flink.runtime.rest.messages.job.JobManagerJobConfigurationHeaders Modifier and Type Constant Field Value public static final String
JOBMANAGER_JOB_CONFIG_REST_PATH
"/jobs/:jobid/jobmanager/config"
-
org.apache.flink.runtime.rest.messages.job.JobManagerJobEnvironmentHeaders Modifier and Type Constant Field Value public static final String
JOBMANAGER_JOB_ENV_REST_PATH
"/jobs/:jobid/jobmanager/environment"
-
org.apache.flink.runtime.rest.messages.job.JobSubmitRequestBody Modifier and Type Constant Field Value public static final String
FIELD_NAME_EXECUTION_PLAN
"executionPlanFileName"
public static final String
FIELD_NAME_JOB_GRAPH
"jobGraphFileName"
-
org.apache.flink.runtime.rest.messages.job.JobSubmitResponseBody Modifier and Type Constant Field Value public static final String
FIELD_NAME_JOB_URL
"jobUrl"
-
org.apache.flink.runtime.rest.messages.job.SubtaskAttemptPathParameter Modifier and Type Constant Field Value public static final String
KEY
"attempt"
-
org.apache.flink.runtime.rest.messages.job.SubtaskExecutionAttemptAccumulatorsInfo 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"
-
org.apache.flink.runtime.rest.messages.job.SubtaskExecutionAttemptDetailsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_ATTEMPT
"attempt"
public static final String
FIELD_NAME_COMPATIBLE_START_TIME
"start_time"
public static final String
FIELD_NAME_DURATION
"duration"
public static final String
FIELD_NAME_END_TIME
"end-time"
public static final String
FIELD_NAME_ENDPOINT
"endpoint"
public static final String
FIELD_NAME_METRICS
"metrics"
public static final String
FIELD_NAME_OTHER_CONCURRENT_ATTEMPTS
"other-concurrent-attempts"
public static final String
FIELD_NAME_START_TIME
"start-time"
public static final String
FIELD_NAME_STATUS
"status"
public static final String
FIELD_NAME_STATUS_DURATION
"status-duration"
public static final String
FIELD_NAME_SUBTASK_INDEX
"subtask"
public static final String
FIELD_NAME_TASKMANAGER_ID
"taskmanager-id"
-
org.apache.flink.runtime.rest.messages.job.SubtasksAllAccumulatorsInfo 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"
-
org.apache.flink.runtime.rest.messages.job.SubtasksAllAccumulatorsInfo.SubtaskAccumulatorsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_ATTEMPT_NUM
"attempt"
public static final String
FIELD_NAME_ENDPOINT
"endpoint"
public static final String
FIELD_NAME_SUBTASK_INDEX
"subtask"
public static final String
FIELD_NAME_USER_ACCUMULATORS
"user-accumulators"
-
org.apache.flink.runtime.rest.messages.job.UpperLimitExceptionParameter Modifier and Type Constant Field Value public static final String
KEY
"maxExceptions"
-
org.apache.flink.runtime.rest.messages.job.UserAccumulator 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"
-
org.apache.flink.runtime.rest.messages.job.coordination.ClientCoordinationHeaders Modifier and Type Constant Field Value public static final String
URL
"/jobs/:jobid/coordinators/:operatorUid"
-
org.apache.flink.runtime.rest.messages.job.coordination.ClientCoordinationRequestBody Modifier and Type Constant Field Value public static final String
FIELD_NAME_SERIALIZED_COORDINATION_REQUEST
"serializedCoordinationRequest"
-
org.apache.flink.runtime.rest.messages.job.coordination.ClientCoordinationResponseBody Modifier and Type Constant Field Value public static final String
FIELD_NAME_SERIALIZED_COORDINATION_RESULT
"serializedCoordinationResult"
-
org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_ACC_BACK_PRESSURE
"accumulated-backpressured-time"
public static final String
FIELD_NAME_ACC_BUSY
"accumulated-busy-time"
public static final String
FIELD_NAME_ACC_IDLE
"accumulated-idle-time"
public static final String
FIELD_NAME_BYTES_READ
"read-bytes"
public static final String
FIELD_NAME_BYTES_WRITTEN
"write-bytes"
public static final String
FIELD_NAME_RECORDS_READ
"read-records"
public static final String
FIELD_NAME_RECORDS_WRITTEN
"write-records"
-
org.apache.flink.runtime.rest.messages.job.savepoints.SavepointDisposalRequest Modifier and Type Constant Field Value public static final String
FIELD_NAME_SAVEPOINT_PATH
"savepoint-path"
-
org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody Modifier and Type Constant Field Value public static final String
FIELD_NAME_TARGET_DIRECTORY
"target-directory"
-
org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody Modifier and Type Constant Field Value public static final String
FIELD_NAME_FORMAT_TYPE
"formatType"
public static final String
FIELD_NAME_TARGET_DIRECTORY
"targetDirectory"
-
org.apache.flink.runtime.rest.messages.json.SerializedThrowableSerializer Modifier and Type Constant Field Value public static final String
FIELD_NAME_SERIALIZED_THROWABLE
"serialized-throwable"
-
org.apache.flink.runtime.rest.messages.taskmanager.SlotInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_JOB_ID
"jobId"
public static final String
FIELD_NAME_RESOURCE
"resource"
-
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerDetailsHeaders Modifier and Type Constant Field Value public static final String
URL
"/taskmanagers/:taskmanagerid"
-
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerDetailsInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_ALLOCATED_SLOTS
"allocatedSlots"
public static final String
FIELD_NAME_METRICS
"metrics"
-
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerIdPathParameter Modifier and Type Constant Field Value public static final String
KEY
"taskmanagerid"
-
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_ADDRESS
"path"
public static final String
FIELD_NAME_AVAILABLE_RESOURCE
"freeResource"
public static final String
FIELD_NAME_BLOCKED
"blocked"
public static final String
FIELD_NAME_DATA_PORT
"dataPort"
public static final String
FIELD_NAME_HARDWARE
"hardware"
public static final String
FIELD_NAME_JMX_PORT
"jmxPort"
public static final String
FIELD_NAME_LAST_HEARTBEAT
"timeSinceLastHeartbeat"
public static final String
FIELD_NAME_MEMORY
"memoryConfiguration"
public static final String
FIELD_NAME_NUMBER_AVAILABLE_SLOTS
"freeSlots"
public static final String
FIELD_NAME_NUMBER_SLOTS
"slotsNumber"
public static final String
FIELD_NAME_RESOURCE_ID
"id"
public static final String
FIELD_NAME_TOTAL_RESOURCE
"totalResource"
-
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerMetricsInfo 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_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"
-
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerMetricsInfo.GarbageCollectorInfo 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"
-
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagersHeaders Modifier and Type Constant Field Value public static final String
URL
"/taskmanagers"
-
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagersInfo Modifier and Type Constant Field Value public static final String
FIELD_NAME_TASK_MANAGERS
"taskmanagers"
-
org.apache.flink.runtime.rest.util.RestConstants 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"
-
org.apache.flink.runtime.scheduler.DefaultVertexParallelismInfo Modifier and Type Constant Field Value public static final int
PARALLELISM_AUTO_MAX
2147483647
-
org.apache.flink.runtime.scheduler.adaptive.JobFailureMetricReporter Modifier and Type Constant Field Value public static final String
FAILURE_LABEL_ATTRIBUTE_PREFIX
"failureLabel."
-
org.apache.flink.runtime.scheduler.strategy.ExecutionVertexID Modifier and Type Constant Field Value public static final int
SIZE
20
-
org.apache.flink.runtime.scheduler.strategy.PartialFinishedInputConsumableDecider Modifier and Type Constant Field Value public static final int
NUM_FINISHED_PARTITIONS_AS_CONSUMABLE
1
-
org.apache.flink.runtime.shuffle.ShuffleServiceOptions Modifier and Type Constant Field Value public static final String
NETTY_SHUFFLE_SERVICE_FACTORY_CLASS
"org.apache.flink.runtime.io.network.NettyShuffleServiceFactory"
-
org.apache.flink.runtime.source.coordinator.SourceCoordinatorSerdeUtils Modifier and Type Constant Field Value public static final int
VERSION_0
0
public static final int
VERSION_1
1
-
org.apache.flink.runtime.state.DefaultOperatorStateBackend Modifier and Type Constant Field Value public static final String
DEFAULT_OPERATOR_STATE_NAME
"_default_"
-
org.apache.flink.runtime.state.FullSnapshotUtil 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
-
org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle Modifier and Type Constant Field Value public static final long
UNKNOWN_CHECKPOINTED_SIZE
-1L
-
org.apache.flink.runtime.state.KeyedBackendSerializationProxy<K> Modifier and Type Constant Field Value public static final int
VERSION
6
-
org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream Modifier and Type Constant Field Value public static final int
NO_CURRENT_KEY_GROUP
-1
public static final long
NO_OFFSET_SET
-1L
-
org.apache.flink.runtime.state.KeyGroupRangeAssignment 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
-
org.apache.flink.runtime.state.OperatorBackendSerializationProxy Modifier and Type Constant Field Value public static final int
VERSION
6
-
org.apache.flink.runtime.state.StateBackendLoader Modifier and Type Constant Field Value public static final String
FORST_STATE_BACKEND_NAME
"forst"
public static final String
HASHMAP_STATE_BACKEND_NAME
"hashmap"
public static final String
ROCKSDB_STATE_BACKEND_NAME
"rocksdb"
-
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager Modifier and Type Constant Field Value public static final String
ALLOCATION_DIR_PREFIX
"aid_"
-
org.apache.flink.runtime.state.TaskLocalStateStoreImpl Modifier and Type Constant Field Value public static final String
TASK_STATE_SNAPSHOT_FILENAME
"_task_state_snapshot"
-
org.apache.flink.runtime.state.changelog.StateChange Modifier and Type Constant Field Value public static final int
META_KEY_GROUP
-1
-
org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogStorageFactory Modifier and Type Constant Field Value public static final String
IDENTIFIER
"memory"
-
org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorageAccess 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"
-
org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory Modifier and Type Constant Field Value public static final int
MAX_FILE_STATE_THRESHOLD
1048576
-
org.apache.flink.runtime.state.heap.CopyOnWriteStateMap<K,N,S> Modifier and Type Constant Field Value public static final int
DEFAULT_CAPACITY
128
-
org.apache.flink.runtime.state.heap.HeapPriorityQueueElement Modifier and Type Constant Field Value public static final int
NOT_CONTAINED
-2147483648
-
org.apache.flink.runtime.state.heap.space.Constants 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
-
org.apache.flink.runtime.state.memory.NonPersistentMetadataCheckpointStorageLocation Modifier and Type Constant Field Value public static final String
EXTERNAL_POINTER
"<checkpoint-not-externally-addressable>"
-
org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters Modifier and Type Constant Field Value public static final int
CURRENT_STATE_META_INFO_SNAPSHOT_VERSION
7
-
org.apache.flink.runtime.state.storage.JobManagerCheckpointStorage Modifier and Type Constant Field Value public static final int
DEFAULT_MAX_STATE_SIZE
5242880
-
org.apache.flink.runtime.taskexecutor.TaskExecutor Modifier and Type Constant Field Value public static final String
TASK_MANAGER_NAME
"taskmanager"
-
org.apache.flink.runtime.taskexecutor.TaskExecutorMemoryConfiguration 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"
-
org.apache.flink.runtime.taskexecutor.TaskManagerRunner Modifier and Type Constant Field Value public static final int
FAILURE_EXIT_CODE
1
-
org.apache.flink.runtime.util.EnvironmentInformation Modifier and Type Constant Field Value public static final String
UNKNOWN
"<unknown>"
public static final String
UNKNOWN_COMMIT_ID
"DecafC0ffeeD0d0F00d"
public static final String
UNKNOWN_COMMIT_ID_ABBREV
"DeadD0d0"
-
org.apache.flink.runtime.util.ZooKeeperUtils Modifier and Type Constant Field Value public static final String
HA_STORAGE_COMPLETED_CHECKPOINT
"completedCheckpoint"
public static final String
HA_STORAGE_SUBMITTED_EXECUTION_PLAN_PREFIX
"submittedExecutionPlan"
public static final String
RESOURCE_MANAGER_NODE
"resource_manager"
-
org.apache.flink.runtime.util.bash.BashJavaUtils Modifier and Type Constant Field Value public static final String
EXECUTION_PREFIX
"BASH_JAVA_UTILS_EXEC_RESULT:"
-
org.apache.flink.runtime.webmonitor.handlers.JarIdPathParameter Modifier and Type Constant Field Value public static final String
KEY
"jarid"
-
org.apache.flink.runtime.webmonitor.handlers.JarListHeaders Modifier and Type Constant Field Value public static final String
URL
"/jars"
-
org.apache.flink.runtime.webmonitor.handlers.JarListInfo Modifier and Type Constant Field Value public static final String
JAR_LIST_FIELD_ADDRESS
"address"
public static final String
JAR_LIST_FIELD_FILES
"files"
-
org.apache.flink.runtime.webmonitor.handlers.JarListInfo.JarEntryInfo Modifier and Type Constant Field Value public static final String
JAR_ENTRY_FIELD_DESC
"description"
public static final String
JAR_ENTRY_FIELD_NAME
"name"
-
org.apache.flink.runtime.webmonitor.handlers.JarListInfo.JarFileInfo 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"
-
org.apache.flink.runtime.webmonitor.handlers.JarUploadHeaders Modifier and Type Constant Field Value public static final String
URL
"/jars/upload"
-
org.apache.flink.runtime.webmonitor.handlers.SavepointPathQueryParameter Modifier and Type Constant Field Value public static final String
KEY
"savepointPath"
-
org.apache.flink.runtime.webmonitor.stats.TaskStatsRequestCoordinator<T,V> Modifier and Type Constant Field Value protected static final int
NUM_GHOST_SAMPLE_IDS
10
-
org.apache.flink.runtime.zookeeper.FlinkZooKeeperQuorumPeer 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
-
org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants Modifier and Type Constant Field Value public static final int
A
1
public static final int
ABS
2
public static final int
ABSENT
3
public static final int
ABSOLUTE
4
public static final int
ACTION
5
public static final int
ADA
6
public static final int
ADD
7
public static final int
ADMIN
8
public static final int
AFTER
9
public static final int
ALL
10
public static final int
ALLOCATE
11
public static final int
ALLOW
12
public static final int
ALTER
13
public static final int
ALWAYS
14
public static final int
ANALYZE
703
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
765
public static final int
ARE
18
public static final int
ARRAY
19
public static final int
ARRAY_AGG
20
public static final int
ARRAY_CONCAT_AGG
21
public static final int
ARRAY_MAX_CARDINALITY
22
public static final int
AS
23
public static final int
ASC
24
public static final int
ASENSITIVE
25
public static final int
ASSERTION
26
public static final int
ASSIGNMENT
27
public static final int
ASYMMETRIC
28
public static final int
AT
29
public static final int
ATOMIC
30
public static final int
ATTRIBUTE
31
public static final int
ATTRIBUTES
32
public static final int
AUTHORIZATION
33
public static final int
AVG
34
public static final int
BACK_QUOTED_IDENTIFIER
829
public static final int
BEFORE
35
public static final int
BEGIN
36
public static final int
BEGIN_FRAME
37
public static final int
BEGIN_PARTITION
38
public static final int
BEL
837
public static final int
BERNOULLI
39
public static final int
BETWEEN
40
public static final int
BIG_QUERY_BACK_QUOTED_IDENTIFIER
830
public static final int
BIG_QUERY_DOUBLE_QUOTED_STRING
776
public static final int
BIG_QUERY_QUOTED_STRING
777
public static final int
BIGINT
41
public static final int
BINARY
42
public static final int
BINARY_STRING_LITERAL
770
public static final int
BIT
43
public static final int
BLOB
44
public static final int
BOOLEAN
45
public static final int
BOTH
46
public static final int
BQHID
4
public static final int
BQID
3
public static final int
BRACKET_QUOTED_IDENTIFIER
827
public static final int
BREADTH
47
public static final int
BTID
2
public static final int
BUCKETS
704
public static final int
BY
48
public static final int
BYTES
705
public static final int
C
49
public static final int
C_STYLE_ESCAPED_STRING_LITERAL
774
public static final int
CALL
50
public static final int
CALLED
51
public static final int
CARDINALITY
52
public static final int
CARET
812
public static final int
CASCADE
53
public static final int
CASCADED
54
public static final int
CASE
55
public static final int
CAST
56
public static final int
CATALOG
57
public static final int
CATALOG_NAME
58
public static final int
CATALOGS
706
public static final int
CEIL
59
public static final int
CEILING
60
public static final int
CENTURY
61
public static final int
CHAIN
62
public static final int
CHANGELOG_MODE
707
public static final int
CHAR
63
public static final int
CHAR_LENGTH
64
public static final int
CHARACTER
65
public static final int
CHARACTER_LENGTH
66
public static final int
CHARACTER_SET_CATALOG
67
public static final int
CHARACTER_SET_NAME
68
public static final int
CHARACTER_SET_SCHEMA
69
public static final int
CHARACTERISTICS
70
public static final int
CHARACTERS
71
public static final int
CHARSETNAME
775
public static final int
CHECK
72
public static final int
CLASS_ORIGIN
74
public static final int
CLASSIFIER
73
public static final int
CLOB
75
public static final int
CLOSE
76
public static final int
COALESCE
77
public static final int
COBOL
78
public static final int
COLLATE
79
public static final int
COLLATION
80
public static final int
COLLATION_CATALOG
81
public static final int
COLLATION_ID
833
public static final int
COLLATION_NAME
82
public static final int
COLLATION_SCHEMA
83
public static final int
COLLECT
84
public static final int
COLON
796
public static final int
COLUMN
85
public static final int
COLUMN_NAME
86
public static final int
COLUMNS
708
public static final int
COMMA
791
public static final int
COMMAND_FUNCTION
87
public static final int
COMMAND_FUNCTION_CODE
88
public static final int
COMMENT
709
public static final int
COMMENT_END
820
public static final int
COMMIT
89
public static final int
COMMITTED
90
public static final int
COMPACT
710
public static final int
COMPILE
711
public static final int
COMPUTE
712
public static final int
CONCAT
806
public static final int
CONDITION
91
public static final int
CONDITION_NUMBER
93
public static final int
CONDITIONAL
92
public static final int
CONNECT
94
public static final int
CONNECTION
95
public static final int
CONNECTION_NAME
96
public static final int
CONSTRAINT
97
public static final int
CONSTRAINT_CATALOG
98
public static final int
CONSTRAINT_NAME
99
public static final int
CONSTRAINT_SCHEMA
100
public static final int
CONSTRAINTS
101
public static final int
CONSTRUCTOR
102
public static final int
CONTAINS
103
public static final int
CONTINUE
104
public static final int
CONTINUOUS
713
public static final int
CONVERT
105
public static final int
CORR
106
public static final int
CORRESPONDING
107
public static final int
COUNT
108
public static final int
COVAR_POP
109
public static final int
COVAR_SAMP
110
public static final int
CREATE
111
public static final int
CROSS
112
public static final int
CUBE
113
public static final int
CUME_DIST
114
public static final int
CURRENT
115
public static final int
CURRENT_CATALOG
116
public static final int
CURRENT_DATE
117
public static final int
CURRENT_DEFAULT_TRANSFORM_GROUP
118
public static final int
CURRENT_PATH
119
public static final int
CURRENT_ROLE
120
public static final int
CURRENT_ROW
121
public static final int
CURRENT_SCHEMA
122
public static final int
CURRENT_TIME
123
public static final int
CURRENT_TIMESTAMP
124
public static final int
CURRENT_TRANSFORM_GROUP_FOR_TYPE
125
public static final int
CURRENT_USER
126
public static final int
CURSOR
127
public static final int
CURSOR_NAME
128
public static final int
CYCLE
129
public static final int
DATA
130
public static final int
DATABASE
131
public static final int
DATABASES
714
public static final int
DATE
132
public static final int
DATE_DIFF
138
public static final int
DATE_TRUNC
133
public static final int
DATETIME
134
public static final int
DATETIME_DIFF
135
public static final int
DATETIME_INTERVAL_CODE
136
public static final int
DATETIME_INTERVAL_PRECISION
137
public static final int
DAY
139
public static final int
DAYS
140
public static final int
DEALLOCATE
141
public static final int
DEC
142
public static final int
DECADE
143
public static final int
DECIMAL
144
public static final int
DECIMAL_NUMERIC_LITERAL
766
public static final int
DECLARE
145
public static final int
DEFAULT
0
public static final int
DEFAULT_
146
public static final int
DEFAULTS
147
public static final int
DEFERRABLE
148
public static final int
DEFERRED
149
public static final int
DEFINE
150
public static final int
DEFINED
151
public static final int
DEFINER
152
public static final int
DEGREE
153
public static final int
DELETE
154
public static final int
DENSE_RANK
155
public static final int
DEPTH
156
public static final int
DEREF
157
public static final int
DERIVED
158
public static final int
DESC
159
public static final int
DESCRIBE
160
public static final int
DESCRIPTION
161
public static final int
DESCRIPTOR
162
public static final int
DETERMINISTIC
163
public static final int
DIAGNOSTICS
164
public static final int
DIGIT
836
public static final int
DISALLOW
165
public static final int
DISCONNECT
166
public static final int
DISPATCH
167
public static final int
DISTINCT
168
public static final int
DISTRIBUTED
715
public static final int
DISTRIBUTION
716
public static final int
DOLLAR
813
public static final int
DOMAIN
169
public static final int
DOT
790
public static final int
DOT_FORMAT
170
public static final int
DOUBLE
171
public static final int
DOUBLE_PERIOD
808
public static final int
DOUBLE_QUOTE
810
public static final int
DOW
172
public static final int
DOY
173
public static final int
DQID
1
public static final int
DRAIN
717
public static final int
DROP
174
public static final int
DYNAMIC
175
public static final int
DYNAMIC_FUNCTION
176
public static final int
DYNAMIC_FUNCTION_CODE
177
public static final int
EACH
178
public static final int
ELEMENT
179
public static final int
ELSE
180
public static final int
EMPTY
181
public static final int
ENCODING
182
public static final int
END
183
public static final int
END_EXEC
184
public static final int
END_FRAME
185
public static final int
END_PARTITION
186
public static final int
ENFORCED
718
public static final int
EOF
0
public static final int
EPOCH
187
public static final int
EQ
792
public static final int
EQUALS
188
public static final int
ERROR
189
public static final int
ESCAPE
190
public static final int
ESTIMATED_COST
719
public static final int
EVERY
191
public static final int
EXCEPT
192
public static final int
EXCEPTION
193
public static final int
EXCLUDE
194
public static final int
EXCLUDING
195
public static final int
EXEC
196
public static final int
EXECUTE
197
public static final int
EXISTS
198
public static final int
EXP
199
public static final int
EXPLAIN
200
public static final int
EXPONENT
767
public static final int
EXTEND
201
public static final int
EXTENDED
720
public static final int
EXTERNAL
202
public static final int
EXTRACT
203
public static final int
FALSE
204
public static final int
FETCH
205
public static final int
FILTER
206
public static final int
FINAL
207
public static final int
FIRST
208
public static final int
FIRST_VALUE
209
public static final int
FLOAT
210
public static final int
FLOOR
211
public static final int
FOLLOWING
212
public static final int
FOR
213
public static final int
FOREIGN
215
public static final int
FORMAL_COMMENT
824
public static final int
FORMAT
214
public static final int
FORTRAN
216
public static final int
FOUND
217
public static final int
FRAC_SECOND
218
public static final int
FRAME_ROW
219
public static final int
FREE
220
public static final int
FRESHNESS
722
public static final int
FRIDAY
221
public static final int
FROM
222
public static final int
FULL
223
public static final int
FUNCTION
224
public static final int
FUNCTIONS
721
public static final int
FUSION
225
public static final int
G
226
public static final int
GE
798
public static final int
GENERAL
227
public static final int
GENERATED
228
public static final int
GEOMETRY
229
public static final int
GET
230
public static final int
GLOBAL
231
public static final int
GO
232
public static final int
GOTO
233
public static final int
GRANT
234
public static final int
GRANTED
235
public static final int
GROUP
236
public static final int
GROUP_CONCAT
237
public static final int
GROUPING
238
public static final int
GROUPS
239
public static final int
GT
793
public static final int
HASH
723
public static final int
HAVING
240
public static final int
HEXDIGIT
768
public static final int
HIERARCHY
241
public static final int
HINT_BEG
819
public static final int
HOLD
242
public static final int
HOOK
795
public static final int
HOP
243
public static final int
HOUR
244
public static final int
HOURS
245
public static final int
HYPHENATED_IDENTIFIER
831
public static final int
IDENTIFIER
832
public static final int
IDENTITY
246
public static final int
IF
724
public static final int
IGNORE
247
public static final int
ILIKE
248
public static final int
IMMEDIATE
249
public static final int
IMMEDIATELY
250
public static final int
IMPLEMENTATION
251
public static final int
IMPORT
252
public static final int
IN
253
public static final int
IN_FORMAL_COMMENT
5
public static final int
IN_MULTI_LINE_COMMENT
6
public static final int
INCLUDE
254
public static final int
INCLUDING
255
public static final int
INCREMENT
256
public static final int
INDICATOR
257
public static final int
INITIAL
258
public static final int
INITIALLY
259
public static final int
INNER
260
public static final int
INOUT
261
public static final int
INPUT
262
public static final int
INSENSITIVE
263
public static final int
INSERT
264
public static final int
INSTANCE
265
public static final int
INSTANTIABLE
266
public static final int
INT
267
public static final int
INTEGER
268
public static final int
INTERSECT
269
public static final int
INTERSECTION
270
public static final int
INTERVAL
271
public static final int
INTO
272
public static final int
INVOKER
273
public static final int
IS
274
public static final int
ISODOW
275
public static final int
ISOLATION
277
public static final int
ISOYEAR
276
public static final int
JAR
726
public static final int
JARS
727
public static final int
JAVA
278
public static final int
JOB
728
public static final int
JOBS
729
public static final int
JOIN
279
public static final int
JSON
280
public static final int
JSON_ARRAY
281
public static final int
JSON_ARRAYAGG
282
public static final int
JSON_EXECUTION_PLAN
725
public static final int
JSON_EXISTS
283
public static final int
JSON_OBJECT
284
public static final int
JSON_OBJECTAGG
285
public static final int
JSON_QUERY
286
public static final int
JSON_VALUE
287
public static final int
K
288
public static final int
KEY
289
public static final int
KEY_MEMBER
290
public static final int
KEY_TYPE
291
public static final int
LABEL
292
public static final int
LAG
293
public static final int
LANGUAGE
294
public static final int
LARGE
295
public static final int
LAST
296
public static final int
LAST_VALUE
297
public static final int
LATERAL
298
public static final int
LBRACE
785
public static final int
LBRACE_D
781
public static final int
LBRACE_FN
784
public static final int
LBRACE_T
782
public static final int
LBRACE_TS
783
public static final int
LBRACKET
787
public static final int
LE
797
public static final int
LEAD
299
public static final int
LEADING
300
public static final int
LEFT
301
public static final int
LENGTH
302
public static final int
LETTER
835
public static final int
LEVEL
303
public static final int
LIBRARY
304
public static final int
LIKE
305
public static final int
LIKE_REGEX
306
public static final int
LIMIT
307
public static final int
LN
308
public static final int
LOAD
730
public static final int
LOCAL
309
public static final int
LOCALTIME
310
public static final int
LOCALTIMESTAMP
311
public static final int
LOCATOR
312
public static final int
LOWER
313
public static final int
LPAREN
779
public static final int
LT
794
public static final int
M
314
public static final int
MAP
315
public static final int
MATCH
316
public static final int
MATCH_NUMBER
319
public static final int
MATCH_RECOGNIZE
320
public static final int
MATCHED
317
public static final int
MATCHES
318
public static final int
MATERIALIZED
734
public static final int
MAX
321
public static final int
MAXVALUE
322
public static final int
MEASURES
323
public static final int
MEMBER
324
public static final int
MERGE
325
public static final int
MESSAGE_LENGTH
326
public static final int
MESSAGE_OCTET_LENGTH
327
public static final int
MESSAGE_TEXT
328
public static final int
METADATA
731
public static final int
METHOD
329
public static final int
MICROSECOND
330
public static final int
MILLENNIUM
332
public static final int
MILLISECOND
331
public static final int
MIN
333
public static final int
MINUS
802
public static final int
MINUTE
334
public static final int
MINUTES
335
public static final int
MINVALUE
336
public static final int
MOD
337
public static final int
MODEL
732
public static final int
MODELS
733
public static final int
MODIFIES
338
public static final int
MODIFY
735