Constant Field Values

Contents

• org.apache.*

org.apache.*

org.apache.calcite.avatica.util.DateTimeUtils

Modifier and Type	Constant Field	Value
public static final String	DATE_FORMAT_STRING	"yyyy-MM-dd"
public static final int	EPOCH_JULIAN	2440588
public static final long	MILLIS_PER_DAY	86400000L
public static final long	MILLIS_PER_HOUR	3600000L
public static final long	MILLIS_PER_MINUTE	60000L
public static final long	MILLIS_PER_SECOND	1000L
public static final String	TIME_FORMAT_STRING	"HH:mm:ss"
public static final String	TIMESTAMP_FORMAT_STRING	"yyyy-MM-dd HH:mm:ss"

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

Modifier and Type	Constant Field	Value
public static final int	POSITION_FAULT_TOLERANCE	30
public static final int	POSITION_HIGH_AVAILABILITY	40
public static final int	POSITION_MEMORY	10
public static final int	POSITION_PARALLELISM_SLOTS	20
public static final int	POSITION_SECURITY	50

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

Modifier and Type	Constant Field	Value
public static final String	GPU_NAME	"GPU"

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.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.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.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 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_DELAY	"high-availability.job.delay"
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_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.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.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.snapshot.RocksSnapshotUtil

Modifier and Type	Constant Field	Value
public static final int	END_OF_KEY_GROUP_MARK	65535
public static final int	FIRST_BIT_IN_BYTE_MASK	128
public static final String	SST_FILE_SUFFIX	".sst"

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.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.formats.parquet.ParquetInputFormat<E>

Modifier and Type	Constant Field	Value
public static final String	PARQUET_SKIP_CORRUPTED_RECORD	"skip.corrupted.record"
public static final String	PARQUET_SKIP_WRONG_SCHEMA_SPLITS	"skip.splits.wrong.schema"

org.apache.flink.formats.parquet.utils.ParquetSchemaConverter

Modifier and Type	Constant Field	Value
public static final String	LIST_ARRAY_TYPE	"array"
public static final String	LIST_ELEMENT	"element"
public static final String	LIST_GROUP_NAME	"list"
public static final String	MAP_VALUE	"value"
public static final String	MESSAGE_ROOT	"root"

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.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.mesos.Utils

Modifier and Type	Constant Field	Value
public static final String	UNRESERVED_ROLE	"*"

org.apache.flink.mesos.runtime.clusterframework.MesosConfigKeys

Modifier and Type	Constant Field	Value
public static final String	ENV_FLINK_CONTAINER_ID	"_FLINK_CONTAINER_ID"
public static final String	ENV_FLINK_TMP_DIR	"_FLINK_TMP_DIR"
public static final String	ENV_FRAMEWORK_NAME	"FRAMEWORK_NAME"
public static final String	ENV_JVM_ARGS	"JVM_ARGS"
public static final String	ENV_TASK_NAME	"TASK_NAME"

org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Modifier and Type	Constant Field	Value
public static final String	MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_DOCKER	"docker"
public static final String	MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_MESOS	"mesos"

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	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.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.runtime.blob.BlobKey

Modifier and Type	Constant Field	Value
public static final int	SIZE	20

org.apache.flink.runtime.checkpoint.CheckpointFailureManager

Modifier and Type	Constant Field	Value
public static final int	UNLIMITED_TOLERABLE_FAILURE_NUMBER	2147483647

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.savepoint.SavepointV1

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

org.apache.flink.runtime.checkpoint.savepoint.SavepointV2

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

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

Modifier and Type	Constant Field	Value
public static final int	VALUE_NOT_SET	-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.FailoverStrategyLoader

Modifier and Type	Constant Field	Value
public static final String	FULL_RESTART_STRATEGY_NAME	"full"
public static final String	INDIVIDUAL_RESTART_STRATEGY_NAME	"individual"
public static final String	LEGACY_PIPELINED_REGION_RESTART_STRATEGY_NAME	"region-legacy"
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.NumberOfFullRestartsGauge

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

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.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.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.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.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	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_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	MEMORY_COMMITTED	"Committed"
public static final String	MEMORY_MAX	"Max"
public static final String	MEMORY_USED	"Used"
public static final String	NUM_REGISTERED_TASK_MANAGERS	"numRegisteredTaskManagers"
public static final String	NUM_RUNNING_JOBS	"numRunningJobs"
public static final String	SUFFIX_RATE	"PerSecond"
public static final String	TASK_SLOTS_AVAILABLE	"taskSlotsAvailable"
public static final String	TASK_SLOTS_TOTAL	"taskSlotsTotal"

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.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.sort.UnilateralSortMerger<E>

Modifier and Type	Constant Field	Value
protected static final int	MAX_NUM_WRITE_BUFFERS	4
protected static final int	MIN_NUM_SORT_MEM_SEGMENTS	10
protected static final int	MIN_NUM_WRITE_BUFFERS	2

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_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.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_BACKPRESSURE_LEVEL	"backpressure-level"
public static final String	FIELD_NAME_RATIO	"ratio"
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_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.JobVertexDetailsInfo.VertexTaskDetail

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	"subtask"

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"

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.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_CHECKPOINT_INTERVAL	"interval"
public static final String	FIELD_NAME_CHECKPOINT_MAX_CONCURRENT	"max_concurrent"
public static final String	FIELD_NAME_CHECKPOINT_MIN_PAUSE	"min_pause"
public static final String	FIELD_NAME_CHECKPOINT_TIMEOUT	"timeout"
public static final String	FIELD_NAME_EXTERNALIZED_CHECKPOINT_CONFIG	"externalization"
public static final String	FIELD_NAME_PROCESSING_MODE	"mode"

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_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_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_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.MinMaxAvgStatistics

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"

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_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_STATE_SIZE	"state_size"

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"

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_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"

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_STATE_SIZE	"state_size"

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_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_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_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"

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.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.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.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_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_DATA_PORT	"dataPort"
public static final String	FIELD_NAME_HARDWARE	"hardware"
public static final String	FIELD_NAME_LAST_HEARTBEAT	"timeSinceLastHeartbeat"
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"

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_MEMROY_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"

org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerMetricsInfo.GarbageCollectorInfo

Modifier and Type	Constant Field	Value
public static final String	FIELD_NAME_COUNT	"count"
public static final String	FIELD_NAME_NAME	"name"
public static final String	FIELD_NAME_TIME	"time"

org.apache.flink.runtime.rest.messages.taskmanager.TaskManagersHeaders

Modifier and Type	Constant Field	Value
public static final String	URL	"/taskmanagers"

org.apache.flink.runtime.rest.messages.taskmanager.TaskManagersInfo

Modifier and Type	Constant Field	Value
public static final String	FIELD_NAME_TASK_MANAGERS	"taskmanagers"

org.apache.flink.runtime.rest.util.RestConstants

Modifier and Type	Constant Field	Value
public static final String	CONTENT_TYPE_BINARY	"application/octet-stream"
public static final String	CONTENT_TYPE_JAR	"application/java-archive"

org.apache.flink.runtime.state.DefaultOperatorStateBackend

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_OPERATOR_STATE_NAME	"_default_"

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	MEMORY_STATE_BACKEND_NAME	"jobmanager"
public static final String	ROCKSDB_STATE_BACKEND_NAME	"rocksdb"

org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage

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.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.taskexecutor.TaskExecutor

Modifier and Type	Constant Field	Value
public static final String	TASK_MANAGER_NAME	"taskmanager"

org.apache.flink.runtime.taskexecutor.TaskManagerRunner

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

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

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.zookeeper.FlinkZooKeeperQuorumPeer

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_ZOOKEEPER_CLIENT_PORT	2181
public static final int	DEFAULT_ZOOKEEPER_INIT_LIMIT	10
public static final int	DEFAULT_ZOOKEEPER_LEADER_PORT	3888
public static final int	DEFAULT_ZOOKEEPER_PEER_PORT	2888
public static final int	DEFAULT_ZOOKEEPER_SYNC_LIMIT	5

org.apache.flink.sql.parser.impl.FlinkSqlParserImplConstants

Modifier and Type	Constant Field	Value
public static final int	A	1
public static final int	ABS	2
public static final int	ABSENT	3
public static final int	ABSOLUTE	4
public static final int	ACTION	5
public static final int	ADA	6
public static final int	ADD	7
public static final int	ADMIN	8
public static final int	AFTER	9
public static final int	ALL	10
public static final int	ALLOCATE	11
public static final int	ALLOW	12
public static final int	ALTER	13
public static final int	ALWAYS	14
public static final int	AND	15
public static final int	ANY	16
public static final int	APPLY	17
public static final int	APPROX_NUMERIC_LITERAL	678
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	ASCENDING	670
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	737
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	743
public static final int	BERNOULLI	37
public static final int	BETWEEN	38
public static final int	BIGINT	39
public static final int	BINARY	40
public static final int	BINARY_STRING_LITERAL	683
public static final int	BIT	41
public static final int	BLOB	42
public static final int	BOOLEAN	43
public static final int	BOTH	44
public static final int	BOUNDED	672
public static final int	BRACKET_QUOTED_IDENTIFIER	735
public static final int	BREADTH	45
public static final int	BTID	2
public static final int	BY	46
public static final int	BYTES	676
public static final int	C	47
public static final int	CALL	48
public static final int	CALLED	49
public static final int	CARDINALITY	50
public static final int	CARET	722
public static final int	CASCADE	51
public static final int	CASCADED	52
public static final int	CASE	53
public static final int	CAST	54
public static final int	CATALOG	55
public static final int	CATALOG_NAME	56
public static final int	CEIL	57
public static final int	CEILING	58
public static final int	CENTURY	59
public static final int	CHAIN	60
public static final int	CHAR	61
public static final int	CHAR_LENGTH	62
public static final int	CHARACTER	63
public static final int	CHARACTER_LENGTH	64
public static final int	CHARACTER_SET_CATALOG	65
public static final int	CHARACTER_SET_NAME	66
public static final int	CHARACTER_SET_SCHEMA	67
public static final int	CHARACTERISTICS	68
public static final int	CHARACTERS	69
public static final int	CHARSETNAME	687
public static final int	CHECK	70
public static final int	CLASS_ORIGIN	72
public static final int	CLASSIFIER	71
public static final int	CLOB	73
public static final int	CLOSE	74
public static final int	COALESCE	75
public static final int	COBOL	76
public static final int	COLLATE	77
public static final int	COLLATION	78
public static final int	COLLATION_CATALOG	79
public static final int	COLLATION_ID	738
public static final int	COLLATION_NAME	80
public static final int	COLLATION_SCHEMA	81
public static final int	COLLECT	82
public static final int	COLON	706
public static final int	COLUMN	83
public static final int	COLUMN_NAME	84
public static final int	COMMA	701
public static final int	COMMAND_FUNCTION	85
public static final int	COMMAND_FUNCTION_CODE	86
public static final int	COMMENT	666
public static final int	COMMIT	87
public static final int	COMMITTED	88
public static final int	CONCAT	716
public static final int	CONDITION	89
public static final int	CONDITION_NUMBER	91
public static final int	CONDITIONAL	90
public static final int	CONNECT	92
public static final int	CONNECTION	93
public static final int	CONNECTION_NAME	94
public static final int	CONSTRAINT	95
public static final int	CONSTRAINT_CATALOG	96
public static final int	CONSTRAINT_NAME	97
public static final int	CONSTRAINT_SCHEMA	98
public static final int	CONSTRAINTS	99
public static final int	CONSTRUCTOR	100
public static final int	CONTAINS	101
public static final int	CONTINUE	102
public static final int	CONVERT	103
public static final int	CORR	104
public static final int	CORRESPONDING	105
public static final int	COUNT	106
public static final int	COVAR_POP	107
public static final int	COVAR_SAMP	108
public static final int	CREATE	109
public static final int	CROSS	110
public static final int	CUBE	111
public static final int	CUME_DIST	112
public static final int	CURRENT	113
public static final int	CURRENT_CATALOG	114
public static final int	CURRENT_DATE	115
public static final int	CURRENT_DEFAULT_TRANSFORM_GROUP	116
public static final int	CURRENT_PATH	117
public static final int	CURRENT_ROLE	118
public static final int	CURRENT_ROW	119
public static final int	CURRENT_SCHEMA	120
public static final int	CURRENT_TIME	121
public static final int	CURRENT_TIMESTAMP	122
public static final int	CURRENT_TRANSFORM_GROUP_FOR_TYPE	123
public static final int	CURRENT_USER	124
public static final int	CURSOR	125
public static final int	CURSOR_NAME	126
public static final int	CYCLE	127
public static final int	DATA	128
public static final int	DATABASE	129
public static final int	DATE	130
public static final int	DATETIME_INTERVAL_CODE	131
public static final int	DATETIME_INTERVAL_PRECISION	132
public static final int	DAY	133
public static final int	DEALLOCATE	134
public static final int	DEC	135
public static final int	DECADE	136
public static final int	DECIMAL	137
public static final int	DECIMAL_NUMERIC_LITERAL	679
public static final int	DECLARE	138
public static final int	DEFAULT	0
public static final int	DEFAULT_	139
public static final int	DEFAULTS	140
public static final int	DEFERRABLE	141
public static final int	DEFERRED	142
public static final int	DEFINE	143
public static final int	DEFINED	144
public static final int	DEFINER	145
public static final int	DEGREE	146
public static final int	DELAY	673
public static final int	DELETE	147
public static final int	DENSE_RANK	148
public static final int	DEPTH	149
public static final int	DEREF	150
public static final int	DERIVED	151
public static final int	DESC	152
public static final int	DESCRIBE	153
public static final int	DESCRIPTION	154
public static final int	DESCRIPTOR	155
public static final int	DETERMINISTIC	156
public static final int	DIAGNOSTICS	157
public static final int	DIGIT	742
public static final int	DISALLOW	158
public static final int	DISCONNECT	159
public static final int	DISPATCH	160
public static final int	DISTINCT	161
public static final int	DOLLAR	723
public static final int	DOMAIN	162
public static final int	DOT	700
public static final int	DOUBLE	163
public static final int	DOUBLE_PERIOD	718
public static final int	DOUBLE_QUOTE	720
public static final int	DOW	164
public static final int	DOY	165
public static final int	DQID	1
public static final int	DROP	166
public static final int	DYNAMIC	167
public static final int	DYNAMIC_FUNCTION	168
public static final int	DYNAMIC_FUNCTION_CODE	169
public static final int	EACH	170
public static final int	ELEMENT	171
public static final int	ELSE	172
public static final int	EMPTY	173
public static final int	ENCODING	174
public static final int	END	175
public static final int	END_EXEC	176
public static final int	END_FRAME	177
public static final int	END_PARTITION	178
public static final int	EOF	0
public static final int	EPOCH	179
public static final int	EQ	702
public static final int	EQUALS	180
public static final int	ERROR	181
public static final int	ESCAPE	182
public static final int	EVERY	183
public static final int	EXCEPT	184
public static final int	EXCEPTION	185
public static final int	EXCLUDE	186
public static final int	EXCLUDING	187
public static final int	EXEC	188
public static final int	EXECUTE	189
public static final int	EXISTS	190
public static final int	EXP	191
public static final int	EXPLAIN	192
public static final int	EXPONENT	680
public static final int	EXTEND	193
public static final int	EXTERNAL	194
public static final int	EXTRACT	195
public static final int	FALSE	196
public static final int	FETCH	197
public static final int	FILTER	198
public static final int	FINAL	199
public static final int	FIRST	200
public static final int	FIRST_VALUE	201
public static final int	FLOAT	202
public static final int	FLOOR	203
public static final int	FOLLOWING	204
public static final int	FOR	205
public static final int	FOREIGN	207
public static final int	FORMAL_COMMENT	732
public static final int	FORMAT	206
public static final int	FORTRAN	208
public static final int	FOUND	209
public static final int	FRAC_SECOND	210
public static final int	FRAME_ROW	211
public static final int	FREE	212
public static final int	FROM	213
public static final int	FROM_SOURCE	671
public static final int	FULL	214
public static final int	FUNCTION	215
public static final int	FUSION	216
public static final int	G	217
public static final int	GE	708
public static final int	GENERAL	218
public static final int	GENERATED	219
public static final int	GEOMETRY	220
public static final int	GET	221
public static final int	GLOBAL	222
public static final int	GO	223
public static final int	GOTO	224
public static final int	GRANT	225
public static final int	GRANTED	226
public static final int	GROUP	227
public static final int	GROUPING	228
public static final int	GROUPS	229
public static final int	GT	703
public static final int	HAVING	230
public static final int	HEXDIGIT	681
public static final int	HIERARCHY	231
public static final int	HOLD	232
public static final int	HOOK	705
public static final int	HOUR	233
public static final int	IDENTIFIER	739
public static final int	IDENTITY	234
public static final int	IF	668
public static final int	IGNORE	235
public static final int	IMMEDIATE	236
public static final int	IMMEDIATELY	237
public static final int	IMPLEMENTATION	238
public static final int	IMPORT	239
public static final int	IN	240
public static final int	IN_FORMAL_COMMENT	3
public static final int	IN_MULTI_LINE_COMMENT	4
public static final int	INCLUDING	241
public static final int	INCREMENT	242
public static final int	INDICATOR	243
public static final int	INITIAL	244
public static final int	INITIALLY	245
public static final int	INNER	246
public static final int	INOUT	247
public static final int	INPUT	248
public static final int	INSENSITIVE	249
public static final int	INSERT	250
public static final int	INSTANCE	251
public static final int	INSTANTIABLE	252
public static final int	INT	253
public static final int	INTEGER	254
public static final int	INTERSECT	255
public static final int	INTERSECTION	256
public static final int	INTERVAL	257
public static final int	INTO	258
public static final int	INVOKER	259
public static final int	IS	260
public static final int	ISODOW	261
public static final int	ISOLATION	263
public static final int	ISOYEAR	262
public static final int	JAVA	264
public static final int	JOIN	265
public static final int	JSON	266
public static final int	JSON_ARRAY	267
public static final int	JSON_ARRAYAGG	268
public static final int	JSON_EXISTS	269
public static final int	JSON_OBJECT	270
public static final int	JSON_OBJECTAGG	271
public static final int	JSON_QUERY	272
public static final int	JSON_VALUE	273
public static final int	K	274
public static final int	KEY	275
public static final int	KEY_MEMBER	276
public static final int	KEY_TYPE	277
public static final int	LABEL	278
public static final int	LAG	279
public static final int	LANGUAGE	280
public static final int	LARGE	281
public static final int	LAST	282
public static final int	LAST_VALUE	283
public static final int	LATERAL	284
public static final int	LBRACE	695
public static final int	LBRACE_D	691
public static final int	LBRACE_FN	694
public static final int	LBRACE_T	692
public static final int	LBRACE_TS	693
public static final int	LBRACKET	697
public static final int	LE	707
public static final int	LEAD	285
public static final int	LEADING	286
public static final int	LEFT	287
public static final int	LENGTH	288
public static final int	LETTER	741
public static final int	LEVEL	289
public static final int	LIBRARY	290
public static final int	LIKE	291
public static final int	LIKE_REGEX	292
public static final int	LIMIT	293
public static final int	LN	294
public static final int	LOCAL	295
public static final int	LOCALTIME	296
public static final int	LOCALTIMESTAMP	297
public static final int	LOCATOR	298
public static final int	LOWER	299
public static final int	LPAREN	689
public static final int	LT	704
public static final int	M	300
public static final int	MAP	301
public static final int	MATCH	302
public static final int	MATCH_NUMBER	305
public static final int	MATCH_RECOGNIZE	306
public static final int	MATCHED	303
public static final int	MATCHES	304
public static final int	MAX	307
public static final int	MAXVALUE	308
public static final int	MEASURES	309
public static final int	MEMBER	310
public static final int	MERGE	311
public static final int	MESSAGE_LENGTH	312
public static final int	MESSAGE_OCTET_LENGTH	313
public static final int	MESSAGE_TEXT	314
public static final int	METHOD	315
public static final int	MICROSECOND	316
public static final int	MILLENNIUM	318
public static final int	MILLISECOND	317
public static final int	MIN	319
public static final int	MINUS	712
public static final int	MINUTE	320
public static final int	MINVALUE	321
public static final int	MOD	322
public static final int	MODIFIES	323
public static final int	MODULE	324
public static final int	MONTH	325
public static final int	MORE_	326
public static final int	MULTI_LINE_COMMENT	733
public static final int	MULTISET	327
public static final int	MUMPS	328
public static final int	NAME	329
public static final int	NAMED_ARGUMENT_ASSIGNMENT	717
public static final int	NAMES	330
public static final int	NANOSECOND	331
public static final int	NATIONAL	332
public static final int	NATURAL	333
public static final int	NCHAR	334
public static final int	NCLOB	335
public static final int	NE	709
public static final int	NE2	710
public static final int	NESTING	336
public static final int	NEW	337
public static final int	NEXT	338
public static final int	NO	339
public static final int	NONE	340
public static final int	NORMALIZE	341
public static final int	NORMALIZED	342
public static final int	NOT	343
public static final int	NTH_VALUE	344
public static final int	NTILE	345
public static final int	NULL	346
public static final int	NULLABLE	347
public static final int	NULLIF	348
public static final int	NULLS	349
public static final int	NUMBER	350
public static final int	NUMERIC	351
public static final int	OBJECT	352
public static final int	OCCURRENCES_REGEX	353
public static final int	OCTET_LENGTH	354
public static final int	OCTETS	355
public static final int	OF	356
public static final int	OFFSET	357
public static final int	OLD	358
public static final int	OMIT	359
public static final int	ON	360
public static final int	ONE	361
public static final int	ONLY	362
public static final int	OPEN	363
public static final int	OPTION	364
public static final int	OPTIONS	365
public static final int	OR	366
public static final int	ORDER	367
public static final int	ORDERING	368
public static final int	ORDINALITY	369
public static final int	OTHERS	370
public static final int	OUT	371
public static final int	OUTER	372
public static final int	OUTPUT	373
public static final int	OVER	374
public static final int	OVERLAPS	375
public static final int	OVERLAY	376
public static final int	OVERRIDING	377
public static final int	OVERWRITE	674
public static final int	PAD	378
public static final int	PARAMETER	379
public static final int	PARAMETER_MODE	380
public static final int	PARAMETER_NAME	381
public static final int	PARAMETER_ORDINAL_POSITION	382
public static final int	PARAMETER_SPECIFIC_CATALOG	383
public static final int	PARAMETER_SPECIFIC_NAME	384
public static final int	PARAMETER_SPECIFIC_SCHEMA	385
public static final int	PARTIAL	386
public static final int	PARTITION	387
public static final int	PARTITIONED	667
public static final int	PASCAL	388
public static final int	PASSING	389
public static final int	PASSTHROUGH	390
public static final int	PAST	391
public static final int	PATH	392
public static final int	PATTERN	393
public static final int	PER	394
public static final int	PERCENT	395
public static final int	PERCENT_RANK	398
public static final int	PERCENT_REMAINDER	715
public static final int	PERCENTILE_CONT	396
public static final int	PERCENTILE_DISC	397
public static final int	PERIOD	399
public static final int	PERMUTE	400
public static final int	PLACING	401
public static final int	PLAN	402
public static final int	PLI	403
public static final int	PLUS	711
public static final int	PORTION	404
public static final int	POSITION	405
public static final int	POSITION_REGEX	406
public static final int	POWER	407
public static final int	PRECEDES	408
public static final int	PRECEDING	409
public static final int	PRECISION	410
public static final int	PREFIXED_STRING_LITERAL	685
public static final int	PREPARE	411
public static final int	PRESERVE	412
public static final int	PREV	413
public static final int	PRIMARY	414
public static final int	PRIOR	415
public static final int	PRIVILEGES	416
public static final int	PROCEDURE	417
public static final int	PUBLIC	418
public static final int	QUARTER	419
public static final int	QUOTE	719
public static final int	QUOTED_IDENTIFIER	736
public static final int	QUOTED_STRING	684
public static final int	RANGE	420
public static final int	RANK	421
public static final int	RBRACE	696
public static final int	RBRACKET	698
public static final int	READ	422
public static final int	READS	423
public static final int	REAL	424
public static final int	RECURSIVE	425
public static final int	REF	426
public static final int	REFERENCES	427
public static final int	REFERENCING	428
public static final int	REGR_AVGX	429
public static final int	REGR_AVGY	430
public static final int	REGR_COUNT	431
public static final int	REGR_INTERCEPT	432
public static final int	REGR_R2	433
public static final int	REGR_SLOPE	434
public static final int	REGR_SXX	435
public static final int	REGR_SXY	436
public static final int	REGR_SYY	437
public static final int	RELATIVE	438
public static final int	RELEASE	439
public static final int	REPEATABLE	440
public static final int	REPLACE	441
public static final int	RESET	442
public static final int	RESPECT	443
public static final int	RESTART	444
public static final int	RESTRICT	445
public static final int	RESULT	446
public static final int	RETURN	447
public static final int	RETURNED_CARDINALITY	448
public static final int	RETURNED_LENGTH	449
public static final int	RETURNED_OCTET_LENGTH	450
public static final int	RETURNED_SQLSTATE	451
public static final int	RETURNING	452
public static final int	RETURNS	453
public static final int	REVOKE	454
public static final int	RIGHT	455
public static final int	ROLE	456
public static final int	ROLLBACK	457
public static final int	ROLLUP	458
public static final int	ROUTINE	459
public static final int	ROUTINE_CATALOG	460
public static final int	ROUTINE_NAME	461
public static final int	ROUTINE_SCHEMA	462
public static final int	ROW	463
public static final int	ROW_COUNT	464
public static final int	ROW_NUMBER	465
public static final int	ROWS	466
public static final int	RPAREN	690
public static final int	RUNNING	467
public static final int	SAVEPOINT	468
public static final int	SCALAR	469
public static final int	SCALE	470
public static final int	SCHEMA	471
public static final int	SCHEMA_NAME	472
public static final int	SCOPE	473
public static final int	SCOPE_CATALOGS	474
public static final int	SCOPE_NAME	475
public static final int	SCOPE_SCHEMA	476
public static final int	SCROLL	477
public static final int	SEARCH	478
public static final int	SECOND	479
public static final int	SECTION	480
public static final int	SECURITY	481
public static final int	SEEK	482
public static final int	SELECT	483
public static final int	SELF	484
public static final int	SEMICOLON	699
public static final int	SENSITIVE	485
public static final int	SEQUENCE	486
public static final int	SERIALIZABLE	487
public static final int	SERVER	488
public static final int	SERVER_NAME	489
public static final int	SESSION	490
public static final int	SESSION_USER	491
public static final int	SET	492
public static final int	SET_MINUS	494
public static final int	SETS	493
public static final int	SHOW	495
public static final int	SIMILAR	496
public static final int	SIMPLE	497
public static final int	SINGLE_LINE_COMMENT	731
public static final int	SIZE	498
public static final int	SKIP_	499
public static final int	SLASH	714
public static final int	SMALLINT	500
public static final int	SOME	501
public static final int	SOURCE	502
public static final int	SPACE	503
public static final int	SPECIFIC	504
public static final int	SPECIFIC_NAME	505
public static final int	SPECIFICTYPE	506
public static final int	SQL	507
public static final int	SQL_BIGINT	511
public static final int	SQL_BINARY	512
public static final int	SQL_BIT	513
public static final int	SQL_BLOB	514
public static final int	SQL_BOOLEAN	515
public static final int	SQL_CHAR	516
public static final int	SQL_CLOB	517
public static final int	SQL_DATE	518
public static final int	SQL_DECIMAL	519
public static final int	SQL_DOUBLE	520
public static final int	SQL_FLOAT	521
public static final int	SQL_INTEGER	522
public static final int	SQL_INTERVAL_DAY	523
public static final int	SQL_INTERVAL_DAY_TO_HOUR	524
public static final int	SQL_INTERVAL_DAY_TO_MINUTE	525
public static final int	SQL_INTERVAL_DAY_TO_SECOND	526
public static final int	SQL_INTERVAL_HOUR	527
public static final int	SQL_INTERVAL_HOUR_TO_MINUTE	528
public static final int	SQL_INTERVAL_HOUR_TO_SECOND	529
public static final int	SQL_INTERVAL_MINUTE	530
public static final int	SQL_INTERVAL_MINUTE_TO_SECOND	531
public static final int	SQL_INTERVAL_MONTH	532
public static final int	SQL_INTERVAL_SECOND	533
public static final int	SQL_INTERVAL_YEAR	534
public static final int	SQL_INTERVAL_YEAR_TO_MONTH	535
public static final int	SQL_LONGVARBINARY	536
public static final int	SQL_LONGVARCHAR	537
public static final int	SQL_LONGVARNCHAR	538
public static final int	SQL_NCHAR	539
public static final int	SQL_NCLOB	540
public static final int	SQL_NUMERIC	541
public static final int	SQL_NVARCHAR	542
public static final int	SQL_REAL	543
public static final int	SQL_SMALLINT	544
public static final int	SQL_TIME	545
public static final int	SQL_TIMESTAMP	546
public static final int	SQL_TINYINT	547
public static final int	SQL_TSI_DAY	548
public static final int	SQL_TSI_FRAC_SECOND	549
public static final int	SQL_TSI_HOUR	550
public static final int	SQL_TSI_MICROSECOND	551
public static final int	SQL_TSI_MINUTE	552
public static final int	SQL_TSI_MONTH	553
public static final int	SQL_TSI_QUARTER	554
public static final int	SQL_TSI_SECOND	555
public static final int	SQL_TSI_WEEK	556
public static final int	SQL_TSI_YEAR	557
public static final int	SQL_VARBINARY	558
public static final int	SQL_VARCHAR	559
public static final int	SQLEXCEPTION	508
public static final int	SQLSTATE	509
public static final int	SQLWARNING	510
public static final int	SQRT	560
public static final int	STAR	713
public static final int	START	561
public static final int	STATE	562
public static final int	STATEMENT	563
public static final int	STATIC	564
public static final int	STDDEV_POP	565
public static final int	STDDEV_SAMP	566
public static final int	STREAM	567
public static final int	STRING	675
public static final int	STRUCTURE	568
public static final int	STYLE	569
public static final int	SUBCLASS_ORIGIN	570
public static final int	SUBMULTISET	571
public static final int	SUBSET	572
public static final int	SUBSTITUTE	573
public static final int	SUBSTRING	574
public static final int	SUBSTRING_REGEX	575
public static final int	SUCCEEDS	576
public static final int	SUM	577
public static final int	SYMMETRIC	578
public static final int	SYSTEM	579
public static final int	SYSTEM_TIME	580
public static final int	SYSTEM_USER	581
public static final int	TABLE	582
public static final int	TABLE_NAME	583
public static final int	TABLESAMPLE	584
public static final int	TEMPORARY	585
public static final int	THEN	586
public static final int	TIES	587
public static final int	TIME	588
public static final int	TIMESTAMP	589
public static final int	TIMESTAMPADD	590
public static final int	TIMESTAMPDIFF	591
public static final int	TIMEZONE_HOUR	592
public static final int	TIMEZONE_MINUTE	593
public static final int	TINYINT	594
public static final int	TO	595
public static final int	TOP_LEVEL_COUNT	596
public static final int	TRAILING	597
public static final int	TRANSACTION	598
public static final int	TRANSACTIONS_ACTIVE	599
public static final int	TRANSACTIONS_COMMITTED	600
public static final int	TRANSACTIONS_ROLLED_BACK	601
public static final int	TRANSFORM	602
public static final int	TRANSFORMS	603
public static final int	TRANSLATE	604
public static final int	TRANSLATE_REGEX	605
public static final int	TRANSLATION	606
public static final int	TREAT	607
public static final int	TRIGGER	608
public static final int	TRIGGER_CATALOG	609
public static final int	TRIGGER_NAME	610
public static final int	TRIGGER_SCHEMA	611
public static final int	TRIM	612
public static final int	TRIM_ARRAY	613
public static final int	TRUE	614
public static final int	TRUNCATE	615
public static final int	TYPE	616
public static final int	UESCAPE	617
public static final int	UNBOUNDED	618
public static final int	UNCOMMITTED	619
public static final int	UNCONDITIONAL	620
public static final int	UNDER	621
public static final int	UNICODE_QUOTED_ESCAPE_CHAR	688
public static final int	UNICODE_QUOTED_IDENTIFIER	740
public static final int	UNICODE_STRING_LITERAL	686
public static final int	UNION	622
public static final int	UNIQUE	623
public static final int	UNKNOWN	624
public static final int	UNNAMED	625
public static final int	UNNEST	626
public static final int	UNSIGNED_INTEGER_LITERAL	677
public static final int	UPDATE	627
public static final int	UPPER	628
public static final int	UPSERT	629
public static final int	USAGE	630
public static final int	USER	631
public static final int	USER_DEFINED_TYPE_CATALOG	632
public static final int	USER_DEFINED_TYPE_CODE	633
public static final int	USER_DEFINED_TYPE_NAME	634
public static final int	USER_DEFINED_TYPE_SCHEMA	635
public static final int	USING	636
public static final int	UTF16	638
public static final int	UTF32	639
public static final int	UTF8	637
public static final int	VALUE	640
public static final int	VALUE_OF	642
public static final int	VALUES	641
public static final int	VAR_POP	643
public static final int	VAR_SAMP	644
public static final int	VARBINARY	645
public static final int	VARCHAR	646
public static final int	VARYING	647
public static final int	VERSION	648
public static final int	VERSIONING	649
public static final int	VERTICAL_BAR	721
public static final int	VIEW	650
public static final int	WATERMARK	669
public static final int	WEEK	651
public static final int	WHEN	652
public static final int	WHENEVER	653
public static final int	WHERE	654
public static final int	WHITESPACE	682
public static final int	WIDTH_BUCKET	655
public static final int	WINDOW	656
public static final int	WITH	657
public static final int	WITHIN	658
public static final int	WITHOUT	659
public static final int	WORK	660
public static final int	WRAPPER	661
public static final int	WRITE	662
public static final int	XML	663
public static final int	YEAR	664
public static final int	ZONE	665

org.apache.flink.sql.parser.impl.SimpleCharStream

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

org.apache.flink.streaming.api.TimerService

Modifier and Type	Constant Field	Value
public static final String	UNSUPPORTED_DELETE_TIMER_MSG	"Deleting timers is only supported on a keyed streams."
public static final String	UNSUPPORTED_REGISTER_TIMER_MSG	"Setting timers is only supported on a keyed streams."

org.apache.flink.streaming.api.environment.CheckpointConfig

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_CONCURRENT_CHECKPOINTS	1
public static final long	DEFAULT_MIN_PAUSE_BETWEEN_CHECKPOINTS	0L
public static final long	DEFAULT_TIMEOUT	600000L
public static final int	UNDEFINED_TOLERABLE_CHECKPOINT_NUMBER	-1

org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_JOB_NAME	"Flink Streaming Job"

org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction<OUT>

Modifier and Type	Constant Field	Value
public static final long	MIN_MONITORING_INTERVAL	1L

org.apache.flink.streaming.api.graph.JSONGenerator

Modifier and Type	Constant Field	Value
public static final String	CONTENTS	"contents"
public static final String	ID	"id"
public static final String	PACT	"pact"
public static final String	PARALLELISM	"parallelism"
public static final String	PREDECESSORS	"predecessors"
public static final String	SHIP_STRATEGY	"ship_strategy"
public static final String	SIDE	"side"
public static final String	STEPS	"step_function"
public static final String	TYPE	"type"

org.apache.flink.streaming.api.graph.StreamGraph

Modifier and Type	Constant Field	Value
public static final String	ITERATION_SINK_NAME_PREFIX	"IterationSink"
public static final String	ITERATION_SOURCE_NAME_PREFIX	"IterationSource"

org.apache.flink.streaming.api.graph.StreamGraphGenerator

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_JOB_NAME	"Flink Streaming Job"
public static final int	DEFAULT_LOWER_BOUND_MAX_PARALLELISM	128
public static final long	DEFAULT_NETWORK_BUFFER_TIMEOUT	100L
public static final String	DEFAULT_SLOT_SHARING_GROUP	"default"

org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy<K>

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

org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters

Modifier and Type	Constant Field	Value
public static final int	NO_VERSION	-2147483648

org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseConfig

Modifier and Type	Constant Field	Value
public static final boolean	DEFAULT_IGNORE_NULL_FIELDS	false
public static final int	DEFAULT_MAX_CONCURRENT_REQUESTS	2147483647

org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase<T,C extends AutoCloseable>

Modifier and Type	Constant Field	Value
public static final String	CONFIG_KEY_BULK_FLUSH_BACKOFF_DELAY	"bulk.flush.backoff.delay"
public static final String	CONFIG_KEY_BULK_FLUSH_BACKOFF_ENABLE	"bulk.flush.backoff.enable"
public static final String	CONFIG_KEY_BULK_FLUSH_BACKOFF_RETRIES	"bulk.flush.backoff.retries"
public static final String	CONFIG_KEY_BULK_FLUSH_BACKOFF_TYPE	"bulk.flush.backoff.type"
public static final String	CONFIG_KEY_BULK_FLUSH_INTERVAL_MS	"bulk.flush.interval.ms"
public static final String	CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS	"bulk.flush.max.actions"
public static final String	CONFIG_KEY_BULK_FLUSH_MAX_SIZE_MB	"bulk.flush.max.size.mb"

org.apache.flink.streaming.connectors.fs.AvroKeyValueSinkWriter<K,V>

Modifier and Type	Constant Field	Value
public static final String	CONF_COMPRESS	"mapreduce.output.fileoutputformat.compress"
public static final String	CONF_COMPRESS_CODEC	"mapreduce.output.fileoutputformat.compress.codec"
public static final String	CONF_DEFLATE_LEVEL	"avro.deflate.level"
public static final String	CONF_OUTPUT_KEY_SCHEMA	"avro.schema.output.key"
public static final String	CONF_OUTPUT_VALUE_SCHEMA	"avro.schema.output.value"
public static final String	CONF_XZ_LEVEL	"avro.xz.level"

org.apache.flink.streaming.connectors.fs.AvroKeyValueSinkWriter.AvroKeyValue<K,V>

Modifier and Type	Constant Field	Value
public static final String	KEY_FIELD	"key"
public static final String	KEY_VALUE_PAIR_RECORD_NAME	"KeyValuePair"
public static final String	KEY_VALUE_PAIR_RECORD_NAMESPACE	"org.apache.avro.mapreduce"
public static final String	VALUE_FIELD	"value"

org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer<T>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_POLL_TIMEOUT	100L
public static final String	KEY_POLL_TIMEOUT	"flink.poll-timeout"

org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08<T>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_GET_PARTITIONS_RETRIES	3
public static final String	GET_PARTITIONS_RETRIES_KEY	"flink.get-partitions.retry"

org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09<T>

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_POLL_TIMEOUT	100L
public static final String	KEY_POLL_TIMEOUT	"flink.poll-timeout"

org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase<T>

Modifier and Type	Constant Field	Value
public static final String	KEY_DISABLE_METRICS	"flink.disable-metrics"
public static final String	KEY_PARTITION_DISCOVERY_INTERVAL_MILLIS	"flink.partition-discovery.interval-millis"
public static final int	MAX_NUM_PENDING_CHECKPOINTS	100
public static final long	PARTITION_DISCOVERY_DISABLED	-9223372036854775808L

org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer<IN>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_KAFKA_PRODUCERS_POOL_SIZE	5
public static final String	KEY_DISABLE_METRICS	"flink.disable-metrics"
public static final int	SAFE_SCALE_DOWN_FACTOR	5

org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011<IN>

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_KAFKA_PRODUCERS_POOL_SIZE	5
public static final String	KEY_DISABLE_METRICS	"flink.disable-metrics"
public static final int	SAFE_SCALE_DOWN_FACTOR	5

org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase<IN>

Modifier and Type	Constant Field	Value
public static final String	KEY_DISABLE_METRICS	"flink.disable-metrics"

org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionStateSentinel

Modifier and Type	Constant Field	Value
public static final long	EARLIEST_OFFSET	-915623761775L
public static final long	GROUP_OFFSET	-915623761773L
public static final long	LATEST_OFFSET	-915623761774L
public static final long	OFFSET_NOT_SET	-915623761776L

org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaConsumerMetricConstants

Modifier and Type	Constant Field	Value
public static final String	COMMITS_FAILED_METRICS_COUNTER	"commitsFailed"
public static final String	COMMITS_SUCCEEDED_METRICS_COUNTER	"commitsSucceeded"
public static final String	COMMITTED_OFFSETS_METRICS_GAUGE	"committedOffsets"
public static final String	CURRENT_OFFSETS_METRICS_GAUGE	"currentOffsets"
public static final String	KAFKA_CONSUMER_METRICS_GROUP	"KafkaConsumer"
public static final String	LEGACY_COMMITTED_OFFSETS_METRICS_GROUP	"committed-offsets"
public static final String	LEGACY_CURRENT_OFFSETS_METRICS_GROUP	"current-offsets"
public static final String	OFFSETS_BY_PARTITION_METRICS_GROUP	"partition"
public static final String	OFFSETS_BY_TOPIC_METRICS_GROUP	"topic"

org.apache.flink.streaming.connectors.twitter.TwitterSource

Modifier and Type	Constant Field	Value
public static final String	CLIENT_BUFFER_SIZE	"twitter-source.bufferSize"
public static final String	CLIENT_HOSTS	"twitter-source.hosts"
public static final String	CLIENT_NAME	"twitter-source.name"
public static final String	CONSUMER_KEY	"twitter-source.consumerKey"
public static final String	CONSUMER_SECRET	"twitter-source.consumerSecret"
public static final String	TOKEN	"twitter-source.token"
public static final String	TOKEN_SECRET	"twitter-source.tokenSecret"

org.apache.flink.streaming.connectors.wikiedits.WikipediaEditsSource

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_CHANNEL	"#en.wikipedia"
public static final String	DEFAULT_HOST	"irc.wikimedia.org"
public static final int	DEFAULT_PORT	6667

org.apache.flink.streaming.examples.iteration.util.IterateExampleData

Modifier and Type	Constant Field	Value
public static final String	INPUT_PAIRS	"(1,40)\n(29,38)\n(11,15)\n(17,39)\n(24,41)\n(7,33)\n(20,2)\n(11,5)\n(3,16)\n(23,36)\n(15,23)\n(28,13)\n(1,1)\n(10,6)\n(21,5)\n(14,36)\n(17,15)\n(7,9)"
public static final String	RESULTS	"((1,40),3)\n((24,41),2)\n((3,16),5)\n((1,1),10)\n((17,15),4)\n((29,38),2)\n((7,33),3)\n((23,36),3)\n((10,6),6)\n((7,9),5)\n((11,15),4)\n((20,2),5)\n((15,23),4)\n((21,5),5)\n((17,39),3)\n((11,5),6)\n((28,13),4)\n((14,36),3)"

org.apache.flink.streaming.examples.ml.util.IncrementalLearningSkeletonData

Modifier and Type	Constant Field	Value
public static final String	RESULTS	"1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n1\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n0\n"

org.apache.flink.streaming.examples.statemachine.kafka.KafkaStandaloneGenerator

Modifier and Type	Constant Field	Value
public static final String	BROKER_ADDRESS	"localhost:9092"
public static final int	NUM_PARTITIONS	1
public static final String	TOPIC	"flink-demo-topic-1"

org.apache.flink.streaming.examples.twitter.util.TwitterExampleData

Modifier and Type	Constant Field	Value
public static final String	STREAMING_COUNTS_AS_TUPLES	"(apache,1)\n(apache,2)\n(apache,3)\n(flink,1)\n(flink,2)\n(flink,3)\n"

org.apache.flink.streaming.examples.windowing.util.SessionWindowingData

Modifier and Type	Constant Field	Value
public static final String	EXPECTED	"(a,1,1)\n(c,6,1)\n(c,11,1)\n(b,1,3)\n(a,10,1)"

org.apache.flink.streaming.examples.windowing.util.TopSpeedWindowingExampleData

Modifier and Type	Constant Field	Value
public static final String	CAR_DATA	"(0,55,15.277777777777777,1424951918630)\n(1,45,12.5,1424951918632)\n(0,50,29.166666666666664,1424951919632)\n(1,50,26.38888888888889,1424951919632)\n(0,55,44.44444444444444,1424951920633)\n(1,45,38.888888888888886,1424951920633)\n(0,50,58.33333333333333,1424951921634)\n(1,40,50.0,1424951921634)\n(0,55,73.6111111111111,1424951922634)\n(1,35,59.72222222222222,1424951922634)\n(0,60,90.27777777777777,1424951923634)\n(1,40,70.83333333333333,1424951923634)\n(0,65,108.33333333333333,1424951924635)\n(1,35,80.55555555555554,1424951924635)\n(0,60,125.0,1424951925635)\n(1,40,91.66666666666666,1424951925635)\n(0,55,140.27777777777777,1424951926635)\n(1,45,104.16666666666666,1424951926636)\n(0,60,156.94444444444443,1424951927636)\n(1,50,118.05555555555554,1424951927636)\n(0,55,172.2222222222222,1424951928636)\n(1,45,130.55555555555554,1424951928636)\n(0,50,186.1111111111111,1424951929636)\n(1,50,144.44444444444443,1424951929637)\n(0,55,201.38888888888886,1424951930637)\n(1,55,159.7222222222222,1424951930637)\n(0,60,218.05555555555551,1424951931637)\n(1,60,176.38888888888886,1424951931637)\n(0,55,233.3333333333333,1424951932637)\n(1,65,194.4444444444444,1424951932638)\n(0,50,247.22222222222217,1424951933638)\n(1,70,213.88888888888886,1424951933638)\n(0,45,259.7222222222222,1424951934638)\n(1,65,231.9444444444444,1424951934638)\n(0,50,273.6111111111111,1424951935638)\n(1,70,251.38888888888886,1424951935639)\n(0,55,288.88888888888886,1424951936639)\n(1,75,272.2222222222222,1424951936639)\n(0,50,302.77777777777777,1424951937639)\n(1,70,291.66666666666663,1424951937639)\n(0,45,315.27777777777777,1424951938640)\n(1,65,309.7222222222222,1424951938640)\n(0,50,329.1666666666667,1424951939640)\n(1,70,329.16666666666663,1424951939640)\n(0,55,344.44444444444446,1424951940640)\n(1,65,347.2222222222222,1424951940640)\n(0,50,358.33333333333337,1424951941641)\n(1,70,366.66666666666663,1424951941641)\n(0,55,373.61111111111114,1424951942641)\n(1,65,384.7222222222222,1424951942641)\n(0,50,387.50000000000006,1424951943641)\n(1,70,404.16666666666663,1424951943641)\n(0,45,400.00000000000006,1424951944642)\n(1,65,422.2222222222222,1424951944642)\n(0,50,413.88888888888897,1424951945642)\n(1,60,438.88888888888886,1424951945642)\n(0,45,426.38888888888897,1424951946642)\n(1,65,456.9444444444444,1424951946642)\n(0,40,437.50000000000006,1424951947643)\n(1,70,476.38888888888886,1424951947643)\n(0,45,450.00000000000006,1424951948643)\n(1,75,497.2222222222222,1424951948643)\n(0,40,461.11111111111114,1424951949643)\n(1,80,519.4444444444443,1424951949644)\n(0,45,473.61111111111114,1424951950644)\n(1,75,540.2777777777777,1424951950644)\n(0,50,487.50000000000006,1424951951644)\n(1,80,562.4999999999999,1424951951644)\n(0,45,500.00000000000006,1424951952644)\n(1,85,586.111111111111,1424951952645)\n(0,40,511.11111111111114,1424951953645)\n(1,80,608.3333333333331,1424951953645)\n(0,35,520.8333333333334,1424951954645)\n(1,75,629.1666666666665,1424951954645)\n(0,40,531.9444444444445,1424951955645)\n(1,70,648.611111111111,1424951955646)\n(0,45,544.4444444444445,1424951956646)\n(1,75,669.4444444444443,1424951956646)\n(0,50,558.3333333333334,1424951957646)\n(1,80,691.6666666666665,1424951957646)\n(0,55,573.6111111111112,1424951958646)\n(1,85,715.2777777777776,1424951958647)\n(0,60,590.2777777777778,1424951959647)\n(1,80,737.4999999999998,1424951959647)\n(0,65,608.3333333333334,1424951960647)\n(1,85,761.1111111111109,1424951960647)\n(0,70,627.7777777777778,1424951961647)\n(1,80,783.333333333333,1424951961648)\n(0,75,648.6111111111112,1424951962648)\n(1,85,806.9444444444441,1424951962648)\n(0,80,670.8333333333334,1424951963648)\n(1,90,831.9444444444441,1424951963648)\n(0,75,691.6666666666667,1424951964649)\n(1,95,858.333333333333,1424951964649)\n(0,70,711.1111111111112,1424951965649)\n(1,90,883.333333333333,1424951965649)\n(0,75,731.9444444444446,1424951966649)\n(1,95,909.722222222222,1424951966649)\n(0,70,751.388888888889,1424951967649)\n(1,100,937.4999999999998,1424951967650)\n(0,75,772.2222222222224,1424951968650)\n(1,100,965.2777777777776,1424951968650)\n(0,80,794.4444444444446,1424951969650)\n(1,100,993.0555555555554,1424951969650)\n(0,75,815.2777777777779,1424951970651)\n(1,100,1020.8333333333333,1424951970651)\n(0,80,837.5000000000001,1424951971651)\n(1,100,1048.611111111111,1424951971651)\n(0,85,861.1111111111112,1424951972651)\n(1,100,1076.388888888889,1424951972651)\n(0,80,883.3333333333334,1424951973652)\n(1,95,1102.7777777777778,1424951973652)\n(0,75,904.1666666666667,1424951974652)\n(1,100,1130.5555555555557,1424951974652)\n(0,70,923.6111111111112,1424951975652)\n(1,100,1158.3333333333335,1424951975652)\n(0,75,944.4444444444446,1424951976653)\n(1,100,1186.1111111111113,1424951976653)\n(0,80,966.6666666666667,1424951977653)\n(1,95,1212.5000000000002,1424951977653)\n(0,75,987.5000000000001,1424951978653)\n(1,100,1240.277777777778,1424951978653)\n(0,80,1009.7222222222223,1424951979654)\n(1,100,1268.0555555555559,1424951979654)\n(0,85,1033.3333333333335,1424951980654)\n(1,100,1295.8333333333337,1424951980654)\n(0,90,1058.3333333333335,1424951981654)\n(1,100,1323.6111111111115,1424951981654)\n(0,85,1081.9444444444446,1424951982655)\n(1,100,1351.3888888888894,1424951982655)\n(0,90,1106.9444444444446,1424951983655)\n(1,100,1379.1666666666672,1424951983655)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1406.944444444445,1424951984656)\n(0,90,1158.3333333333335,1424951985656)\n(1,95,1433.333333333334,1424951985656)\n(0,95,1184.7222222222224,1424951986656)\n(1,90,1458.333333333334,1424951986656)\n(0,90,1209.7222222222224,1424951987656)\n(1,95,1484.7222222222229,1424951987657)\n(0,85,1233.3333333333335,1424951988657)\n(1,90,1509.7222222222229,1424951988657)\n(0,80,1255.5555555555557,1424951989657)\n(1,95,1536.1111111111118,1424951989657)\n(0,85,1279.1666666666667,1424951990657)\n(1,100,1563.8888888888896,1424951990658)\n(0,90,1304.1666666666667,1424951991658)\n(1,95,1590.2777777777785,1424951991658)\n(0,95,1330.5555555555557,1424951992658)\n(1,90,1615.2777777777785,1424951992658)\n(0,100,1358.3333333333335,1424951993659)\n(1,95,1641.6666666666674,1424951993659)\n(0,100,1386.1111111111113,1424951994659)\n(1,100,1669.4444444444453,1424951994659)\n(0,95,1412.5000000000002,1424951995659)\n(1,95,1695.8333333333342,1424951995660)\n(0,100,1440.277777777778,1424951996660)\n(1,90,1720.8333333333342,1424951996660)\n(0,100,1468.0555555555559,1424951997660)\n(1,85,1744.4444444444453,1424951997660)\n(0,95,1494.4444444444448,1424951998660)\n(1,80,1766.6666666666674,1424951998661)\n(0,100,1522.2222222222226,1424951999661)\n(1,75,1787.5000000000007,1424951999661)\n(0,95,1548.6111111111115,1424952000661)\n(1,80,1809.7222222222229,1424952000661)\n(0,90,1573.6111111111115,1424952001662)\n(1,75,1830.555555555556,1424952001662)\n(0,95,1600.0000000000005,1424952002662)\n(1,80,1852.7777777777783,1424952002662)\n(0,100,1627.7777777777783,1424952003662)\n(1,85,1876.3888888888894,1424952003662)\n(0,100,1655.555555555556,1424952004663)\n(1,80,1898.6111111111115,1424952004663)\n(0,95,1681.944444444445,1424952005663)\n(1,85,1922.2222222222226,1424952005663)\n(0,100,1709.7222222222229,1424952006663)\n(1,90,1947.2222222222226,1424952006664)\n(0,100,1737.5000000000007,1424952007664)\n(1,95,1973.6111111111115,1424952007664)\n(0,95,1763.8888888888896,1424952008664)\n(1,90,1998.6111111111115,1424952008664)\n(0,100,1791.6666666666674,1424952009664)\n(1,85,2022.2222222222226,1424952009665)\n(0,95,1818.0555555555563,1424952010665)\n(1,80,2044.4444444444448,1424952010665)\n(0,90,1843.0555555555563,1424952011665)\n(1,75,2065.2777777777783,1424952011665)\n(0,95,1869.4444444444453,1424952012666)\n(1,80,2087.5000000000005,1424952012666)\n(0,100,1897.222222222223,1424952013666)\n(1,85,2111.1111111111118,1424952013666)\n(0,95,1923.611111111112,1424952014666)\n(1,90,2136.1111111111118,1424952014666)\n(0,100,1951.3888888888898,1424952015667)\n(1,85,2159.722222222223,1424952015667)\n(0,95,1977.7777777777787,1424952016667)\n(1,90,2184.722222222223,1424952016667)\n(0,100,2005.5555555555566,1424952017667)\n(1,95,2211.1111111111118,1424952017668)"
public static final String	TOP_CASE_CLASS_SPEEDS	"CarEvent(0,55,15.277777777777777,1424951918630)\nCarEvent(1,50,26.38888888888889,1424951919632)\nCarEvent(0,65,108.33333333333333,1424951924635)\nCarEvent(1,50,26.38888888888889,1424951919632)\nCarEvent(0,65,108.33333333333333,1424951924635)\nCarEvent(1,65,194.4444444444444,1424951932638)\nCarEvent(0,65,108.33333333333333,1424951924635)\nCarEvent(1,70,213.88888888888886,1424951933638)\nCarEvent(0,60,218.05555555555551,1424951931637)\nCarEvent(1,75,272.2222222222222,1424951936639)\nCarEvent(0,55,233.3333333333333,1424951932637)\nCarEvent(1,75,272.2222222222222,1424951936639)\nCarEvent(1,75,272.2222222222222,1424951936639)\nCarEvent(0,55,288.88888888888886,1424951936639)\nCarEvent(1,70,329.16666666666663,1424951939640)\nCarEvent(0,55,373.61111111111114,1424951942641)\nCarEvent(1,80,519.4444444444443,1424951949644)\nCarEvent(1,85,586.111111111111,1424951952645)\nCarEvent(0,50,487.50000000000006,1424951951644)\nCarEvent(1,85,586.111111111111,1424951952645)\nCarEvent(0,60,590.2777777777778,1424951959647)\nCarEvent(1,85,586.111111111111,1424951952645)\nCarEvent(0,75,648.6111111111112,1424951962648)\nCarEvent(1,85,715.2777777777776,1424951958647)\nCarEvent(1,95,858.333333333333,1424951964649)\nCarEvent(0,80,670.8333333333334,1424951963648)\nCarEvent(1,95,858.333333333333,1424951964649)\nCarEvent(0,80,670.8333333333334,1424951963648)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(0,80,670.8333333333334,1424951963648)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(0,85,861.1111111111112,1424951972651)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(1,100,937.4999999999998,1424951967650)\nCarEvent(0,85,861.1111111111112,1424951972651)\nCarEvent(1,100,993.0555555555554,1424951969650)\nCarEvent(0,85,861.1111111111112,1424951972651)\nCarEvent(1,100,1048.611111111111,1424951971651)\nCarEvent(1,100,1130.5555555555557,1424951974652)\nCarEvent(0,90,1058.3333333333335,1424951981654)\nCarEvent(1,100,1158.3333333333335,1424951975652)\nCarEvent(0,95,1133.3333333333335,1424951984655)\nCarEvent(1,100,1240.277777777778,1424951978653)\nCarEvent(0,95,1133.3333333333335,1424951984655)\nCarEvent(1,100,1268.0555555555559,1424951979654)\nCarEvent(0,95,1133.3333333333335,1424951984655)\nCarEvent(1,100,1323.6111111111115,1424951981654)\nCarEvent(0,95,1133.3333333333335,1424951984655)\nCarEvent(1,100,1379.1666666666672,1424951983655)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(1,100,1563.8888888888896,1424951990658)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(1,100,1563.8888888888896,1424951990658)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(1,100,1563.8888888888896,1424951990658)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(0,100,1358.3333333333335,1424951993659)\nCarEvent(1,100,1669.4444444444453,1424951994659)\nCarEvent(0,100,1440.277777777778,1424951996660)\nCarEvent(1,90,1720.8333333333342,1424951996660)\nCarEvent(0,100,1468.0555555555559,1424951997660)\nCarEvent(1,95,1973.6111111111115,1424952007664)\nCarEvent(0,100,1522.2222222222226,1424951999661)\nCarEvent(0,100,1627.7777777777783,1424952003662)\nCarEvent(1,95,1973.6111111111115,1424952007664)\nCarEvent(0,100,1627.7777777777783,1424952003662)\nCarEvent(1,95,1973.6111111111115,1424952007664)\nCarEvent(0,100,1709.7222222222229,1424952006663)\nCarEvent(0,100,1737.5000000000007,1424952007664)\nCarEvent(1,95,1973.6111111111115,1424952007664)\n"
public static final String	TOP_SPEEDS	"(0,55,15.277777777777777,1424951918630)\n(1,50,26.38888888888889,1424951919632)\n(0,65,108.33333333333333,1424951924635)\n(1,50,26.38888888888889,1424951919632)\n(0,65,108.33333333333333,1424951924635)\n(1,65,194.4444444444444,1424951932638)\n(0,65,108.33333333333333,1424951924635)\n(1,70,213.88888888888886,1424951933638)\n(0,60,218.05555555555551,1424951931637)\n(1,75,272.2222222222222,1424951936639)\n(0,55,233.3333333333333,1424951932637)\n(1,75,272.2222222222222,1424951936639)\n(1,75,272.2222222222222,1424951936639)\n(0,55,288.88888888888886,1424951936639)\n(1,70,329.16666666666663,1424951939640)\n(0,55,373.61111111111114,1424951942641)\n(1,80,519.4444444444443,1424951949644)\n(1,85,586.111111111111,1424951952645)\n(0,50,487.50000000000006,1424951951644)\n(1,85,586.111111111111,1424951952645)\n(0,60,590.2777777777778,1424951959647)\n(1,85,586.111111111111,1424951952645)\n(0,75,648.6111111111112,1424951962648)\n(1,85,715.2777777777776,1424951958647)\n(1,95,858.333333333333,1424951964649)\n(0,80,670.8333333333334,1424951963648)\n(1,95,858.333333333333,1424951964649)\n(0,80,670.8333333333334,1424951963648)\n(1,100,937.4999999999998,1424951967650)\n(1,100,937.4999999999998,1424951967650)\n(0,80,670.8333333333334,1424951963648)\n(1,100,937.4999999999998,1424951967650)\n(0,85,861.1111111111112,1424951972651)\n(1,100,937.4999999999998,1424951967650)\n(1,100,937.4999999999998,1424951967650)\n(0,85,861.1111111111112,1424951972651)\n(1,100,993.0555555555554,1424951969650)\n(0,85,861.1111111111112,1424951972651)\n(1,100,1048.611111111111,1424951971651)\n(1,100,1130.5555555555557,1424951974652)\n(0,90,1058.3333333333335,1424951981654)\n(1,100,1158.3333333333335,1424951975652)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1240.277777777778,1424951978653)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1268.0555555555559,1424951979654)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1323.6111111111115,1424951981654)\n(0,95,1133.3333333333335,1424951984655)\n(1,100,1379.1666666666672,1424951983655)\n(0,100,1358.3333333333335,1424951993659)\n(1,100,1563.8888888888896,1424951990658)\n(0,100,1358.3333333333335,1424951993659)\n(1,100,1563.8888888888896,1424951990658)\n(0,100,1358.3333333333335,1424951993659)\n(1,100,1563.8888888888896,1424951990658)\n(0,100,1358.3333333333335,1424951993659)\n(0,100,1358.3333333333335,1424951993659)\n(1,100,1669.4444444444453,1424951994659)\n(0,100,1440.277777777778,1424951996660)\n(1,90,1720.8333333333342,1424951996660)\n(0,100,1468.0555555555559,1424951997660)\n(1,95,1973.6111111111115,1424952007664)\n(0,100,1522.2222222222226,1424951999661)\n(0,100,1627.7777777777783,1424952003662)\n(1,95,1973.6111111111115,1424952007664)\n(0,100,1627.7777777777783,1424952003662)\n(1,95,1973.6111111111115,1424952007664)\n(0,100,1709.7222222222229,1424952006663)\n(0,100,1737.5000000000007,1424952007664)\n(1,95,1973.6111111111115,1424952007664)\n"

org.apache.flink.streaming.runtime.io.StreamTaskInput

Modifier and Type	Constant Field	Value
public static final int	UNSPECIFIED	-1

org.apache.flink.streaming.runtime.streamstatus.StreamStatus

Modifier and Type	Constant Field	Value
public static final int	ACTIVE_STATUS	0
public static final int	IDLE_STATUS	-1

org.apache.flink.streaming.tests.queryablestate.QsConstants

Modifier and Type	Constant Field	Value
public static final String	KEY	""
public static final String	QUERY_NAME	"state"
public static final String	STATE_NAME	"state"

org.apache.flink.table.api.EnvironmentSettings

Modifier and Type	Constant Field	Value
public static final String	CLASS_NAME	"class-name"
public static final String	DEFAULT_BUILTIN_CATALOG	"default_catalog"
public static final String	DEFAULT_BUILTIN_DATABASE	"default_database"
public static final String	STREAMING_MODE	"streaming-mode"

org.apache.flink.table.catalog.GenericInMemoryCatalog

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DB	"default"

org.apache.flink.table.catalog.config.CatalogConfig

Modifier and Type	Constant Field	Value
public static final String	FLINK_PROPERTY_PREFIX	"flink."
public static final String	IS_GENERIC	"is_generic"

org.apache.flink.table.catalog.hive.HiveCatalog

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DB	"default"

org.apache.flink.table.catalog.hive.HiveCatalogConfig

Modifier and Type	Constant Field	Value
public static final String	COMMENT	"comment"
public static final String	DATABASE_LOCATION_URI	"database.location_uri"
public static final String	DEFAULT_LIST_COLUMN_TYPES_SEPARATOR	":"
public static final String	PARTITION_LOCATION	"partition.location"

org.apache.flink.table.catalog.hive.client.HiveShimLoader

Modifier and Type	Constant Field	Value
public static final String	HIVE_V1_VERSION_NAME	"1.2.1"
public static final String	HIVE_V2_VERSION_NAME	"2.3.4"

org.apache.flink.table.catalog.hive.descriptors.HiveCatalogValidator

Modifier and Type	Constant Field	Value
public static final String	CATALOG_HIVE_CONF_DIR	"hive-conf-dir"
public static final String	CATALOG_HIVE_VERSION	"hive-version"
public static final String	CATALOG_TYPE_VALUE_HIVE	"hive"

org.apache.flink.table.catalog.hive.util.HiveStatsUtil

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_STATS_ZERO_CONST	"0"

org.apache.flink.table.client.SqlClient

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_SESSION_ID	"default"
public static final String	MODE_EMBEDDED	"embedded"
public static final String	MODE_GATEWAY	"gateway"

org.apache.flink.table.client.cli.CliResultView<O extends Enum<O>>

Modifier and Type	Constant Field	Value
protected static final int	MAX_COLUMN_WIDTH	25
protected static final int	NO_ROW_SELECTED	-1

org.apache.flink.table.client.cli.CliStrings

Modifier and Type	Constant Field	Value
public static final String	CLI_NAME	"Flink SQL CLI Client"
public static final String	DEFAULT_MARGIN	" "
public static final String	INPUT_ENTER_PAGE	"Enter page number:"
public static final String	INPUT_ERROR	"The input is invalid please check it again."
public static final String	INPUT_TITLE	"Input Dialog"
public static final String	MESSAGE_EMPTY	"Result was empty."
public static final String	MESSAGE_MAX_SIZE_EXCEEDED	"The given file exceeds the maximum number of characters."
public static final String	MESSAGE_QUIT	"Exiting Flink SQL CLI Client..."
public static final String	MESSAGE_RESET	"All session properties have been set to their default values."
public static final String	MESSAGE_RESULT_QUIT	"Result retrieval cancelled."
public static final String	MESSAGE_RESULT_SNAPSHOT_ERROR	"Could not create a snapshot of the dynamic table."
public static final String	MESSAGE_SET	"Session property has been set."
public static final String	MESSAGE_SQL_EXECUTION_ERROR	"Could not execute SQL statement."
public static final String	MESSAGE_STATEMENT_SUBMITTED	"Table update statement has been successfully submitted to the cluster:"
public static final String	MESSAGE_SUBMITTING_STATEMENT	"Submitting SQL update statement to the cluster..."
public static final String	MESSAGE_UNKNOWN_SQL	"Unknown or invalid SQL statement."
public static final String	MESSAGE_UNKNOWN_TABLE	"Unknown table."
public static final String	MESSAGE_UNSUPPORTED_SQL	"Unsupported SQL statement."
public static final String	MESSAGE_VIEW_ALREADY_EXISTS	"A view with this name has already been defined in the current CLI session."
public static final String	MESSAGE_VIEW_CREATED	"View has been created."
public static final String	MESSAGE_VIEW_NOT_FOUND	"The given view does not exist in the current CLI session. Only views created with a CREATE VIEW statement can be accessed."
public static final String	MESSAGE_VIEW_NOT_REMOVED	"The given view cannot be removed without affecting other views."
public static final String	MESSAGE_VIEW_REMOVED	"View has been removed."
public static final String	MESSAGE_WILL_EXECUTE	"Executing the following statement:"
public static final String	NULL_COLUMN	"(NULL)"
public static final String	RESULT_CHANGELOG	"Changelog"
public static final String	RESULT_DEC_REFRESH	"Dec Refresh"
public static final String	RESULT_FIRST	"First Page"
public static final String	RESULT_GOTO	"Goto Page"
public static final String	RESULT_INC_REFRESH	"Inc Refresh"
public static final String	RESULT_LAST	"Last Page"
public static final String	RESULT_LAST_PAGE	"Last"
public static final String	RESULT_LAST_REFRESH	"Updated:"
public static final String	RESULT_NEXT	"Next Page"
public static final String	RESULT_OPEN	"Open Row"
public static final String	RESULT_PAGE	"Page:"
public static final String	RESULT_PAGE_OF	" of "
public static final String	RESULT_PREV	"Prev Page"
public static final String	RESULT_QUIT	"Quit"
public static final String	RESULT_REFRESH	"Refresh"
public static final String	RESULT_REFRESH_INTERVAL	"Refresh:"
public static final String	RESULT_REFRESH_UNKNOWN	"Unknown"
public static final String	RESULT_SEARCH	"Search"
public static final String	RESULT_STOPPED	"Table program finished."
public static final String	RESULT_TABLE	"Table"
public static final String	RESULT_TITLE	"SQL Query Result"
public static final String	ROW_HEADER	"Row Summary"

org.apache.flink.table.client.config.Environment

Modifier and Type	Constant Field	Value
public static final String	CONFIGURATION_ENTRY	"table"
public static final String	DEPLOYMENT_ENTRY	"deployment"
public static final String	EXECUTION_ENTRY	"execution"

org.apache.flink.table.client.config.entries.CatalogEntry

Modifier and Type	Constant Field	Value
public static final String	CATALOG_NAME	"name"

org.apache.flink.table.client.config.entries.ExecutionEntry

Modifier and Type	Constant Field	Value
public static final String	EXECUTION_CURRENT_CATALOG	"current-catalog"
public static final String	EXECUTION_CURRENT_DATABASE	"current-database"
public static final String	EXECUTION_PLANNER_VALUE_BLINK	"blink"
public static final String	EXECUTION_PLANNER_VALUE_OLD	"old"

org.apache.flink.table.client.config.entries.FunctionEntry

Modifier and Type	Constant Field	Value
public static final String	FUNCTIONS_NAME	"name"

org.apache.flink.table.client.config.entries.TableEntry

Modifier and Type	Constant Field	Value
public static final String	TABLES_NAME	"name"

org.apache.flink.table.client.gateway.local.result.MaterializedCollectStreamResult<C>

Modifier and Type	Constant Field	Value
public static final double	MATERIALIZED_TABLE_CAPACITY_FACTOR	0.05
public static final int	MATERIALIZED_TABLE_MAX_INITIAL_CAPACITY	1000000
public static final int	MATERIALIZED_TABLE_MAX_OVERCOMMIT	1000000
public static final double	MATERIALIZED_TABLE_OVERCOMMIT_FACTOR	0.01

org.apache.flink.table.dataformat.BinaryFormat

Modifier and Type	Constant Field	Value
public static final long	HIGHEST_FIRST_BIT	-9223372036854775808L
public static final long	HIGHEST_SECOND_TO_EIGHTH_BIT	9151314442816847872L
public static final int	MAX_FIX_PART_DATA_SIZE	7

org.apache.flink.table.dataformat.BinaryRow

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