Constant Field Values

Contents

• com.amazonaws.*
• org.apache.*

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