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.SqlMatchRecognize

Modifier and Type	Constant Field	Value
public static final int	OPERAND_AFTER	6
public static final int	OPERAND_INTERVAL	11
public static final int	OPERAND_MEASURES	5
public static final int	OPERAND_ORDER_BY	10
public static final int	OPERAND_PARTITION_BY	9
public static final int	OPERAND_PATTERN	1
public static final int	OPERAND_PATTERN_DEFINES	4
public static final int	OPERAND_ROWS_PER_MATCH	8
public static final int	OPERAND_STRICT_END	3
public static final int	OPERAND_STRICT_START	2
public static final int	OPERAND_SUBSET	7
public static final int	OPERAND_TABLE_REF	0

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.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	COMMON_HIGH_AVAILABILITY	"common_high_availability"
public static final String	COMMON_HIGH_AVAILABILITY_ZOOKEEPER	"common_high_availability_zk"
public static final String	COMMON_HOST_PORT	"common_host_port"
public static final String	COMMON_MEMORY	"common_memory"
public static final String	COMMON_MISCELLANEOUS	"common_miscellaneous"
public static final String	COMMON_STATE_BACKENDS	"common_state_backends"
public static final String	DEPRECATED_FILE_SINKS	"deprecated_file_sinks"
public static final String	EXPERT_CLASS_LOADING	"expert_class_loading"
public static final String	EXPERT_CLUSTER	"expert_cluster"
public static final String	EXPERT_DEBUGGING_AND_TUNING	"expert_debugging_and_tuning"
public static final String	EXPERT_FAULT_TOLERANCE	"expert_fault_tolerance"
public static final String	EXPERT_HIGH_AVAILABILITY	"expert_high_availability"
public static final String	EXPERT_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_STATE_BACKENDS	"expert_state_backends"
public static final String	EXPERT_ZOOKEEPER_HIGH_AVAILABILITY	"expert_high_availability_zk"
public static final String	SECURITY_AUTH_KERBEROS	"security_auth_kerberos"
public static final String	SECURITY_AUTH_ZOOKEEPER	"security_auth_zk"
public static final String	SECURITY_SSL	"security_ssl"
public static final String	STATE_BACKEND_LATENCY_TRACKING	"state_backend_latency_tracking"
public static final String	STATE_BACKEND_ROCKSDB	"state_backend_rocksdb"

org.apache.flink.api.common.ExecutionConfig

Modifier and Type	Constant Field	Value
public static final int	PARALLELISM_AUTO_MAX	2147483647
public static final int	PARALLELISM_DEFAULT	-1
public static final int	PARALLELISM_UNKNOWN	-2

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 String	BLOCK_SIZE_PARAMETER_KEY	"input.block_size"
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 String	BLOCK_SIZE_PARAMETER_KEY	"output.block_size"
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
public static final String	ENUMERATE_NESTED_FILES_FLAG	"recursive.file.enumeration"
protected static final long	READ_WHOLE_SPLIT_FLAG	-1L

org.apache.flink.api.common.io.FileOutputFormat<IT>

Modifier and Type	Constant Field	Value
public static final String	FILE_PARAMETER_KEY	"flink.output.file"

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.dag.Transformation<T>

Modifier and Type	Constant Field	Value
public static final int	UPPER_BOUND_MAX_PARALLELISM	32768

org.apache.flink.api.java.io.CsvInputFormat<OUT>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_FIELD_DELIMITER	","
public static final String	DEFAULT_LINE_DELIMITER	"\n"

org.apache.flink.api.java.io.CsvOutputFormat<T extends Tuple>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_LINE_DELIMITER	"\n"

org.apache.flink.api.java.sampling.RandomSampler<T>

Modifier and Type	Constant Field	Value
protected static final double	EPSILON	1.0E-5

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.runtime.RowSerializer

Modifier and Type	Constant Field	Value
public static final int	ROW_KIND_OFFSET	2

org.apache.flink.api.java.typeutils.runtime.ValueSerializer.ValueSerializerConfigSnapshot<T extends Value>

Modifier and Type	Constant Field	Value
public static final long	serialVersionUID	2277251654485371327L

org.apache.flink.api.java.utils.AbstractParameterTool

Modifier and Type	Constant Field	Value
protected static final String	DEFAULT_UNDEFINED	"<undefined>"
protected static final String	NO_VALUE_KEY	"__NO_VALUE_KEY"

org.apache.flink.api.scala.operators.ScalaCsvOutputFormat<T extends scala.Product>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_LINE_DELIMITER	"\n"

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.changelog.fs.FsStateChangelogStorageFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"filesystem"

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.ConfigConstants

Modifier and Type	Constant Field	Value
public static final String	AKKA_ASK_TIMEOUT	"akka.ask.timeout"
public static final String	AKKA_CLIENT_TIMEOUT	"akka.client.timeout"
public static final String	AKKA_DISPATCHER_THROUGHPUT	"akka.throughput"
public static final String	AKKA_FRAMESIZE	"akka.framesize"
public static final String	AKKA_JVM_EXIT_ON_FATAL_ERROR	"akka.jvm-exit-on-fatal-error"
public static final String	AKKA_LOG_LIFECYCLE_EVENTS	"akka.log.lifecycle.events"
public static final String	AKKA_LOOKUP_TIMEOUT	"akka.lookup.timeout"
public static final String	AKKA_SSL_ENABLED	"akka.ssl.enabled"
public static final String	AKKA_STARTUP_TIMEOUT	"akka.startup-timeout"
public static final String	AKKA_TCP_TIMEOUT	"akka.tcp.timeout"
public static final String	AKKA_TRANSPORT_HEARTBEAT_INTERVAL	"akka.transport.heartbeat.interval"
public static final String	AKKA_TRANSPORT_HEARTBEAT_PAUSE	"akka.transport.heartbeat.pause"
public static final String	AKKA_TRANSPORT_THRESHOLD	"akka.transport.threshold"
public static final String	AKKA_WATCH_HEARTBEAT_INTERVAL	"akka.watch.heartbeat.interval"
public static final String	AKKA_WATCH_HEARTBEAT_PAUSE	"akka.watch.heartbeat.pause"
public static final String	AKKA_WATCH_THRESHOLD	"akka.watch.threshold"
public static final String	BLOB_FETCH_BACKLOG_KEY	"blob.fetch.backlog"
public static final String	BLOB_FETCH_CONCURRENT_KEY	"blob.fetch.num-concurrent"
public static final String	BLOB_FETCH_RETRIES_KEY	"blob.fetch.retries"
public static final String	BLOB_SERVER_PORT	"blob.server.port"
public static final String	BLOB_SERVICE_SSL_ENABLED	"blob.service.ssl.enabled"
public static final String	BLOB_STORAGE_DIRECTORY_KEY	"blob.storage.directory"
public static final String	CHECKPOINTS_DIRECTORY_KEY	"state.checkpoints.dir"
public static final String	CONTAINERIZED_HEAP_CUTOFF_MIN	"containerized.heap-cutoff-min"
public static final String	CONTAINERIZED_HEAP_CUTOFF_RATIO	"containerized.heap-cutoff-ratio"
public static final String	CONTAINERIZED_MASTER_ENV_PREFIX	"containerized.master.env."
public static final String	CONTAINERIZED_TASK_MANAGER_ENV_PREFIX	"containerized.taskmanager.env."
public static final String	DEFAULT_AKKA_ASK_TIMEOUT	"10 s"
public static final String	DEFAULT_AKKA_CLIENT_TIMEOUT	"60 s"
public static final int	DEFAULT_AKKA_DISPATCHER_THROUGHPUT	15
public static final String	DEFAULT_AKKA_FRAMESIZE	"10485760b"
public static final boolean	DEFAULT_AKKA_LOG_LIFECYCLE_EVENTS	false
public static final String	DEFAULT_AKKA_LOOKUP_TIMEOUT	"10 s"
public static final boolean	DEFAULT_AKKA_SSL_ENABLED	true
public static final String	DEFAULT_AKKA_TRANSPORT_HEARTBEAT_INTERVAL	"1000 s"
public static final String	DEFAULT_AKKA_TRANSPORT_HEARTBEAT_PAUSE	"6000 s"
public static final double	DEFAULT_AKKA_TRANSPORT_THRESHOLD	300.0
public static final double	DEFAULT_AKKA_WATCH_THRESHOLD	12.0
public static final int	DEFAULT_BLOB_FETCH_BACKLOG	1000
public static final int	DEFAULT_BLOB_FETCH_CONCURRENT	50
public static final int	DEFAULT_BLOB_FETCH_RETRIES	5
public static final String	DEFAULT_BLOB_SERVER_PORT	"0"
public static final boolean	DEFAULT_BLOB_SERVICE_SSL_ENABLED	true
public static final int	DEFAULT_DELIMITED_FORMAT_MAX_LINE_SAMPLES	10
public static final int	DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN	2097152
public static final int	DEFAULT_DELIMITED_FORMAT_MIN_LINE_SAMPLES	2
public static final int	DEFAULT_EXECUTION_RETRIES	0
public static final boolean	DEFAULT_FILESYSTEM_ALWAYS_CREATE_DIRECTORY	false
public static final boolean	DEFAULT_FILESYSTEM_OVERWRITE	false
public static final String	DEFAULT_FILESYSTEM_SCHEME	"file:///"
public static final String	DEFAULT_FLINK_PLUGINS_DIRS	"plugins"
public static final String	DEFAULT_FLINK_USR_LIB_DIR	"usrlib"
public static final int	DEFAULT_FS_STREAM_OPENING_TIMEOUT	0
public static final String	DEFAULT_HA_JOB_MANAGER_PORT	"0"
public static final String	DEFAULT_HA_MODE	"none"
public static final String	DEFAULT_HA_ZOOKEEPER_CLIENT_ACL	"open"
public static final int	DEFAULT_JOB_MANAGER_IPC_PORT	6123
public static final int	DEFAULT_JOB_MANAGER_WEB_ARCHIVE_COUNT	5
public static final int	DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL	600000
public static final int	DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_DELAY	50
public static final int	DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES	100
public static final int	DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL	60000
public static final boolean	DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_DISABLE	false
public static final int	DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE	10
public static final int	DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT	8081
public static final boolean	DEFAULT_JOB_MANAGER_WEB_SSL_ENABLED	true
public static final boolean	DEFAULT_JOB_MANAGER_WEB_SUBMIT_ENABLED	true
public static final int	DEFAULT_LOCAL_NUMBER_JOB_MANAGER	1
public static final int	DEFAULT_LOCAL_NUMBER_RESOURCE_MANAGER	1
public static final int	DEFAULT_LOCAL_NUMBER_TASK_MANAGER	1
public static final float	DEFAULT_MEMORY_MANAGER_MEMORY_FRACTION	0.699999988079071f
public static final int	DEFAULT_MESOS_ARTIFACT_SERVER_PORT	0
public static final boolean	DEFAULT_MESOS_ARTIFACT_SERVER_SSL_ENABLED	true
public static final int	DEFAULT_MESOS_FAILOVER_TIMEOUT_SECS	600
public static final String	DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_NAME	"Flink"
public static final String	DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE	"*"
public static final String	DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_USER	""
public static final int	DEFAULT_METRICS_LATENCY_HISTORY_SIZE	128
public static final int	DEFAULT_PARALLELISM	1
public static final String	DEFAULT_PARALLELISM_KEY	"parallelism.default"
public static final String	DEFAULT_RECOVERY_JOB_MANAGER_PORT	"0"
public static final String	DEFAULT_RECOVERY_MODE	"standalone"
public static final int	DEFAULT_RESOURCE_MANAGER_IPC_PORT	0
public static final boolean	DEFAULT_RUNTIME_HASH_JOIN_BLOOM_FILTERS	false
public static final String	DEFAULT_SECURITY_SSL_ALGORITHMS	"TLS_RSA_WITH_AES_128_CBC_SHA"
public static final boolean	DEFAULT_SECURITY_SSL_ENABLED	false
public static final String	DEFAULT_SECURITY_SSL_PROTOCOL	"TLSv1.2"
public static final boolean	DEFAULT_SECURITY_SSL_VERIFY_HOSTNAME	true
public static final float	DEFAULT_SORT_SPILLING_THRESHOLD	0.800000011920929f
public static final String	DEFAULT_SORT_SPILLING_THRESHOLD_KEY	"taskmanager.runtime.sort-spilling-threshold"
public static final int	DEFAULT_SPILLING_MAX_FAN	128
public static final String	DEFAULT_SPILLING_MAX_FAN_KEY	"taskmanager.runtime.max-fan"
public static final String	DEFAULT_STATE_BACKEND	"jobmanager"
public static final long	DEFAULT_TASK_CANCELLATION_INTERVAL_MILLIS	30000L
public static final int	DEFAULT_TASK_MANAGER_DATA_PORT	0
public static final boolean	DEFAULT_TASK_MANAGER_DATA_SSL_ENABLED	true
public static final long	DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS	5000L
public static final boolean	DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD	false
public static final String	DEFAULT_TASK_MANAGER_INITIAL_REGISTRATION_PAUSE	"500 ms"
public static final int	DEFAULT_TASK_MANAGER_IPC_PORT	0
public static final String	DEFAULT_TASK_MANAGER_MAX_REGISTRATION_DURATION	"Inf"
public static final String	DEFAULT_TASK_MANAGER_MAX_REGISTRATION_PAUSE	"30 s"
public static final boolean	DEFAULT_TASK_MANAGER_MEMORY_PRE_ALLOCATE	false
public static final int	DEFAULT_TASK_MANAGER_MEMORY_SEGMENT_SIZE	32768
public static final String	DEFAULT_TASK_MANAGER_NETWORK_DEFAULT_IO_MODE	"sync"
public static final int	DEFAULT_TASK_MANAGER_NETWORK_NUM_BUFFERS	2048
public static final String	DEFAULT_TASK_MANAGER_REFUSED_REGISTRATION_PAUSE	"10 s"
public static final boolean	DEFAULT_USE_LARGE_RECORD_HANDLER	false
public static final String	DEFAULT_YARN_APPLICATION_MASTER_PORT	"deprecated"
public static final String	DEFAULT_YARN_CONTAINER_START_COMMAND_TEMPLATE	"%java% %jvmmem% %jvmopts% %logging% %class% %args% %redirects%"
public static final int	DEFAULT_YARN_HEAP_CUTOFF	600
public static final float	DEFAULT_YARN_HEAP_CUTOFF_RATIO	0.25f
public static final String	DEFAULT_YARN_JOB_MANAGER_PORT	"0"
public static final int	DEFAULT_YARN_MIN_HEAP_CUTOFF	-1
public static final String	DEFAULT_ZOOKEEPER_CHECKPOINT_COUNTER_PATH	"/checkpoint-counter"
public static final String	DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH	"/checkpoints"
public static final int	DEFAULT_ZOOKEEPER_CLIENT_PORT	2181
public static final int	DEFAULT_ZOOKEEPER_CONNECTION_TIMEOUT	15000
public static final String	DEFAULT_ZOOKEEPER_DIR_KEY	"/flink"
public static final int	DEFAULT_ZOOKEEPER_INIT_LIMIT	10
public static final String	DEFAULT_ZOOKEEPER_JOBGRAPHS_PATH	"/jobgraphs"
public static final String	DEFAULT_ZOOKEEPER_LATCH_PATH	"/leaderlatch"
public static final String	DEFAULT_ZOOKEEPER_LEADER_PATH	"/leader"
public static final int	DEFAULT_ZOOKEEPER_LEADER_PORT	3888
public static final int	DEFAULT_ZOOKEEPER_MAX_RETRY_ATTEMPTS	3
public static final String	DEFAULT_ZOOKEEPER_MESOS_WORKERS_PATH	"/mesos-workers"
public static final String	DEFAULT_ZOOKEEPER_NAMESPACE_KEY	"/default"
public static final int	DEFAULT_ZOOKEEPER_PEER_PORT	2888
public static final int	DEFAULT_ZOOKEEPER_RETRY_WAIT	5000
public static final boolean	DEFAULT_ZOOKEEPER_SASL_DISABLE	true
public static final int	DEFAULT_ZOOKEEPER_SESSION_TIMEOUT	60000
public static final int	DEFAULT_ZOOKEEPER_SYNC_LIMIT	5
public static final String	DELIMITED_FORMAT_MAX_LINE_SAMPLES_KEY	"compiler.delimited-informat.max-line-samples"
public static final String	DELIMITED_FORMAT_MAX_SAMPLE_LENGTH_KEY	"compiler.delimited-informat.max-sample-len"
public static final String	DELIMITED_FORMAT_MIN_LINE_SAMPLES_KEY	"compiler.delimited-informat.min-line-samples"
public static final String	ENV_FLINK_BIN_DIR	"FLINK_BIN_DIR"
public static final String	ENV_FLINK_CONF_DIR	"FLINK_CONF_DIR"
public static final String	ENV_FLINK_HOME_DIR	"FLINK_HOME"
public static final String	ENV_FLINK_LIB_DIR	"FLINK_LIB_DIR"
public static final String	ENV_FLINK_OPT_DIR	"FLINK_OPT_DIR"
public static final String	ENV_FLINK_PLUGINS_DIR	"FLINK_PLUGINS_DIR"
public static final String	EXECUTION_RETRIES_KEY	"execution-retries.default"
public static final String	EXECUTION_RETRY_DELAY_KEY	"execution-retries.delay"
public static final String	FILESYSTEM_DEFAULT_OVERWRITE_KEY	"fs.overwrite-files"
public static final String	FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY_KEY	"fs.output.always-create-directory"
public static final String	FILESYSTEM_SCHEME	"fs.default-scheme"
public static final String	FLINK_BASE_DIR_PATH_KEY	"flink.base.dir.path"
public static final String	FLINK_JVM_OPTIONS	"env.java.opts"
public static final String	FS_STREAM_OPENING_TIMEOUT_KEY	"taskmanager.runtime.fs_timeout"
public static final String	HA_JOB_MANAGER_PORT	"high-availability.jobmanager.port"
public static final String	HA_MODE	"high-availability"
public static final String	HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH	"high-availability.zookeeper.path.checkpoint-counter"
public static final String	HA_ZOOKEEPER_CHECKPOINTS_PATH	"high-availability.zookeeper.path.checkpoints"
public static final String	HA_ZOOKEEPER_CLIENT_ACL	"high-availability.zookeeper.client.acl"
public static final String	HA_ZOOKEEPER_CONNECTION_TIMEOUT	"high-availability.zookeeper.client.connection-timeout"
public static final String	HA_ZOOKEEPER_DIR_KEY	"high-availability.zookeeper.path.root"
public static final String	HA_ZOOKEEPER_JOBGRAPHS_PATH	"high-availability.zookeeper.path.jobgraphs"
public static final String	HA_ZOOKEEPER_LATCH_PATH	"high-availability.zookeeper.path.latch"
public static final String	HA_ZOOKEEPER_LEADER_PATH	"high-availability.zookeeper.path.leader"
public static final String	HA_ZOOKEEPER_MAX_RETRY_ATTEMPTS	"high-availability.zookeeper.client.max-retry-attempts"
public static final String	HA_ZOOKEEPER_MESOS_WORKERS_PATH	"high-availability.zookeeper.path.mesos-workers"
public static final String	HA_ZOOKEEPER_NAMESPACE_KEY	"high-availability.zookeeper.path.namespace"
public static final String	HA_ZOOKEEPER_QUORUM_KEY	"high-availability.zookeeper.quorum"
public static final String	HA_ZOOKEEPER_RETRY_WAIT	"high-availability.zookeeper.client.retry-wait"
public static final String	HA_ZOOKEEPER_SESSION_TIMEOUT	"high-availability.zookeeper.client.session-timeout"
public static final String	HA_ZOOKEEPER_STORAGE_PATH	"high-availability.zookeeper.storageDir"
public static final String	HDFS_DEFAULT_CONFIG	"fs.hdfs.hdfsdefault"
public static final String	HDFS_SITE_CONFIG	"fs.hdfs.hdfssite"
public static final String	JOB_MANAGER_IPC_ADDRESS_KEY	"jobmanager.rpc.address"
public static final String	JOB_MANAGER_IPC_PORT_KEY	"jobmanager.rpc.port"
public static final String	JOB_MANAGER_WEB_ARCHIVE_COUNT	"jobmanager.web.history"
public static final String	JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL	"jobmanager.web.backpressure.cleanup-interval"
public static final String	JOB_MANAGER_WEB_BACK_PRESSURE_DELAY	"jobmanager.web.backpressure.delay-between-samples"
public static final String	JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES	"jobmanager.web.backpressure.num-samples"
public static final String	JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL	"jobmanager.web.backpressure.refresh-interval"
public static final String	JOB_MANAGER_WEB_CHECKPOINTS_DISABLE	"jobmanager.web.checkpoints.disable"
public static final String	JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE	"jobmanager.web.checkpoints.history"
public static final String	JOB_MANAGER_WEB_LOG_PATH_KEY	"jobmanager.web.log.path"
public static final String	JOB_MANAGER_WEB_PORT_KEY	"jobmanager.web.port"
public static final String	JOB_MANAGER_WEB_SSL_ENABLED	"jobmanager.web.ssl.enabled"
public static final String	JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY	"jobmanager.web.submit.enable"
public static final String	JOB_MANAGER_WEB_TMPDIR_KEY	"jobmanager.web.tmpdir"
public static final String	JOB_MANAGER_WEB_UPLOAD_DIR_KEY	"jobmanager.web.upload.dir"
public static final String	LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL	"library-cache-manager.cleanup.interval"
public static final String	LOCAL_NUMBER_JOB_MANAGER	"local.number-jobmanager"
public static final String	LOCAL_NUMBER_RESOURCE_MANAGER	"local.number-resourcemanager"
public static final String	LOCAL_NUMBER_TASK_MANAGER	"local.number-taskmanager"
public static final String	LOCAL_START_WEBSERVER	"local.start-webserver"
public static final String	MESOS_ARTIFACT_SERVER_PORT_KEY	"mesos.resourcemanager.artifactserver.port"
public static final String	MESOS_ARTIFACT_SERVER_SSL_ENABLED	"mesos.resourcemanager.artifactserver.ssl.enabled"
public static final String	MESOS_FAILOVER_TIMEOUT_SECONDS	"mesos.failover-timeout"
public static final String	MESOS_INITIAL_TASKS	"mesos.initial-tasks"
public static final String	MESOS_MASTER_URL	"mesos.master"
public static final String	MESOS_MAX_FAILED_TASKS	"mesos.maximum-failed-tasks"
public static final String	MESOS_RESOURCEMANAGER_FRAMEWORK_NAME	"mesos.resourcemanager.framework.name"
public static final String	MESOS_RESOURCEMANAGER_FRAMEWORK_PRINCIPAL	"mesos.resourcemanager.framework.principal"
public static final String	MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE	"mesos.resourcemanager.framework.role"
public static final String	MESOS_RESOURCEMANAGER_FRAMEWORK_SECRET	"mesos.resourcemanager.framework.secret"
public static final String	MESOS_RESOURCEMANAGER_FRAMEWORK_USER	"mesos.resourcemanager.framework.user"
public static final String	METRICS_LATENCY_HISTORY_SIZE	"metrics.latency.history-size"
public static final String	METRICS_REPORTER_CLASS_SUFFIX	"class"
public static final String	METRICS_REPORTER_EXCLUDED_VARIABLES	"scope.variables.excludes"
public static final String	METRICS_REPORTER_FACTORY_CLASS_SUFFIX	"factory.class"
public static final String	METRICS_REPORTER_INTERVAL_SUFFIX	"interval"
public static final String	METRICS_REPORTER_PREFIX	"metrics.reporter."
public static final String	METRICS_REPORTER_SCOPE_DELIMITER	"scope.delimiter"
public static final String	METRICS_REPORTERS_LIST	"metrics.reporters"
public static final String	METRICS_SCOPE_DELIMITER	"metrics.scope.delimiter"
public static final String	METRICS_SCOPE_NAMING_JM	"metrics.scope.jm"
public static final String	METRICS_SCOPE_NAMING_JM_JOB	"metrics.scope.jm.job"
public static final String	METRICS_SCOPE_NAMING_OPERATOR	"metrics.scope.operator"
public static final String	METRICS_SCOPE_NAMING_TASK	"metrics.scope.task"
public static final String	METRICS_SCOPE_NAMING_TM	"metrics.scope.tm"
public static final String	METRICS_SCOPE_NAMING_TM_JOB	"metrics.scope.tm.job"
public static final String	PATH_HADOOP_CONFIG	"fs.hdfs.hadoopconf"
public static final String	RECOVERY_JOB_DELAY	"recovery.job.delay"
public static final String	RECOVERY_JOB_MANAGER_PORT	"recovery.jobmanager.port"
public static final String	RECOVERY_MODE	"recovery.mode"
public static final String	RESOURCE_MANAGER_IPC_PORT_KEY	"resourcemanager.rpc.port"
public static final String	RESTART_STRATEGY	"restart-strategy"
public static final String	RESTART_STRATEGY_FAILURE_RATE_DELAY	"restart-strategy.failure-rate.delay"
public static final String	RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL	"restart-strategy.failure-rate.failure-rate-interval"
public static final String	RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL	"restart-strategy.failure-rate.max-failures-per-interval"
public static final String	RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS	"restart-strategy.fixed-delay.attempts"
public static final String	RUNTIME_HASH_JOIN_BLOOM_FILTERS_KEY	"taskmanager.runtime.hashjoin-bloom-filters"
public static final String	SAVEPOINT_DIRECTORY_KEY	"state.savepoints.dir"
public static final String	SAVEPOINT_FS_DIRECTORY_KEY	"savepoints.state.backend.fs.dir"
public static final String	SECURITY_SSL_ALGORITHMS	"security.ssl.algorithms"
public static final String	SECURITY_SSL_ENABLED	"security.ssl.enabled"
public static final String	SECURITY_SSL_KEY_PASSWORD	"security.ssl.key-password"
public static final String	SECURITY_SSL_KEYSTORE	"security.ssl.keystore"
public static final String	SECURITY_SSL_KEYSTORE_PASSWORD	"security.ssl.keystore-password"
public static final String	SECURITY_SSL_PROTOCOL	"security.ssl.protocol"
public static final String	SECURITY_SSL_TRUSTSTORE	"security.ssl.truststore"
public static final String	SECURITY_SSL_TRUSTSTORE_PASSWORD	"security.ssl.truststore-password"
public static final String	SECURITY_SSL_VERIFY_HOSTNAME	"security.ssl.verify-hostname"
public static final String	STATE_BACKEND	"state.backend"
public static final String	TASK_CANCELLATION_INTERVAL_MILLIS	"task.cancellation-interval"
public static final String	TASK_MANAGER_DATA_PORT_KEY	"taskmanager.data.port"
public static final String	TASK_MANAGER_DATA_SSL_ENABLED	"taskmanager.data.ssl.enabled"
public static final String	TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS	"taskmanager.debug.memory.logIntervalMs"
public static final String	TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD	"taskmanager.debug.memory.startLogThread"
public static final String	TASK_MANAGER_HOSTNAME_KEY	"taskmanager.hostname"
public static final String	TASK_MANAGER_INITIAL_REGISTRATION_PAUSE	"taskmanager.initial-registration-pause"
public static final String	TASK_MANAGER_IPC_PORT_KEY	"taskmanager.rpc.port"
public static final String	TASK_MANAGER_LOG_PATH_KEY	"taskmanager.log.path"
public static final String	TASK_MANAGER_MAX_REGISTARTION_PAUSE	"taskmanager.max-registration-pause"
public static final String	TASK_MANAGER_MAX_REGISTRATION_DURATION	"taskmanager.maxRegistrationDuration"
public static final String	TASK_MANAGER_MEMORY_FRACTION_KEY	"taskmanager.memory.fraction"
public static final String	TASK_MANAGER_MEMORY_OFF_HEAP_KEY	"taskmanager.memory.off-heap"
public static final String	TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY	"taskmanager.memory.preallocate"
public static final String	TASK_MANAGER_MEMORY_SEGMENT_SIZE_KEY	"taskmanager.memory.segment-size"
public static final String	TASK_MANAGER_MEMORY_SIZE_KEY	"taskmanager.memory.size"
public static final String	TASK_MANAGER_NETWORK_DEFAULT_IO_MODE	"taskmanager.network.defaultIOMode"
public static final String	TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY	"taskmanager.network.numberOfBuffers"
public static final String	TASK_MANAGER_NUM_TASK_SLOTS	"taskmanager.numberOfTaskSlots"
public static final String	TASK_MANAGER_REFUSED_REGISTRATION_PAUSE	"taskmanager.refused-registration-pause"
public static final String	TASK_MANAGER_TMP_DIR_KEY	"taskmanager.tmp.dirs"
public static final String	USE_LARGE_RECORD_HANDLER_KEY	"taskmanager.runtime.large-record-handler"
public static final String	YARN_APPLICATION_ATTEMPTS	"yarn.application-attempts"
public static final String	YARN_APPLICATION_MASTER_ENV_PREFIX	"yarn.application-master.env."
public static final String	YARN_APPLICATION_MASTER_PORT	"yarn.application-master.port"
public static final String	YARN_APPLICATION_TAGS	"yarn.tags"
public static final String	YARN_CONTAINER_START_COMMAND_TEMPLATE	"yarn.container-start-command-template"
public static final String	YARN_HEAP_CUTOFF_MIN	"yarn.heap-cutoff-min"
public static final String	YARN_HEAP_CUTOFF_RATIO	"yarn.heap-cutoff-ratio"
public static final String	YARN_HEARTBEAT_DELAY_SECONDS	"yarn.heartbeat-delay"
public static final String	YARN_MAX_FAILED_CONTAINERS	"yarn.maximum-failed-containers"
public static final String	YARN_PROPERTIES_FILE_LOCATION	"yarn.properties-file.location"
public static final String	YARN_REALLOCATE_FAILED_CONTAINERS	"yarn.reallocate-failed"
public static final String	YARN_TASK_MANAGER_ENV_PREFIX	"yarn.taskmanager.env."
public static final String	YARN_VCORES	"yarn.containers.vcores"
public static final String	ZOOKEEPER_CHECKPOINT_COUNTER_PATH	"recovery.zookeeper.path.checkpoint-counter"
public static final String	ZOOKEEPER_CHECKPOINTS_PATH	"recovery.zookeeper.path.checkpoints"
public static final String	ZOOKEEPER_CONNECTION_TIMEOUT	"recovery.zookeeper.client.connection-timeout"
public static final String	ZOOKEEPER_DIR_KEY	"recovery.zookeeper.path.root"
public static final String	ZOOKEEPER_JOBGRAPHS_PATH	"recovery.zookeeper.path.jobgraphs"
public static final String	ZOOKEEPER_LATCH_PATH	"recovery.zookeeper.path.latch"
public static final String	ZOOKEEPER_LEADER_PATH	"recovery.zookeeper.path.leader"
public static final String	ZOOKEEPER_MAX_RETRY_ATTEMPTS	"recovery.zookeeper.client.max-retry-attempts"
public static final String	ZOOKEEPER_MESOS_WORKERS_PATH	"recovery.zookeeper.path.mesos-workers"
public static final String	ZOOKEEPER_NAMESPACE_KEY	"recovery.zookeeper.path.namespace"
public static final String	ZOOKEEPER_QUORUM_KEY	"recovery.zookeeper.quorum"
public static final String	ZOOKEEPER_RECOVERY_PATH	"recovery.zookeeper.storageDir"
public static final String	ZOOKEEPER_RETRY_WAIT	"recovery.zookeeper.client.retry-wait"
public static final String	ZOOKEEPER_SASL_DISABLE	"zookeeper.sasl.disable"
public static final String	ZOOKEEPER_SASL_SERVICE_NAME	"zookeeper.sasl.service-name"
public static final String	ZOOKEEPER_SESSION_TIMEOUT	"recovery.zookeeper.client.session-timeout"

org.apache.flink.configuration.CoreOptions

Modifier and Type	Constant Field	Value
public static final String	PARENT_FIRST_LOGGING_PATTERNS	"org.slf4j;org.apache.log4j;org.apache.logging;org.apache.commons.logging;ch.qos.logback"

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	"flink-conf.yaml"
public static final String	HIDDEN_CONTENT	"******"

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.TaskManagerOptions

Modifier and Type	Constant Field	Value
public static final String	MANAGED_MEMORY_CONSUMER_NAME_DATAPROC	"DATAPROC"
public static final String	MANAGED_MEMORY_CONSUMER_NAME_OPERATOR	"OPERATOR"
public static final String	MANAGED_MEMORY_CONSUMER_NAME_PYTHON	"PYTHON"
public static final String	MANAGED_MEMORY_CONSUMER_NAME_STATE_BACKEND	"STATE_BACKEND"

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	MIN	"min"
public static final String	RANDOM	"random"
public static final String	SEQUENCE	"sequence"
public static final String	START	"start"

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_STRING_LENGTH_DEFAULT	100

org.apache.flink.connector.file.src.reader.TextLineFormat

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.hbase.table.HBaseConnectorOptionsUtil

Modifier and Type	Constant Field	Value
public static final String	PROPERTIES_PREFIX	"properties."

org.apache.flink.connector.hbase.util.HBaseConfigurationUtil

Modifier and Type	Constant Field	Value
public static final String	ENV_HBASE_CONF_DIR	"HBASE_CONF_DIR"

org.apache.flink.connector.jdbc.JdbcExactlyOnceOptions

Modifier and Type	Constant Field	Value
public static final boolean	DEFAULT_TRANSACTION_PER_CONNECTION	false

org.apache.flink.connector.jdbc.JdbcExecutionOptions

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_RETRY_TIMES	3
public static final int	DEFAULT_SIZE	5000

org.apache.flink.connector.jdbc.JdbcInputFormat

Modifier and Type	Constant Field	Value
protected static final long	serialVersionUID	2L

org.apache.flink.connector.jdbc.catalog.PostgresCatalog

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DATABASE	"postgres"
public static final String	PG_BIGINT	"int8"
public static final String	PG_BIGINT_ARRAY	"_int8"
public static final String	PG_BIGSERIAL	"bigserial"
public static final String	PG_BOOLEAN	"bool"
public static final String	PG_BOOLEAN_ARRAY	"_bool"
public static final String	PG_BYTEA	"bytea"
public static final String	PG_BYTEA_ARRAY	"_bytea"
public static final String	PG_CHAR	"bpchar"
public static final String	PG_CHAR_ARRAY	"_bpchar"
public static final String	PG_CHARACTER	"character"
public static final String	PG_CHARACTER_ARRAY	"_character"
public static final String	PG_CHARACTER_VARYING	"varchar"
public static final String	PG_CHARACTER_VARYING_ARRAY	"_varchar"
public static final String	PG_DATE	"date"
public static final String	PG_DATE_ARRAY	"_date"
public static final String	PG_DOUBLE_PRECISION	"float8"
public static final String	PG_DOUBLE_PRECISION_ARRAY	"_float8"
public static final String	PG_INTEGER	"int4"
public static final String	PG_INTEGER_ARRAY	"_int4"
public static final String	PG_NUMERIC	"numeric"
public static final String	PG_NUMERIC_ARRAY	"_numeric"
public static final String	PG_REAL	"float4"
public static final String	PG_REAL_ARRAY	"_float4"
public static final String	PG_SERIAL	"serial"
public static final String	PG_SMALLINT	"int2"
public static final String	PG_SMALLINT_ARRAY	"_int2"
public static final String	PG_TEXT	"text"
public static final String	PG_TEXT_ARRAY	"_text"
public static final String	PG_TIME	"time"
public static final String	PG_TIME_ARRAY	"_time"
public static final String	PG_TIMESTAMP	"timestamp"
public static final String	PG_TIMESTAMP_ARRAY	"_timestamp"
public static final String	PG_TIMESTAMPTZ	"timestamptz"
public static final String	PG_TIMESTAMPTZ_ARRAY	"_timestamptz"

org.apache.flink.connector.jdbc.catalog.factory.JdbcCatalogFactoryOptions

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"jdbc"

org.apache.flink.connector.jdbc.internal.JdbcOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_FLUSH_INTERVAL_MILLS	0L
public static final int	DEFAULT_FLUSH_MAX_SIZE	5000

org.apache.flink.connector.jdbc.table.JdbcDynamicTableFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"jdbc"

org.apache.flink.connector.kafka.source.metrics.KafkaSourceReaderMetrics

Modifier and Type	Constant Field	Value
public static final String	BYTES_CONSUMED_TOTAL	"bytes-consumed-total"
public static final String	COMMITS_FAILED_METRIC_COUNTER	"commitsFailed"
public static final String	COMMITS_SUCCEEDED_METRIC_COUNTER	"commitsSucceeded"
public static final String	COMMITTED_OFFSET_METRIC_GAUGE	"committedOffset"
public static final String	CONSUMER_FETCH_MANAGER_GROUP	"consumer-fetch-manager-metrics"
public static final String	CURRENT_OFFSET_METRIC_GAUGE	"currentOffset"
public static final long	INITIAL_OFFSET	-1L
public static final String	KAFKA_CONSUMER_METRIC_GROUP	"KafkaConsumer"
public static final String	KAFKA_SOURCE_READER_METRIC_GROUP	"KafkaSourceReader"
public static final String	PARTITION_GROUP	"partition"
public static final String	RECORDS_LAG	"records-lag"
public static final String	TOPIC_GROUP	"topic"

org.apache.flink.connector.kafka.source.split.KafkaPartitionSplit

Modifier and Type	Constant Field	Value
public static final long	COMMITTED_OFFSET	-3L
public static final long	EARLIEST_OFFSET	-2L
public static final long	LATEST_OFFSET	-1L
public static final long	NO_STOPPING_OFFSET	-9223372036854775808L

org.apache.flink.connector.print.table.PrintTableSinkFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"print"

org.apache.flink.connector.pulsar.common.config.PulsarOptions

Modifier and Type	Constant Field	Value
public static final String	ADMIN_CONFIG_PREFIX	"pulsar.admin."
public static final String	CLIENT_CONFIG_PREFIX	"pulsar.client."

org.apache.flink.connector.pulsar.common.schema.PulsarSchemaUtils

Modifier and Type	Constant Field	Value
public static final String	CLASS_INFO_PLACEHOLDER	"INTERNAL.pulsar.schema.type.class.name"

org.apache.flink.connector.pulsar.source.PulsarSourceOptions

Modifier and Type	Constant Field	Value
public static final String	CONSUMER_CONFIG_PREFIX	"pulsar.consumer."
public static final String	SOURCE_CONFIG_PREFIX	"pulsar.source."

org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumStateSerializer

Modifier and Type	Constant Field	Value
public static final int	CURRENT_VERSION	1

org.apache.flink.connector.pulsar.source.enumerator.topic.TopicRange

Modifier and Type	Constant Field	Value
public static final int	MAX_RANGE	65535
public static final int	MIN_RANGE	0
public static final int	RANGE_SIZE	65536

org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplitSerializer

Modifier and Type	Constant Field	Value
public static final int	CURRENT_VERSION	0

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.connectors.test.common.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	TEST_ENV_STORE_KEY	"testEnvironment"

org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend<K>

Modifier and Type	Constant Field	Value
public static final String	MERGE_OPERATOR_NAME	"stringappendtest"

org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions

Modifier and Type	Constant Field	Value
public static final String	METRICS_COLUMN_FAMILY_AS_VARIABLE_KEY	"state.backend.rocksdb.metrics.column-family-as-variable"

org.apache.flink.contrib.streaming.state.snapshot.RocksSnapshotUtil

Modifier and Type	Constant Field	Value
public static final String	SST_FILE_SUFFIX	".sst"

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.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.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.examples.java.distcp.DistCp

Modifier and Type	Constant Field	Value
public static final String	BYTES_COPIED_CNT_NAME	"BYTES_COPIED"
public static final String	FILES_COPIED_CNT_NAME	"FILES_COPIED"

org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

Modifier and Type	Constant Field	Value
public static final int	V1	0
public static final int	V2	1

org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

Modifier and Type	Constant Field	Value
public static final int	D1	2
public static final int	D2	3
public static final int	V1	0
public static final int	V2	1

org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad

Modifier and Type	Constant Field	Value
public static final int	V1	0
public static final int	V2	1
public static final int	V3	2

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.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	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	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.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	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	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	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	KEY_TYPE_INFO_FIELD_NUMBER	5
public static final int	METRIC_ENABLED_FIELD_NUMBER	4
public static final int	PAYLOAD_FIELD_NUMBER	3
public static final int	PROFILE_ENABLED_FIELD_NUMBER	6
public static final int	RUNTIME_CONTEXT_FIELD_NUMBER	2

org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.FunctionType

Modifier and Type	Constant Field	Value
public static final int	CO_PROCESS_VALUE	1
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.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.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	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.AvroFileSystemFormatFactory

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.csv.CsvFileSystemFormatFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"csv"

org.apache.flink.formats.csv.CsvFormatFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"csv"

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.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.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.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.utils.RefCountedBufferingFileStream

Modifier and Type	Constant Field	Value
public static final int	BUFFER_SIZE	4096

org.apache.flink.graph.asm.translate.translators.LongValueToSignedIntValue

Modifier and Type	Constant Field	Value
public static final long	MAX_VERTEX_COUNT	4294967296L

org.apache.flink.graph.asm.translate.translators.LongValueToUnsignedIntValue

Modifier and Type	Constant Field	Value
public static final long	MAX_VERTEX_COUNT	4294967296L

org.apache.flink.graph.examples.data.CommunityDetectionData

Modifier and Type	Constant Field	Value
public static final String	COMMUNITIES_SINGLE_ITERATION	"1,5\n2,6\n3,1\n4,1\n5,1\n6,8\n7,8\n8,7"
public static final String	COMMUNITIES_WITH_TIE	"1,2\n2,1\n3,1\n4,1\n5,1"
public static final double	DELTA	0.5

org.apache.flink.graph.examples.data.ConnectedComponentsDefaultData

Modifier and Type	Constant Field	Value
public static final String	EDGES	"1\t2\n2\t3\n2\t4\n3\t4"
public static final String	VERTICES_WITH_MIN_ID	"1,1\n2,1\n3,1\n4,1"

org.apache.flink.graph.examples.data.EuclideanGraphData

Modifier and Type	Constant Field	Value
public static final String	EDGES	"1,2\n1,4\n2,3\n2,4\n2,5\n3,5\n4,5\n4,6\n5,7\n5,9\n6,7\n6,8\n7,8\n7,9\n8,9"
public static final int	NUM_VERTICES	9
public static final String	RESULTED_WEIGHTED_EDGES	"1,2,1.4142135623730951\n1,4,4.242640687119285\n2,3,1.4142135623730951\n2,4,2.8284271247461903\n2,5,4.242640687119285\n3,5,2.8284271247461903\n4,5,1.4142135623730951\n4,6,2.8284271247461903\n5,7,2.8284271247461903\n5,9,5.656854249492381\n6,7,1.4142135623730951\n6,8,2.8284271247461903\n7,8,1.4142135623730951\n7,9,2.8284271247461903\n8,9,1.4142135623730951"
public static final String	VERTICES	"1,1.0,1.0\n2,2.0,2.0\n3,3.0,3.0\n4,4.0,4.0\n5,5.0,5.0\n6,6.0,6.0\n7,7.0,7.0\n8,8.0,8.0\n9,9.0,9.0"

org.apache.flink.graph.examples.data.IncrementalSSSPData

Modifier and Type	Constant Field	Value
public static final String	EDGES	"1,3,3.0\n2,4,3.0\n2,5,2.0\n3,2,1.0\n3,5,5.0\n4,5,1.0"
public static final String	EDGES_IN_SSSP	"1,3,3.0\n2,5,2.0\n3,2,1.0\n4,5,1.0"
public static final int	NUM_VERTICES	5
public static final String	RESULTED_VERTICES	"1,1.7976931348623157E308\n2,1.7976931348623157E308\n3,1.7976931348623157E308\n4,1.0\n5,0.0"
public static final String	SRC_EDGE_TO_BE_REMOVED	"2"
public static final String	TRG_EDGE_TO_BE_REMOVED	"5"
public static final String	VAL_EDGE_TO_BE_REMOVED	"2.0"
public static final String	VERTICES	"1,6.0\n2,2.0\n3,3.0\n4,1.0\n5,0.0"

org.apache.flink.graph.examples.data.LabelPropagationData

Modifier and Type	Constant Field	Value
public static final String	LABELS_AFTER_1_ITERATION	"1,10\n2,10\n3,10\n4,40\n5,40\n6,40\n7,40\n"
public static final String	LABELS_WITH_TIE	"1,10\n2,10\n3,10\n4,10\n5,20\n6,20\n7,20\n8,20\n9,20\n"

org.apache.flink.graph.examples.data.MusicProfilesData

Modifier and Type	Constant Field	Value
public static final String	COMMUNITIES_RESULT	"user_1\t1\nuser_2\t1\nuser_3\t3\nuser_4\t3\nuser_5\t4"
public static final String	MAX_ITERATIONS	"2"
public static final String	MISMATCHES	"ERROR: <song_5 track_8> Angie"
public static final String	TOP_SONGS_RESULT	"user_1\tsong_1\nuser_2\tsong_4\nuser_3\tsong_2\nuser_4\tsong_3\nuser_5\tsong_3"
public static final String	USER_SONG_TRIPLETS	"user_1\tsong_1\t100\nuser_1\tsong_5\t200\nuser_2\tsong_1\t10\nuser_2\tsong_4\t20\nuser_3\tsong_2\t3\nuser_4\tsong_2\t1\nuser_4\tsong_3\t2\nuser_5\tsong_3\t30"

org.apache.flink.graph.examples.data.PageRankData

Modifier and Type	Constant Field	Value
public static final String	EDGES	"2\t1\n5\t2\n5\t4\n4\t3\n4\t2\n1\t4\n1\t2\n1\t3\n3\t5\n"
public static final String	RANKS_AFTER_3_ITERATIONS	"1,0.237\n2,0.248\n3,0.173\n4,0.175\n5,0.165\n"

org.apache.flink.graph.examples.data.SingleSourceShortestPathsData

Modifier and Type	Constant Field	Value
public static final String	EDGES	"1\t2\t12.0\n1\t3\t13.0\n2\t3\t23.0\n3\t4\t34.0\n3\t5\t35.0\n4\t5\t45.0\n5\t1\t51.0"
public static final String	RESULTED_SINGLE_SOURCE_SHORTEST_PATHS	"1,0.0\n2,12.0\n3,13.0\n4,47.0\n5,48.0"

org.apache.flink.graph.examples.data.TriangleCountData

Modifier and Type	Constant Field	Value
public static final String	EDGES	"1\t2\n1\t3\n2\t3\n2\t6\n3\t4\n3\t5\n3\t6\n4\t5\n6\t7\n"
public static final String	RESULTED_NUMBER_OF_TRIANGLES	"3"

org.apache.flink.graph.generator.CirculantGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_OFFSET	1
public static final int	MINIMUM_VERTEX_COUNT	2

org.apache.flink.graph.generator.CompleteGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_VERTEX_COUNT	2

org.apache.flink.graph.generator.CycleGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_VERTEX_COUNT	2

org.apache.flink.graph.generator.EchoGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_VERTEX_COUNT	2
public static final int	MINIMUM_VERTEX_DEGREE	1

org.apache.flink.graph.generator.EmptyGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_VERTEX_COUNT	0

org.apache.flink.graph.generator.HypercubeGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_DIMENSIONS	1

org.apache.flink.graph.generator.PathGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_VERTEX_COUNT	2

org.apache.flink.graph.generator.RMatGraph<T extends org.apache.commons.math3.random.RandomGenerator>

Modifier and Type	Constant Field	Value
public static final float	DEFAULT_A	0.5699999928474426f
public static final float	DEFAULT_B	0.1899999976158142f
public static final float	DEFAULT_C	0.1899999976158142f
public static final float	DEFAULT_NOISE	0.10000000149011612f
public static final int	MINIMUM_EDGE_COUNT	1
public static final int	MINIMUM_VERTEX_COUNT	1

org.apache.flink.graph.generator.SingletonEdgeGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_VERTEX_PAIR_COUNT	1

org.apache.flink.graph.generator.StarGraph

Modifier and Type	Constant Field	Value
public static final int	MINIMUM_VERTEX_COUNT	2

org.apache.flink.graph.generator.random.GeneratorFactoryBase<T extends org.apache.commons.math3.random.RandomGenerator>

Modifier and Type	Constant Field	Value
public static final int	MAXIMUM_BLOCK_COUNT	32768

org.apache.flink.graph.generator.random.JDKRandomGeneratorFactory

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_SEED	5435701917232523172L
public static final int	MINIMUM_CYCLES_PER_BLOCK	1048576

org.apache.flink.graph.generator.random.MersenneTwisterFactory

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_SEED	8415200798306848441L
public static final int	MINIMUM_CYCLES_PER_BLOCK	1048576

org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees<K>

Modifier and Type	Constant Field	Value
public static final int	D1	2
public static final int	D2	3
public static final int	V1	0
public static final int	V2	1

org.apache.flink.graph.library.TriangleEnumerator.Triad<K>

Modifier and Type	Constant Field	Value
public static final int	V1	0
public static final int	V2	1
public static final int	V3	2

org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result<T>

Modifier and Type	Constant Field	Value
public static final int	HASH_SEED	933365956

org.apache.flink.graph.library.clustering.directed.TriangleListing.Result<T>

Modifier and Type	Constant Field	Value
public static final int	HASH_SEED	138865185

org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result<T>

Modifier and Type	Constant Field	Value
public static final int	HASH_SEED	-1036437567

org.apache.flink.graph.library.clustering.undirected.TriangleListing.Result<T>

Modifier and Type	Constant Field	Value
public static final int	HASH_SEED	-744500821

org.apache.flink.graph.library.linkanalysis.HITS.Result<T>

Modifier and Type	Constant Field	Value
public static final int	HASH_SEED	1074835241

org.apache.flink.graph.library.linkanalysis.PageRank.Result<T>

Modifier and Type	Constant Field	Value
public static final int	HASH_SEED	1074835241

org.apache.flink.graph.library.similarity.AdamicAdar.Result<T>

Modifier and Type	Constant Field	Value
public static final int	HASH_SEED	-469371183

org.apache.flink.graph.library.similarity.JaccardIndex<K extends CopyableValue<K>,VV,EV>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_GROUP_SIZE	64

org.apache.flink.graph.library.similarity.JaccardIndex.Result<T>

Modifier and Type	Constant Field	Value
public static final int	HASH_SEED	1931441127

org.apache.flink.graph.types.valuearray.ByteValueArray

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_CAPACITY_IN_BYTES	1024
protected static final int	ELEMENT_LENGTH_IN_BYTES	1

org.apache.flink.graph.types.valuearray.CharValueArray

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_CAPACITY_IN_BYTES	1024
protected static final int	ELEMENT_LENGTH_IN_BYTES	2

org.apache.flink.graph.types.valuearray.DoubleValueArray

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_CAPACITY_IN_BYTES	1024
protected static final int	ELEMENT_LENGTH_IN_BYTES	8

org.apache.flink.graph.types.valuearray.FloatValueArray

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_CAPACITY_IN_BYTES	1024
protected static final int	ELEMENT_LENGTH_IN_BYTES	4

org.apache.flink.graph.types.valuearray.IntValueArray

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_CAPACITY_IN_BYTES	4096
protected static final int	ELEMENT_LENGTH_IN_BYTES	4

org.apache.flink.graph.types.valuearray.LongValueArray

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_CAPACITY_IN_BYTES	4096
protected static final int	ELEMENT_LENGTH_IN_BYTES	8

org.apache.flink.graph.types.valuearray.ShortValueArray

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_CAPACITY_IN_BYTES	1024
protected static final int	ELEMENT_LENGTH_IN_BYTES	2

org.apache.flink.graph.types.valuearray.StringValueArray

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_CAPACITY_IN_BYTES	4096
protected static final int	HIGH_BIT	128

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	ENV_FLINK_LOG_DIR	"FLINK_LOG_DIR"
public static final String	ENV_FLINK_POD_IP_ADDRESS	"_POD_IP_ADDRESS"
public static final String	ENV_HADOOP_CONF_DIR	"HADOOP_CONF_DIR"
public static final String	ENV_HADOOP_HOME	"HADOOP_HOME"
public static final String	ENV_TM_JVM_MEM_OPTS	"FLINK_TM_JVM_MEM_OPTS"
public static final String	FLINK_CONF_VOLUME	"flink-config-volume"
public static final String	FLINK_REST_SERVICE_SUFFIX	"-rest"
public static final String	HADOOP_CONF_CONFIG_MAP_PREFIX	"hadoop-config-"
public static final String	HADOOP_CONF_DIR_IN_POD	"/opt/hadoop/conf"
public static final String	HADOOP_CONF_VOLUME	"hadoop-config-volume"
public static final String	JOB_GRAPH_STORE_KEY_PREFIX	"jobGraph-"
public static final String	JOB_MANAGER_RPC_PORT_NAME	"jobmanager-rpc"
public static final String	KERBEROS_KEYTAB_MOUNT_POINT	"/opt/kerberos/kerberos-keytab"
public static final String	KERBEROS_KEYTAB_SECRET_PREFIX	"kerberos-keytab-"
public static final String	KERBEROS_KEYTAB_VOLUME	"kerberos-keytab-volume"
public static final String	KERBEROS_KRB5CONF_CONFIG_MAP_PREFIX	"kerberos-krb5conf-"
public static final String	KERBEROS_KRB5CONF_FILE	"krb5.conf"
public static final String	KERBEROS_KRB5CONF_MOUNT_DIR	"/etc"
public static final String	KERBEROS_KRB5CONF_VOLUME	"kerberos-krb5conf-volume"
public static final String	KUBERNETES_JOB_MANAGER_SCRIPT_PATH	"kubernetes-jobmanager.sh"
public static final String	KUBERNETES_TASK_MANAGER_SCRIPT_PATH	"kubernetes-taskmanager.sh"
public static final String	LABEL_APP_KEY	"app"
public static final String	LABEL_COMPONENT_JOB_MANAGER	"jobmanager"
public static final String	LABEL_COMPONENT_KEY	"component"
public static final String	LABEL_COMPONENT_TASK_MANAGER	"taskmanager"
public static final String	LABEL_CONFIGMAP_TYPE_HIGH_AVAILABILITY	"high-availability"
public static final String	LABEL_CONFIGMAP_TYPE_KEY	"configmap-type"
public static final String	LABEL_TYPE_KEY	"type"
public static final String	LABEL_TYPE_NATIVE_TYPE	"flink-native-kubernetes"
public static final String	LEADER_ADDRESS_KEY	"address"
public static final String	LEADER_SESSION_ID_KEY	"sessionId"
public static final String	MAIN_CONTAINER_NAME	"flink-main-container"
public static final int	MAXIMUM_CHARACTERS_OF_CLUSTER_ID	45
public static final String	NAME_SEPARATOR	"-"
public static final String	POD_IP_FIELD_PATH	"status.podIP"
public static final String	POD_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	RUNNING_JOBS_REGISTRY_KEY_PREFIX	"runningJobsRegistry-"
public static final String	SUBMITTED_JOBGRAPH_FILE_PREFIX	"submittedJobGraph"
public static final String	TASK_MANAGER_POD_TEMPLATE_FILE_NAME	"taskmanager-pod-template.yaml"
public static final int	TASK_MANAGER_RPC_PORT	6122
public static final String	TASK_MANAGER_RPC_PORT_NAME	"taskmanager-rpc"

org.apache.flink.metrics.View

Modifier and Type	Constant Field	Value
public static final int	UPDATE_INTERVAL_SECONDS	5

org.apache.flink.metrics.datadog.DatadogHttpReporter

Modifier and Type	Constant Field	Value
public static final String	API_KEY	"apikey"
public static final String	DATA_CENTER	"dataCenter"
public static final String	MAX_METRICS_PER_REQUEST	"maxMetricsPerRequest"
public static final String	PROXY_HOST	"proxyHost"
public static final String	PROXY_PORT	"proxyPort"
public static final String	TAGS	"tags"

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.optimizer.Optimizer

Modifier and Type	Constant Field	Value
public static final String	HINT_LOCAL_STRATEGY	"LOCAL_STRATEGY"
public static final String	HINT_LOCAL_STRATEGY_COMBINING_SORT	"LOCAL_STRATEGY_COMBINING_SORT"
public static final String	HINT_LOCAL_STRATEGY_HASH_BUILD_FIRST	"LOCAL_STRATEGY_HASH_BUILD_FIRST"
public static final String	HINT_LOCAL_STRATEGY_HASH_BUILD_SECOND	"LOCAL_STRATEGY_HASH_BUILD_SECOND"
public static final String	HINT_LOCAL_STRATEGY_MERGE	"LOCAL_STRATEGY_MERGE"
public static final String	HINT_LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_FIRST	"LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_FIRST"
public static final String	HINT_LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_SECOND	"LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_SECOND"
public static final String	HINT_LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_FIRST	"LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_FIRST"
public static final String	HINT_LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_SECOND	"LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_SECOND"
public static final String	HINT_LOCAL_STRATEGY_SORT	"LOCAL_STRATEGY_SORT"
public static final String	HINT_LOCAL_STRATEGY_SORT_BOTH_MERGE	"LOCAL_STRATEGY_SORT_BOTH_MERGE"
public static final String	HINT_LOCAL_STRATEGY_SORT_FIRST_MERGE	"LOCAL_STRATEGY_SORT_FIRST_MERGE"
public static final String	HINT_LOCAL_STRATEGY_SORT_SECOND_MERGE	"LOCAL_STRATEGY_SORT_SECOND_MERGE"
public static final String	HINT_SHIP_STRATEGY	"INPUT_SHIP_STRATEGY"
public static final String	HINT_SHIP_STRATEGY_BROADCAST	"SHIP_BROADCAST"
public static final String	HINT_SHIP_STRATEGY_FIRST_INPUT	"INPUT_LEFT_SHIP_STRATEGY"
public static final String	HINT_SHIP_STRATEGY_FORWARD	"SHIP_FORWARD"
public static final String	HINT_SHIP_STRATEGY_REPARTITION	"SHIP_REPARTITION"
public static final String	HINT_SHIP_STRATEGY_REPARTITION_HASH	"SHIP_REPARTITION_HASH"
public static final String	HINT_SHIP_STRATEGY_REPARTITION_RANGE	"SHIP_REPARTITION_RANGE"
public static final String	HINT_SHIP_STRATEGY_SECOND_INPUT	"INPUT_RIGHT_SHIP_STRATEGY"

org.apache.flink.optimizer.costs.Costs

Modifier and Type	Constant Field	Value
public static final double	UNKNOWN	-1.0

org.apache.flink.optimizer.dag.OptimizerNode

Modifier and Type	Constant Field	Value
public static final int	MAX_DYNAMIC_PATH_COST_WEIGHT	100

org.apache.flink.optimizer.plantranslate.JobGraphGenerator

Modifier and Type	Constant Field	Value
public static final String	MERGE_ITERATION_AUX_TASKS_KEY	"compiler.merge-iteration-aux"

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	"output"
public static final String	OUTPUT_COLLECTION_ID	"output"
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.beam.ProcessPythonEnvironmentManager

Modifier and Type	Constant Field	Value
public static final String	PYTHON_REQUIREMENTS_CACHE	"_PYTHON_REQUIREMENTS_CACHE"
public static final String	PYTHON_REQUIREMENTS_FILE	"_PYTHON_REQUIREMENTS_FILE"
public static final String	PYTHON_REQUIREMENTS_INSTALL_DIR	"_PYTHON_REQUIREMENTS_INSTALL_DIR"
public static final String	PYTHON_WORKING_DIR	"_PYTHON_WORKING_DIR"

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.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.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.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 int	MAX_DISTINCT_LOCATIONS_TO_CONSIDER	8

org.apache.flink.runtime.executiongraph.failover.flip1.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.RestartTimeGauge

Modifier and Type	Constant Field	Value
public static final String	METRIC_NAME	"restartingTime"

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.Lz4BlockCompressionFactory

Modifier and Type	Constant Field	Value
public static final int	HEADER_LENGTH	8

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.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.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	12
public static final String	INDEX_FILE_SUFFIX	".shuffle.index"

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	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_TOTAL	"slots-total"
public static final String	FIELD_NAME_TASKMANAGERS	"taskmanagers"

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.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	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	ESTIMATED_TIME_TO_CONSUME_BUFFERS	"estimatedTimeToConsumeBuffersMs"
public static final String	FULL_RESTARTS	"fullRestarts"
public static final String	IO_CURRENT_INPUT_1_WATERMARK	"currentInput1Watermark"
public static final String	IO_CURRENT_INPUT_2_WATERMARK	"currentInput2Watermark"
public static final String	IO_CURRENT_INPUT_WATERMARK	"currentInputWatermark"
public static final String	IO_CURRENT_INPUT_WATERMARK_PATERN	"currentInput%dWatermark"
public static final String	IO_CURRENT_OUTPUT_WATERMARK	"currentOutputWatermark"
public static final String	IO_NUM_BUFFERS_IN	"numBuffersIn"
public static final String	IO_NUM_BUFFERS_OUT	"numBuffersOut"
public static final String	IO_NUM_BUFFERS_OUT_RATE	"numBuffersOutPerSecond"
public static final String	IO_NUM_BYTES_IN	"numBytesIn"
public static final String	IO_NUM_BYTES_IN_RATE	"numBytesInPerSecond"
public static final String	IO_NUM_BYTES_OUT	"numBytesOut"
public static final String	IO_NUM_BYTES_OUT_RATE	"numBytesOutPerSecond"
public static final String	IO_NUM_RECORDS_IN	"numRecordsIn"
public static final String	IO_NUM_RECORDS_IN_RATE	"numRecordsInPerSecond"
public static final String	IO_NUM_RECORDS_OUT	"numRecordsOut"
public static final String	IO_NUM_RECORDS_OUT_RATE	"numRecordsOutPerSecond"
public static final String	IS_BACK_PRESSURED	"isBackPressured"
public static final String	MEMORY_COMMITTED	"Committed"
public static final String	MEMORY_MAX	"Max"
public static final String	MEMORY_USED	"Used"
public static final String	NUM_RECORDS_IN_ERRORS	"numRecordsInErrors"
public static final String	NUM_RECORDS_OUT_ERRORS	"numRecordsOutErrors"
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	PENDING_BYTES	"pendingBytes"
public static final String	PENDING_RECORDS	"pendingRecords"
public static final String	SOURCE_IDLE_TIME	"sourceIdleTime"
public static final String	START_WORKER_FAILURE_RATE	"startWorkFailurePerSecond"
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_IDLE_TIME	"idleTimeMsPerSecond"
public static final String	TASK_SLOTS_AVAILABLE	"taskSlotsAvailable"
public static final String	TASK_SLOTS_TOTAL	"taskSlotsTotal"
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_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.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	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.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.ClusterConfigurationInfoEntry

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.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.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_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.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.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_EXECUTION_MODE	"execution-mode"
public static final String	FIELD_NAME_GLOBAL_JOB_PARAMETERS	"user-config"
public static final String	FIELD_NAME_OBJECT_REUSE_MODE	"object-reuse-mode"
public static final String	FIELD_NAME_PARALLELISM	"job-parallelism"
public static final String	FIELD_NAME_RESTART_STRATEGY	"restart-strategy"

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.JobExceptionsInfo

Modifier and Type	Constant Field	Value
public static final String	FIELD_NAME_ALL_EXCEPTIONS	"all-exceptions"
public static final String	FIELD_NAME_ROOT_EXCEPTION	"root-exception"
public static final String	FIELD_NAME_TIMESTAMP	"timestamp"
public static final String	FIELD_NAME_TRUNCATED	"truncated"

org.apache.flink.runtime.rest.messages.JobExceptionsInfo.ExecutionExceptionInfo

Modifier and Type	Constant Field	Value
public static final String	FIELD_NAME_EXCEPTION	"exception"
public static final String	FIELD_NAME_LOCATION	"location"
public static final String	FIELD_NAME_TASK	"task"
public static final String	FIELD_NAME_TIMESTAMP	"timestamp"

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_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_LOCATION	"location"
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.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	FIELD_NAME_BACKPRESSURE_LEVEL	"backpressure-level"
public static final String	FIELD_NAME_END_TIMESTAMP	"end-timestamp"
public static final String	FIELD_NAME_STATUS	"status"
public static final String	FIELD_NAME_SUBTASKS	"subtasks"

org.apache.flink.runtime.rest.messages.JobVertexBackPressureInfo.SubtaskBackPressureInfo

Modifier and Type	Constant Field	Value
public static final String	FIELD_NAME_BACK_PRESSURED_RATIO	"ratio"
public static final String	FIELD_NAME_BACKPRESSURE_LEVEL	"backpressure-level"
public static final String	FIELD_NAME_BUSY_RATIO	"busyRatio"
public static final String	FIELD_NAME_IDLE_RATIO	"idleRatio"
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_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_DURATION	"duration"
public static final String	TASK_MANAGERS_FIELD_END_TIME	"end-time"
public static final String	TASK_MANAGERS_FIELD_HOST	"host"
public static final String	TASK_MANAGERS_FIELD_METRICS	"metrics"
public static final String	TASK_MANAGERS_FIELD_START_TIME	"start-time"
public static final String	TASK_MANAGERS_FIELD_STATUS	"status"
public static final String	TASK_MANAGERS_FIELD_STATUS_COUNTS	"status-counts"
public static final String	TASK_MANAGERS_FIELD_TASKMANAGER_ID	"taskmanager-id"

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	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.OperatorIDPathParameter

Modifier and Type	Constant Field	Value
public static final String	KEY	"operatorid"

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.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_HOST	"host"
public static final String	FIELD_NAME_SUBTASK	"subtask"
public static final String	FIELD_NAME_TIMESTAMPS	"timestamps"

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_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_PROCESSING_MODE	"mode"
public static final String	FIELD_NAME_STATE_BACKEND	"state_backend"
public static final String	FIELD_NAME_TOLERABLE_FAILED_CHECKPOINTS	"tolerable_failed_checkpoints"
public static final String	FIELD_NAME_UNALIGNED_CHECKPOINTS	"unaligned_checkpoints"

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_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_DURATION	"end_to_end_duration"
public static final String	FIELD_NAME_ID	"id"
public static final String	FIELD_NAME_IS_SAVEPOINT	"is_savepoint"
public static final String	FIELD_NAME_LATEST_ACK_TIMESTAMP	"latest_ack_timestamp"
public static final String	FIELD_NAME_NUM_ACK_SUBTASKS	"num_acknowledged_subtasks"
public static final String	FIELD_NAME_NUM_SUBTASKS	"num_subtasks"
public static final String	FIELD_NAME_PERSISTED_DATA	"persisted_data"
public static final String	FIELD_NAME_PROCESSED_DATA	"processed_data"
public static final String	FIELD_NAME_STATE_SIZE	"state_size"
public static final String	FIELD_NAME_STATUS	"status"
public static final String	FIELD_NAME_TASKS	"tasks"
public static final String	FIELD_NAME_TRIGGER_TIMESTAMP	"trigger_timestamp"

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_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_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_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.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_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_TASKS_PER_STATE	"tasks"

org.apache.flink.runtime.rest.messages.job.JobSubmitRequestBody

Modifier and Type	Constant Field	Value
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_HOST	"host"
public static final String	FIELD_NAME_METRICS	"metrics"
public static final String	FIELD_NAME_START_TIME	"start-time"
public static final String	FIELD_NAME_STATUS	"status"
public static final String	FIELD_NAME_SUBTASK_INDEX	"subtask"
public static final String	FIELD_NAME_TASKMANAGER_ID	"taskmanager-id"

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_HOST	"host"
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/:operatorid"

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.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_TARGET_DIRECTORY	"targetDirectory"

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_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_NETWORK_MEMORY_SEGMENTS_AVAILABLE	"memorySegmentsAvailable"
public static final String	FIELD_NAME_NETWORK_MEMORY_SEGMENTS_TOTAL	"memorySegmentsTotal"
public static final String	FIELD_NAME_NON_HEAP_COMMITTED	"nonHeapCommitted"
public static final String	FIELD_NAME_NON_HEAP_MAX	"nonHeapMax"
public static final String	FIELD_NAME_NON_HEAP_USED	"nonHeapUsed"
public static final String	FIELD_NAME_SHUFFLE_MEMORY_AVAILABLE	"nettyShuffleMemoryAvailable"
public static final String	FIELD_NAME_SHUFFLE_MEMORY_SEGMENTS_AVAILABLE	"nettyShuffleMemorySegmentsAvailable"
public static final String	FIELD_NAME_SHUFFLE_MEMORY_SEGMENTS_TOTAL	"nettyShuffleMemorySegmentsTotal"
public static final String	FIELD_NAME_SHUFFLE_MEMORY_SEGMENTS_USED	"nettyShuffleMemorySegmentsUsed"
public static final String	FIELD_NAME_SHUFFLE_MEMORY_TOTAL	"nettyShuffleMemoryTotal"
public static final String	FIELD_NAME_SHUFFLE_MEMORY_USED	"nettyShuffleMemoryUsed"

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.messages.taskmanager.ThreadDumpInfo

Modifier and Type	Constant Field	Value
public static final String	FIELD_NAME_THREAD_INFOS	"threadInfos"

org.apache.flink.runtime.rest.messages.taskmanager.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.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.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.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	5

org.apache.flink.runtime.state.StateBackendLoader

Modifier and Type	Constant Field	Value
public static final String	FS_STATE_BACKEND_NAME	"filesystem"
public static final String	HASHMAP_STATE_BACKEND_NAME	"hashmap"
public static final String	MEMORY_STATE_BACKEND_NAME	"jobmanager"
public static final String	ROCKSDB_STATE_BACKEND_NAME	"rocksdb"

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.MemoryStateBackend

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_STATE_SIZE	5242880

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	6

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.TaskManagerServices

Modifier and Type	Constant Field	Value
public static final String	LOCAL_STATE_SUB_DIRECTORY_ROOT	"localState"

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_JOBGRAPH_PREFIX	"submittedJobGraph"

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.hive.ddl.HiveDDLUtils

Modifier and Type	Constant Field	Value
public static final String	COL_DELIMITER	";"

org.apache.flink.sql.parser.hive.ddl.SqlAlterHiveDatabase

Modifier and Type	Constant Field	Value
public static final String	ALTER_DATABASE_OP	"hive.alter.database.op"

org.apache.flink.sql.parser.hive.ddl.SqlAlterHiveDatabaseOwner

Modifier and Type	Constant Field	Value
public static final String	DATABASE_OWNER_NAME	"hive.database.owner.name"
public static final String	DATABASE_OWNER_TYPE	"hive.database.owner.type"
public static final String	ROLE_OWNER	"role"
public static final String	USER_OWNER	"user"

org.apache.flink.sql.parser.hive.ddl.SqlAlterHiveTable

Modifier and Type	Constant Field	Value
public static final String	ALTER_COL_CASCADE	"alter.column.cascade"
public static final String	ALTER_TABLE_OP	"alter.table.op"

org.apache.flink.sql.parser.hive.ddl.SqlCreateHiveDatabase

Modifier and Type	Constant Field	Value
public static final String	DATABASE_LOCATION_URI	"hive.database.location-uri"

org.apache.flink.sql.parser.hive.ddl.SqlCreateHiveTable

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"hive"
public static final String	NOT_NULL_COLS	"hive.not.null.cols"
public static final String	NOT_NULL_CONSTRAINT_TRAITS	"hive.not.null.constraint.traits"
public static final String	PK_CONSTRAINT_TRAIT	"hive.pk.constraint.trait"
public static final String	TABLE_IS_EXTERNAL	"hive.is-external"
public static final String	TABLE_LOCATION_URI	"hive.location-uri"

org.apache.flink.sql.parser.hive.ddl.SqlCreateHiveTable.HiveTableRowFormat

Modifier and Type	Constant Field	Value
public static final String	COLLECTION_DELIM	"hive.serde.info.prop.collection.delim"
public static final String	ESCAPE_CHAR	"hive.serde.info.prop.escape.delim"
public static final String	FIELD_DELIM	"hive.serde.info.prop.field.delim"
public static final String	LINE_DELIM	"hive.serde.info.prop.line.delim"
public static final String	MAPKEY_DELIM	"hive.serde.info.prop.mapkey.delim"
public static final String	SERDE_INFO_PROP_PREFIX	"hive.serde.info.prop."
public static final String	SERDE_LIB_CLASS_NAME	"hive.serde.lib.class.name"
public static final String	SERIALIZATION_NULL_FORMAT	"hive.serde.info.prop.serialization.null.format"

org.apache.flink.sql.parser.hive.ddl.SqlCreateHiveTable.HiveTableStoredAs

Modifier and Type	Constant Field	Value
public static final String	STORED_AS_FILE_FORMAT	"hive.storage.file-format"
public static final String	STORED_AS_INPUT_FORMAT	"hive.stored.as.input.format"
public static final String	STORED_AS_OUTPUT_FORMAT	"hive.stored.as.output.format"

org.apache.flink.sql.parser.hive.impl.FlinkHiveSqlParserImplConstants

Modifier and Type	Constant Field	Value
public static final int	A	1
public static final int	ABS	2
public static final int	ABSENT	3
public static final int	ABSOLUTE	4
public static final int	ACTION	5
public static final int	ADA	6
public static final int	ADD	7
public static final int	ADMIN	8
public static final int	AFTER	9
public static final int	ALL	10
public static final int	ALLOCATE	11
public static final int	ALLOW	12
public static final int	ALTER	13
public static final int	ALWAYS	14
public static final int	AND	15
public static final int	ANY	16
public static final int	APPLY	17
public static final int	APPROX_NUMERIC_LITERAL	726
public static final int	ARE	18
public static final int	ARRAY	19
public static final int	ARRAY_MAX_CARDINALITY	20
public static final int	AS	21
public static final int	ASC	22
public static final int	ASENSITIVE	23
public static final int	ASSERTION	24
public static final int	ASSIGNMENT	25
public static final int	ASYMMETRIC	26
public static final int	AT	27
public static final int	ATOMIC	28
public static final int	ATTRIBUTE	29
public static final int	ATTRIBUTES	30
public static final int	AUTHORIZATION	31
public static final int	AVG	32
public static final int	BACK_QUOTED_IDENTIFIER	789
public static final int	BEFORE	33
public static final int	BEGIN	34
public static final int	BEGIN_FRAME	35
public static final int	BEGIN_PARTITION	36
public static final int	BEL	796
public static final int	BERNOULLI	37
public static final int	BETWEEN	38
public static final int	BIG_QUERY_DOUBLE_QUOTED_STRING	736
public static final int	BIG_QUERY_QUOTED_STRING	737
public static final int	BIGINT	39
public static final int	BINARY	40
public static final int	BINARY_STRING_LITERAL	731
public static final int	BIT	41
public static final int	BLOB	42
public static final int	BOOLEAN	43
public static final int	BOTH	44