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

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.ClusterClient<T>

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

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 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	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_INTERVAL_SUFFIX	"interval"
public static final String	METRICS_REPORTER_PREFIX	"metrics.reporter."
public static final String	METRICS_REPORTER_SCOPE_DELIMITER	"scope.delimiter"
public static final String	METRICS_REPORTERS_LIST	"metrics.reporters"
public static final String	METRICS_SCOPE_DELIMITER	"metrics.scope.delimiter"
public static final String	METRICS_SCOPE_NAMING_JM	"metrics.scope.jm"
public static final String	METRICS_SCOPE_NAMING_JM_JOB	"metrics.scope.jm.job"
public static final String	METRICS_SCOPE_NAMING_OPERATOR	"metrics.scope.operator"
public static final String	METRICS_SCOPE_NAMING_TASK	"metrics.scope.task"
public static final String	METRICS_SCOPE_NAMING_TM	"metrics.scope.tm"
public static final String	METRICS_SCOPE_NAMING_TM_JOB	"metrics.scope.tm.job"
public static final String	PATH_HADOOP_CONFIG	"fs.hdfs.hadoopconf"
public static final String	RECOVERY_JOB_DELAY	"recovery.job.delay"
public static final String	RECOVERY_JOB_MANAGER_PORT	"recovery.jobmanager.port"
public static final String	RECOVERY_MODE	"recovery.mode"
public static final String	RESOURCE_MANAGER_IPC_PORT_KEY	"resourcemanager.rpc.port"
public static final String	RESTART_STRATEGY	"restart-strategy"
public static final String	RESTART_STRATEGY_FAILURE_RATE_DELAY	"restart-strategy.failure-rate.delay"
public static final String	RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL	"restart-strategy.failure-rate.failure-rate-interval"
public static final String	RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL	"restart-strategy.failure-rate.max-failures-per-interval"
public static final String	RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS	"restart-strategy.fixed-delay.attempts"
public static final String	RUNTIME_HASH_JOIN_BLOOM_FILTERS_KEY	"taskmanager.runtime.hashjoin-bloom-filters"
public static final String	SAVEPOINT_DIRECTORY_KEY	"state.savepoints.dir"
public static final String	SAVEPOINT_FS_DIRECTORY_KEY	"savepoints.state.backend.fs.dir"
public static final String	SECURITY_SSL_ALGORITHMS	"security.ssl.algorithms"
public static final String	SECURITY_SSL_ENABLED	"security.ssl.enabled"
public static final String	SECURITY_SSL_KEY_PASSWORD	"security.ssl.key-password"
public static final String	SECURITY_SSL_KEYSTORE	"security.ssl.keystore"
public static final String	SECURITY_SSL_KEYSTORE_PASSWORD	"security.ssl.keystore-password"
public static final String	SECURITY_SSL_PROTOCOL	"security.ssl.protocol"
public static final String	SECURITY_SSL_TRUSTSTORE	"security.ssl.truststore"
public static final String	SECURITY_SSL_TRUSTSTORE_PASSWORD	"security.ssl.truststore-password"
public static final String	SECURITY_SSL_VERIFY_HOSTNAME	"security.ssl.verify-hostname"
public static final String	STATE_BACKEND	"state.backend"
public static final String	TASK_CANCELLATION_INTERVAL_MILLIS	"task.cancellation-interval"
public static final String	TASK_MANAGER_DATA_PORT_KEY	"taskmanager.data.port"
public static final String	TASK_MANAGER_DATA_SSL_ENABLED	"taskmanager.data.ssl.enabled"
public static final String	TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS	"taskmanager.debug.memory.logIntervalMs"
public static final String	TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD	"taskmanager.debug.memory.startLogThread"
public static final String	TASK_MANAGER_HOSTNAME_KEY	"taskmanager.hostname"
public static final String	TASK_MANAGER_INITIAL_REGISTRATION_PAUSE	"taskmanager.initial-registration-pause"
public static final String	TASK_MANAGER_IPC_PORT_KEY	"taskmanager.rpc.port"
public static final String	TASK_MANAGER_LOG_PATH_KEY	"taskmanager.log.path"
public static final String	TASK_MANAGER_MAX_REGISTARTION_PAUSE	"taskmanager.max-registration-pause"
public static final String	TASK_MANAGER_MAX_REGISTRATION_DURATION	"taskmanager.maxRegistrationDuration"
public static final String	TASK_MANAGER_MEMORY_FRACTION_KEY	"taskmanager.memory.fraction"
public static final String	TASK_MANAGER_MEMORY_OFF_HEAP_KEY	"taskmanager.memory.off-heap"
public static final String	TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY	"taskmanager.memory.preallocate"
public static final String	TASK_MANAGER_MEMORY_SEGMENT_SIZE_KEY	"taskmanager.memory.segment-size"
public static final String	TASK_MANAGER_MEMORY_SIZE_KEY	"taskmanager.memory.size"
public static final String	TASK_MANAGER_NETWORK_DEFAULT_IO_MODE	"taskmanager.network.defaultIOMode"
public static final String	TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY	"taskmanager.network.numberOfBuffers"
public static final String	TASK_MANAGER_NUM_TASK_SLOTS	"taskmanager.numberOfTaskSlots"
public static final String	TASK_MANAGER_REFUSED_REGISTRATION_PAUSE	"taskmanager.refused-registration-pause"
public static final String	TASK_MANAGER_TMP_DIR_KEY	"taskmanager.tmp.dirs"
public static final String	USE_LARGE_RECORD_HANDLER_KEY	"taskmanager.runtime.large-record-handler"
public static final String	YARN_APPLICATION_ATTEMPTS	"yarn.application-attempts"
public static final String	YARN_APPLICATION_MASTER_ENV_PREFIX	"yarn.application-master.env."
public static final String	YARN_APPLICATION_MASTER_PORT	"yarn.application-master.port"
public static final String	YARN_APPLICATION_TAGS	"yarn.tags"
public static final String	YARN_CONTAINER_START_COMMAND_TEMPLATE	"yarn.container-start-command-template"
public static final String	YARN_HEAP_CUTOFF_MIN	"yarn.heap-cutoff-min"
public static final String	YARN_HEAP_CUTOFF_RATIO	"yarn.heap-cutoff-ratio"
public static final String	YARN_HEARTBEAT_DELAY_SECONDS	"yarn.heartbeat-delay"
public static final String	YARN_MAX_FAILED_CONTAINERS	"yarn.maximum-failed-containers"
public static final String	YARN_PROPERTIES_FILE_LOCATION	"yarn.properties-file.location"
public static final String	YARN_REALLOCATE_FAILED_CONTAINERS	"yarn.reallocate-failed"
public static final String	YARN_TASK_MANAGER_ENV_PREFIX	"yarn.taskmanager.env."
public static final String	YARN_VCORES	"yarn.containers.vcores"
public static final String	ZOOKEEPER_CHECKPOINT_COUNTER_PATH	"recovery.zookeeper.path.checkpoint-counter"
public static final String	ZOOKEEPER_CHECKPOINTS_PATH	"recovery.zookeeper.path.checkpoints"
public static final String	ZOOKEEPER_CONNECTION_TIMEOUT	"recovery.zookeeper.client.connection-timeout"
public static final String	ZOOKEEPER_DIR_KEY	"recovery.zookeeper.path.root"
public static final String	ZOOKEEPER_JOBGRAPHS_PATH	"recovery.zookeeper.path.jobgraphs"
public static final String	ZOOKEEPER_LATCH_PATH	"recovery.zookeeper.path.latch"
public static final String	ZOOKEEPER_LEADER_PATH	"recovery.zookeeper.path.leader"
public static final String	ZOOKEEPER_MAX_RETRY_ATTEMPTS	"recovery.zookeeper.client.max-retry-attempts"
public static final String	ZOOKEEPER_MESOS_WORKERS_PATH	"recovery.zookeeper.path.mesos-workers"
public static final String	ZOOKEEPER_NAMESPACE_KEY	"recovery.zookeeper.path.namespace"
public static final String	ZOOKEEPER_QUORUM_KEY	"recovery.zookeeper.quorum"
public static final String	ZOOKEEPER_RECOVERY_PATH	"recovery.zookeeper.storageDir"
public static final String	ZOOKEEPER_RETRY_WAIT	"recovery.zookeeper.client.retry-wait"
public static final String	ZOOKEEPER_SASL_DISABLE	"zookeeper.sasl.disable"
public static final String	ZOOKEEPER_SASL_SERVICE_NAME	"zookeeper.sasl.service-name"
public static final String	ZOOKEEPER_SESSION_TIMEOUT	"recovery.zookeeper.client.session-timeout"

org.apache.flink.configuration.CoreOptions

Modifier and Type	Constant Field	Value
public static final String	LEGACY_MODE	"legacy"
public static final String	NEW_MODE	"new"

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.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.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.entrypoint.MesosJobClusterEntrypoint

Modifier and Type	Constant Field	Value
public static final String	JOB_GRAPH_FILE_PATH	"flink.jobgraph.path"

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	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.jmx.JMXReporter

Modifier and Type	Constant Field	Value
public static final String	ARG_PORT	"port"

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.python.api.PythonPlanBinder

Modifier and Type	Constant Field	Value
public static final String	FLINK_PYTHON_DC_ID	"flink"
public static final String	PLAN_ARGUMENTS_KEY	"python.plan.arguments"
public static final String	PLANBINDER_CONFIG_BCVAR_COUNT	"PLANBINDER_BCVAR_COUNT"
public static final String	PLANBINDER_CONFIG_BCVAR_NAME_PREFIX	"PLANBINDER_BCVAR_"

org.apache.flink.python.api.streaming.data.PythonSender

Modifier and Type	Constant Field	Value
public static final byte	TYPE_ARRAY	63
public static final byte	TYPE_KEY_VALUE	62
public static final byte	TYPE_VALUE_VALUE	61

org.apache.flink.python.api.streaming.data.PythonStreamer<S extends PythonSender,OUT>

Modifier and Type	Constant Field	Value
protected static final int	SIGNAL_BUFFER_REQUEST	0
protected static final int	SIGNAL_BUFFER_REQUEST_G0	-3
protected static final int	SIGNAL_BUFFER_REQUEST_G1	-4
protected static final int	SIGNAL_ERROR	-2
protected static final int	SIGNAL_FINISHED	-1
protected static final byte	SIGNAL_LAST	32

org.apache.flink.python.api.streaming.util.SerializationUtils

Modifier and Type	Constant Field	Value
public static final byte	TYPE_BOOLEAN	34
public static final byte	TYPE_BYTE	33
public static final byte	TYPE_BYTES	27
public static final byte	TYPE_DOUBLE	30
public static final byte	TYPE_FLOAT	29
public static final byte	TYPE_INTEGER	32
public static final byte	TYPE_LONG	31
public static final byte	TYPE_NULL	26
public static final byte	TYPE_STRING	28

org.apache.flink.runtime.blob.BlobKey

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

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.clusterframework.FlinkResourceManager<WorkerType extends ResourceIDRetrievable>

Modifier and Type	Constant Field	Value
protected static final int	EXIT_CODE_FATAL_ERROR	-13
public static final String	RESOURCE_MANAGER_NAME	"resourcemanager"

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
protected static final int	SUCCESS_RETURN_CODE	0

org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder

Modifier and Type	Constant Field	Value
public static final String	PARALLELISM_AUTO_MAX_ERROR_MESSAGE	"PARALLELISM_AUTO_MAX is no longer supported. Please specify a concrete value for the parallelism."

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.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	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.iterative.convergence.WorksetEmptyConvergenceCriterion

Modifier and Type	Constant Field	Value
public static final String	AGGREGATOR_NAME	"pact.runtime.workset-empty-aggregator"

org.apache.flink.runtime.jobmaster.JobMaster

Modifier and Type	Constant Field	Value
public static final String	ARCHIVE_NAME	"archive"
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_IN_LOCAL	"numBuffersInLocal"
public static final String	IO_NUM_BUFFERS_IN_LOCAL_RATE	"numBuffersInLocalPerSecond"
public static final String	IO_NUM_BUFFERS_IN_REMOTE	"numBuffersInRemote"
public static final String	IO_NUM_BUFFERS_IN_REMOTE_RATE	"numBuffersInRemotePerSecond"
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_LOCAL	"numBytesInLocal"
public static final String	IO_NUM_BYTES_IN_LOCAL_RATE	"numBytesInLocalPerSecond"
public static final String	IO_NUM_BYTES_IN_REMOTE	"numBytesInRemote"
public static final String	IO_NUM_BYTES_IN_REMOTE_RATE	"numBytesInRemotePerSecond"
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	NUM_REGISTERED_TASK_MANAGERS	"numRegisteredTaskManagers"
public static final String	NUM_RUNNING_JOBS	"numRunningJobs"
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.legacy.DashboardConfigHandler

Modifier and Type	Constant Field	Value
public static final String	DASHBOARD_CONFIG_REST_PATH	"/config"

org.apache.flink.runtime.rest.handler.legacy.SubtaskCurrentAttemptDetailsHandler

Modifier and Type	Constant Field	Value
public static final String	SUBTASK_CURRENT_ATTEMPT_DETAILS_REST_PATH	"/jobs/:jobid/vertices/:vertexid/subtasks/:subtasknum"

org.apache.flink.runtime.rest.handler.legacy.SubtaskExecutionAttemptDetailsHandler

Modifier and Type	Constant Field	Value
public static final String	PARAMETER_SUBTASK_INDEX	"subtasknum"

org.apache.flink.runtime.rest.handler.legacy.TaskManagersHandler

Modifier and Type	Constant Field	Value
public static final String	TASK_MANAGER_ID_KEY	"taskmanagerid"

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.handler.legacy.metrics.AbstractMetricsHandler

Modifier and Type	Constant Field	Value
public static final String	PARAMETER_METRICS	"get"

org.apache.flink.runtime.rest.handler.legacy.metrics.JobMetricsHandler

Modifier and Type	Constant Field	Value
public static final String	PARAMETER_JOB_ID	"jobid"

org.apache.flink.runtime.rest.handler.legacy.metrics.JobVertexMetricsHandler

Modifier and Type	Constant Field	Value
public static final String	PARAMETER_VERTEX_ID	"vertexid"

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

Modifier and Type	Constant Field	Value
public static final String	URL	"/jobs/:jobid"

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

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	3

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	DEFAULT_WRITE_BUFFER_SIZE	4096
public static final int	MAX_FILE_STATE_THRESHOLD	1048576

org.apache.flink.runtime.state.filesystem.FsStateBackend

Modifier and Type	Constant Field	Value
public static final int	MAX_FILE_STATE_THRESHOLD	1048576

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

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

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

Modifier and Type	Constant Field	Value
public static final String	WEB_MONITOR_ADDRESS_KEY	"web.monitor.address"

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.storm.api.FlinkLocalCluster

Modifier and Type	Constant Field	Value
public static final String	SUBMIT_BLOCKING	"SUBMIT_STORM_TOPOLOGY_BLOCKING"

org.apache.flink.storm.exclamation.ExclamationLocal

Modifier and Type	Constant Field	Value
public static final String	TOPOLOGY_ID	"Streaming Exclamation"

org.apache.flink.storm.exclamation.operators.ExclamationBolt

Modifier and Type	Constant Field	Value
public static final String	EXCLAMATION_COUNT	"exclamation.count"

org.apache.flink.storm.split.operators.RandomSpout

Modifier and Type	Constant Field	Value
public static final String	EVEN_STREAM	"even"
public static final String	ODD_STREAM	"odd"

org.apache.flink.storm.util.AbstractLineSpout

Modifier and Type	Constant Field	Value
public static final String	ATTRIBUTE_LINE	"line"

org.apache.flink.storm.util.FileSpout

Modifier and Type	Constant Field	Value
public static final String	INPUT_FILE_PATH	"input.path"

org.apache.flink.storm.wordcount.operators.BoltCounter

Modifier and Type	Constant Field	Value
public static final String	ATTRIBUTE_COUNT	"count"
public static final String	ATTRIBUTE_WORD	"word"

org.apache.flink.storm.wordcount.operators.BoltCounterByName

Modifier and Type	Constant Field	Value
public static final String	ATTRIBUTE_COUNT	"count"
public static final String	ATTRIBUTE_WORD	"word"

org.apache.flink.storm.wordcount.operators.BoltTokenizer

Modifier and Type	Constant Field	Value
public static final String	ATTRIBUTE_COUNT	"count"
public static final int	ATTRIBUTE_COUNT_INDEX	1
public static final String	ATTRIBUTE_WORD	"word"
public static final int	ATTRIBUTE_WORD_INDEX	0

org.apache.flink.storm.wordcount.operators.BoltTokenizerByName

Modifier and Type	Constant Field	Value
public static final String	ATTRIBUTE_COUNT	"count"
public static final int	ATTRIBUTE_COUNT_INDEX	1
public static final String	ATTRIBUTE_WORD	"word"
public static final int	ATTRIBUTE_WORD_INDEX	0

org.apache.flink.storm.wrappers.BoltWrapper<IN,OUT>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_ID	"default ID"
public static final String	DEFUALT_BOLT_NAME	"Unnamed Bolt"

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

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

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.streaming.api.operators.InternalTimerServiceSerializationProxy<K,N>

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

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.elasticsearch.ElasticsearchSinkBase<T>

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.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.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.python.api.environment.PythonConstants

Modifier and Type	Constant Field	Value
public static final String	FLINK_PYTHON_DC_ID	"flink"

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.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_INVALID_PATH	"Path is invalid."
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_UNKNOWN_SQL	"Unknown SQL statement."
public static final String	MESSAGE_UNKNOWN_TABLE	"Unknown table."
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.PropertyStrings

Modifier and Type	Constant Field	Value
public static final String	DEPLOYMENT	"deployment"
public static final String	DEPLOYMENT_GATEWAY_ADDRESS	"gateway-address"
public static final String	DEPLOYMENT_GATEWAY_PORT	"gateway-port"
public static final String	DEPLOYMENT_RESPONSE_TIMEOUT	"response-timeout"
public static final String	DEPLOYMENT_TYPE	"type"
public static final String	DEPLOYMENT_TYPE_VALUE_STANDALONE	"standalone"
public static final String	EXECUTION	"execution"
public static final String	EXECUTION_MAX_PARALLELISM	"max-parallelism"
public static final String	EXECUTION_MAX_STATE_RETENTION	"max-idle-state-retention"
public static final String	EXECUTION_MIN_STATE_RETENTION	"min-idle-state-retention"
public static final String	EXECUTION_PARALLELISM	"parallelism"
public static final String	EXECUTION_RESULT_MODE	"result-mode"
public static final String	EXECUTION_RESULT_MODE_VALUE_CHANGELOG	"changelog"
public static final String	EXECUTION_RESULT_MODE_VALUE_TABLE	"table"
public static final String	EXECUTION_TIME_CHARACTERISTIC	"time-characteristic"
public static final String	EXECUTION_TIME_CHARACTERISTIC_VALUE_EVENT_TIME	"event-time"
public static final String	EXECUTION_TIME_CHARACTERISTIC_VALUE_PROCESSING_TIME	"processing-time"
public static final String	EXECUTION_TYPE	"type"
public static final String	EXECUTION_TYPE_VALUE_BATCH	"batch"
public static final String	EXECUTION_TYPE_VALUE_STREAMING	"streaming"

org.apache.flink.table.descriptors.JsonValidator

Modifier and Type	Constant Field	Value
public static final String	FORMAT_FAIL_ON_MISSING_FIELD	"format.fail-on-missing-field"
public static final String	FORMAT_JSON_SCHEMA	"format.json-schema"
public static final String	FORMAT_SCHEMA	"format.schema"
public static final String	FORMAT_TYPE_VALUE	"json"

org.apache.flink.table.descriptors.KafkaValidator

Modifier and Type	Constant Field	Value
public static final String	CONNECTOR_PROPERTIES	"connector.properties"
public static final String	CONNECTOR_PROPERTIES_KEY	"key"
public static final String	CONNECTOR_PROPERTIES_VALUE	"value"
public static final String	CONNECTOR_SPECIFIC_OFFSETS	"connector.specific-offsets"
public static final String	CONNECTOR_SPECIFIC_OFFSETS_OFFSET	"offset"
public static final String	CONNECTOR_SPECIFIC_OFFSETS_PARTITION	"partition"
public static final String	CONNECTOR_STARTUP_MODE	"connector.startup-mode"
public static final String	CONNECTOR_STARTUP_MODE_VALUE_EARLIEST	"earliest-offset"
public static final String	CONNECTOR_STARTUP_MODE_VALUE_GROUP_OFFSETS	"group-offsets"
public static final String	CONNECTOR_STARTUP_MODE_VALUE_LATEST	"latest-offset"
public static final String	CONNECTOR_STARTUP_MODE_VALUE_SPECIFIC_OFFSETS	"specific-offsets"
public static final String	CONNECTOR_TOPIC	"connector.topic"
public static final String	CONNECTOR_TYPE_VALUE_KAFKA	"kafka"
public static final String	CONNECTOR_VERSION_VALUE_010	"0.10"
public static final String	CONNECTOR_VERSION_VALUE_011	"0.11"
public static final String	CONNECTOR_VERSION_VALUE_08	"0.8"
public static final String	CONNECTOR_VERSION_VALUE_09	"0.9"

org.apache.flink.test.testdata.EnumTriangleData

Modifier and Type	Constant Field	Value
public static final String	EDGES	"1 2\n1 3\n1 4\n1 5\n2 3\n2 5\n3 4\n3 7\n5 6\n3 8\n7 8\n"
public static final String	TRIANGLES_BY_DEGREE	"2,1,3\n4,1,3\n2,1,5\n7,3,8\n"
public static final String	TRIANGLES_BY_ID	"1,2,3\n1,3,4\n1,2,5\n3,7,8\n"

org.apache.flink.test.testdata.KMeansData

Modifier and Type	Constant Field	Value
public static final String	CENTERS_2D_AFTER_20_ITERATIONS_DOUBLE_DIGIT	"0|15.80|79.42|\n1|43.11|78.20|\n2|83.13|82.18|\n3|65.70|18.49|\n4|25.13|44.42|\n5|82.90|48.16|\n6|20.79|13.08|"
public static final String	CENTERS_2D_AFTER_SINGLE_ITERATION_DOUBLE_DIGIT	"0|13.53|74.53|\n1|49.12|80.49|\n2|87.20|81.83|\n3|67.39|23.32|\n4|26.94|46.34|\n5|88.39|48.64|\n6|23.20|16.71|"
public static final String	CENTERS_AFTER_20_ITERATIONS_DOUBLE_DIGIT	"0|38.25|54.52|19.34|\n1|32.14|83.04|50.35|\n2|87.48|56.57|20.27|\n3|75.40|18.65|67.49|\n4|24.93|29.25|77.56|\n5|78.67|66.07|70.82|\n6|39.51|14.04|18.74|\n"
public static final String	CENTERS_AFTER_20_ITERATIONS_SINGLE_DIGIT	"0|38.3|54.5|19.3|\n1|32.1|83.0|50.4|\n2|87.5|56.6|20.3|\n3|75.4|18.6|67.5|\n4|24.9|29.2|77.6|\n5|78.7|66.1|70.8|\n6|39.5|14.0|18.7|\n"
public static final String	CENTERS_AFTER_ONE_STEP	"0|28.47|54.80|21.88|\n1|52.74|80.10|73.03|\n2|83.92|60.45|25.17|\n3|70.73|20.18|67.06|\n4|22.51|47.19|86.23|\n5|82.70|53.79|68.68|\n6|29.74|19.17|59.16|"
public static final String	CENTERS_AFTER_ONE_STEP_SINGLE_DIGIT	"0|28.5|54.8|21.9|\n1|52.7|80.1|73.0|\n2|83.9|60.5|25.2|\n3|70.7|20.2|67.0|\n4|22.5|47.2|86.2|\n5|82.7|53.8|68.7|\n6|29.7|19.2|59.2|"
public static final String	DATAPOINTS	"0|50.90|16.20|72.08|\n1|73.65|61.76|62.89|\n2|61.73|49.95|92.74|\n3|1.60|70.11|16.32|\n4|2.43|19.81|89.56|\n5|67.99|9.00|14.48|\n6|87.80|84.49|55.83|\n7|90.26|42.99|53.29|\n8|51.36|6.16|9.35|\n9|12.43|9.52|12.54|\n10|80.01|8.78|29.74|\n11|92.76|2.93|80.07|\n12|46.32|100.00|22.98|\n13|34.11|45.61|58.60|\n14|68.82|16.36|96.60|\n15|81.47|76.45|28.40|\n16|65.55|40.21|43.43|\n17|84.22|88.56|13.31|\n18|36.99|68.36|57.12|\n19|28.87|37.69|91.04|\n20|31.56|13.22|86.00|\n21|18.49|34.45|54.52|\n22|13.33|94.02|92.07|\n23|91.19|81.62|55.06|\n24|85.78|39.02|25.58|\n25|94.41|47.07|78.23|\n26|90.62|10.43|80.20|\n27|31.52|85.81|39.79|\n28|24.65|77.98|26.35|\n29|69.34|75.79|63.96|\n30|22.56|78.61|66.66|\n31|91.74|83.82|73.92|\n32|76.64|89.53|44.66|\n33|36.02|73.01|92.32|\n34|87.86|18.94|10.74|\n35|91.94|34.61|5.20|\n36|12.52|47.01|95.29|\n37|44.01|26.19|78.50|\n38|26.20|73.36|10.08|\n39|15.21|17.37|54.33|\n40|27.96|94.81|44.41|\n41|26.44|44.81|70.88|\n42|53.29|26.69|2.40|\n43|23.94|11.50|1.71|\n44|19.00|25.48|50.80|\n45|82.26|1.88|58.08|\n46|47.56|82.54|82.73|\n47|51.54|35.10|32.95|\n48|86.71|55.51|19.08|\n49|54.16|23.68|32.41|\n50|71.81|32.83|46.66|\n51|20.70|14.19|64.96|\n52|57.17|88.56|55.23|\n53|91.39|49.38|70.55|\n54|47.90|62.07|76.03|\n55|55.70|37.77|30.15|\n56|87.87|74.62|25.95|\n57|95.70|45.04|15.27|\n58|41.61|89.37|24.45|\n59|82.19|20.84|11.13|\n60|49.88|2.62|18.62|\n61|16.42|53.30|74.13|\n62|38.37|72.62|35.16|\n63|43.26|49.59|92.56|\n64|28.96|2.36|78.49|\n65|88.41|91.43|92.55|\n66|98.61|79.58|33.03|\n67|4.94|18.65|30.78|\n68|75.89|79.30|63.90|\n69|93.18|76.26|9.50|\n70|73.43|70.50|76.49|\n71|78.64|90.87|34.49|\n72|58.47|63.07|8.82|\n73|69.74|54.36|64.43|\n74|38.47|36.60|33.39|\n75|51.07|14.75|2.54|\n76|24.18|16.85|15.00|\n77|7.56|50.72|93.45|\n78|64.28|97.01|57.31|\n79|85.30|24.13|76.57|\n80|72.78|30.78|13.11|\n81|18.42|17.45|32.20|\n82|87.44|74.98|87.90|\n83|38.30|17.77|37.33|\n84|63.62|7.90|34.23|\n85|8.84|67.87|30.65|\n86|76.12|51.83|80.12|\n87|32.30|74.79|4.39|\n88|41.73|45.34|18.66|\n89|58.13|18.43|83.38|\n90|98.10|33.46|83.07|\n91|17.76|4.10|88.51|\n92|60.58|18.15|59.96|\n93|50.11|33.25|85.64|\n94|97.74|60.93|38.97|\n95|76.31|52.50|95.43|\n96|7.71|85.85|36.26|\n97|9.32|72.21|42.17|\n98|71.29|51.88|57.62|\n99|31.39|7.27|88.74|"
public static final String	DATAPOINTS_2D	"0|50.90|16.20|\n1|73.65|61.76|\n2|61.73|49.95|\n3|1.60|70.11|\n4|2.43|19.81|\n5|67.99|9.00|\n6|87.80|84.49|\n7|90.26|42.99|\n8|51.36|6.16|\n9|12.43|9.52|\n10|80.01|8.78|\n11|92.76|2.93|\n12|46.32|100.00|\n13|34.11|45.61|\n14|68.82|16.36|\n15|81.47|76.45|\n16|65.55|40.21|\n17|84.22|88.56|\n18|36.99|68.36|\n19|28.87|37.69|\n20|31.56|13.22|\n21|18.49|34.45|\n22|13.33|94.02|\n23|91.19|81.62|\n24|85.78|39.02|\n25|94.41|47.07|\n26|90.62|10.43|\n27|31.52|85.81|\n28|24.65|77.98|\n29|69.34|75.79|\n30|22.56|78.61|\n31|91.74|83.82|\n32|76.64|89.53|\n33|36.02|73.01|\n34|87.86|18.94|\n35|91.94|34.61|\n36|12.52|47.01|\n37|44.01|26.19|\n38|26.20|73.36|\n39|15.21|17.37|\n40|27.96|94.81|\n41|26.44|44.81|\n42|53.29|26.69|\n43|23.94|11.50|n44|19.00|25.48|\n45|82.26|1.88|\n46|47.56|82.54|\n47|51.54|35.10|\n48|86.71|55.51|\n49|54.16|23.68|\n50|71.81|32.83|\n51|20.70|14.19|\n52|57.17|88.56|\n53|91.39|49.38|\n54|47.90|62.07|\n55|55.70|37.77|\n56|87.87|74.62|\n57|95.70|45.04|\n58|41.61|89.37|\n59|82.19|20.84|\n60|49.88|2.62|\n61|16.42|53.30|\n62|38.37|72.62|\n63|43.26|49.59|\n64|28.96|2.36|\n65|88.41|91.43|\n66|98.61|79.58|\n67|4.94|18.65|\n68|75.89|79.30|\n69|93.18|76.26|\n70|73.43|70.50|\n71|78.64|90.87|\n72|58.47|63.07|\n73|69.74|54.36|\n74|38.47|36.60|\n75|51.07|14.75|\n76|24.18|16.85|\n77|7.56|50.72|\n78|64.28|97.01|\n79|85.30|24.13|\n80|72.78|30.78|\n81|18.42|17.45|\n82|87.44|74.98|\n83|38.30|17.77|\n84|63.62|7.90|\n85|8.84|67.87|\n86|76.12|51.83|\n87|32.30|74.79|n88|41.73|45.34|\n89|58.13|18.43|\n90|98.10|33.46|\n91|17.76|4.10|\n92|60.58|18.15|\n93|50.11|33.25|\n94|97.74|60.93|\n95|76.31|52.50|\n96|7.71|85.85|\n97|9.32|72.21|\n98|71.29|51.88|\n99|31.39|7.27|"
public static final String	INITIAL_CENTERS	"0|1.96|65.04|20.82|\n1|53.99|84.23|81.59|\n2|97.28|74.50|40.32|\n3|63.57|24.53|87.07|\n4|28.10|43.27|86.53|\n5|99.51|62.70|64.48|\n6|30.31|30.36|80.46|"
public static final String	INITIAL_CENTERS_2D	"0|1.96|65.04|\n1|53.99|84.23|\n2|97.28|74.50|\n3|63.57|24.53|\n4|28.10|43.27|\n5|99.51|62.70|\n6|30.31|30.36|"

org.apache.flink.test.testdata.PageRankData

Modifier and Type	Constant Field	Value
public static final String	EDGES	"2 1\n5 2\n5 4\n4 3\n4 2\n1 4\n1 2\n1 3\n3 5\n"
public static final int	NUM_VERTICES	5
public static final String	RANKS_AFTER_3_ITERATIONS	"1 0.237\n2 0.248\n3 0.173\n4 0.175\n5 0.165"
public static final String	RANKS_AFTER_EPSILON_0_0001_CONVERGENCE	"1 0.238\n2 0.244\n3 0.170\n4 0.171\n5 0.174"
public static final String	VERTICES	"1\n2\n5\n3\n4"

org.apache.flink.test.testdata.WebLogAnalysisData

Modifier and Type	Constant Field	Value
public static final String	DOCS	"url_10|volutpat magna quis consectetuer volutpat ad erat editors exerci oscillations euismod volutpat Lorem convectionullamcorper Lorem volutpat enim tation elit |\nurl_11|adipiscing enim diam ex tincidunt tincidunt nonummy volutpat minim euismod volutpat suscipit ex sed laoreet aliquip quis diam tincidunt wisi diam elit sed ut minim ad nonummy amet volutpat nostrud erat |\nurl_12|ut nostrud adipiscing adipiscing ipsum nonummy amet volutpat volutpat sit enim Ut amet |\nurl_13|euismod sit adipiscing ex suscipit ea veniam tincidunt laoreet nibh editors ullamcorper consectetuer convection commodo sed nostrud ea ex ullamcorper dolor dolore ad diam dolore amet ut tincidunt nonummy euismod enim ullamcorper tincidunt dolor sit volutpat dolor tincidunt aliquam nisl tation ullamcorper sed consectetuer sit sit laoreet ex |\nurl_14|ad magna ipsum nonummy aliquip dolore aliquam veniam lobortis nostrud aliquip nibh amet aliquam editors magna aliquam volutpat nonummy sed tation erat adipiscing nostrud magna ut sit dolore volutpat laoreet nisl wisi Ut veniam nibh laoreet ad nostrud ut aliquip |\nurl_15|enim ipsum veniam ex editor Lorem elit laoreet exerci ea wisi oscillations convection euismod euismod diam ut euismod ad Lorem ut Ut tation wisi diam suscipit nibh nostrud minim dolor |\nurl_16|tation ad sed veniam lobortis editor nonummy Ut ea ipsum aliquip dolore ut laoreet tation ad ut Lorem ipsum minim nostrud quis Lorem enim |\nurl_17|veniam editor veniam Lorem aliquam ipsum amet ut convection veniam enim commodo ad ex magna nibh Ut ex sed ut nostrud amet volutpat nibh Ut wisi ea laoreet Lorem amet minim ullamcorper tincidunt veniam laoreet laoreet |\nurl_18|veniam diam tincidunt ullamcorper adipiscing oscillations adipiscing aliquip quis nibh suscipit ex sit sit wisi diam aliquam aliquip ea diam euismod ad erat ut ipsum lobortis ea exerci |\nurl_19|adipiscing nisl oscillations ea editors tincidunt tation convection tincidunt tincidunt ut wisi tincidunt ut ut Ut nibh aliquam laoreet exerci enim ea nibh erat nonummy |\nurl_20|ut diam aliquip ipsum laoreet elit volutpat suscipit nostrud convection tation nisl suscipit nonummy tation tation ut enim dolor nisl magna aliquam enim consectetuer sed tincidunt quis amet elit |\nurl_21|tation ad exerci volutpat tincidunt sit ullamcorper oscillations ut minim sed diam Lorem adipiscing |\nurl_22|sit exerci ad ut minim convection ad ea dolore Lorem ipsum amet sit wisi sed ullamcorper ipsum enim aliquam tincidunt elit nonummy laoreet laoreet dolore tation ullamcorper commodo Ut elit sit minim suscipit nisl laoreet |\nurl_23|Lorem nibh ea ea ex ut tation euismod tincidunt lobortis enim ullamcorper euismod amet magna sit erat enim editor diam dolor volutpat diam nisl ut erat commodo amet veniam consectetuer ex commodo sed magna ea erat ullamcorper dolor sed diam enim euismod |\nurl_24|nisl dolor magna editors ad consectetuer veniam commodo Ut dolor wisi dolore amet dolore dolore volutpat convection Ut oscillations |\nurl_25|ut euismod quis ad nostrud volutpat dolor wisi oscillations nostrud sed nonummy wisi exerci convection sed erat nostrud quis editors Ut nostrud consectetuer aliquip exerci ut Ut tincidunt aliquam suscipit erat |\nurl_26|nisl elit ea minim aliquam dolor consectetuer consectetuer quis Ut convection laoreet sit enim nostrud sed dolor magna dolor elit adipiscing |\nurl_27|nisl euismod ipsum ex adipiscing erat euismod diam quis oscillations aliquip nisl ut sit dolor wisi enim tincidunt amet ullamcorper adipiscing nibh Ut volutpat sed nonummy ex ea wisi exerci aliquam elit Ut aliquip nostrud ad nibh ut sit suscipit ut commodo wisi Lorem nibh |\nurl_28|laoreet sed editor dolor diam convection sed diam exerci laoreet oscillations consectetuer ullamcorper suscipit ut editors quis commodo editor veniam nibh ea diam ex magna ea elit sit sed nibh lobortis consectetuer erat erat sit minim ea ad ea nisl magna volutpat ut |\nurl_29|consectetuer convection amet diam erat euismod erat editor oscillations ipsum tation tation editors minim wisi tation quis adipiscing euismod nonummy erat ut diam suscipit tincidunt ut consectetuer Lorem editor sit quis euismod veniam tincidunt aliquam ut veniam adipiscing magna Ut ut dolore euismod minim veniam |"
public static final String	EXCEPTED_RESULT	"87|url_24|39\n59|url_28|41\n"
public static final String	RANKS	"77|url_10|51|\n7|url_11|24|\n19|url_12|28|\n13|url_13|50|\n81|url_14|41|\n87|url_15|28|\n78|url_16|29|\n70|url_17|7|\n91|url_18|38|\n99|url_19|11|\n37|url_20|46|\n64|url_21|46|\n25|url_22|14|\n6|url_23|12|\n87|url_24|39|\n0|url_25|27|\n97|url_26|27|\n9|url_27|54|\n59|url_28|41|\n40|url_29|11|"
public static final String	VISITS	"112.99.215.248|url_20|2011-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n189.69.147.166|url_19|2009-8-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n83.7.97.153|url_21|2010-3-20|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n215.57.124.59|url_10|2008-1-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n174.176.121.10|url_25|2007-12-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n66.225.121.11|url_16|2007-10-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n57.11.211.126|url_14|2010-12-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n129.127.115.129|url_28|2009-2-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n137.249.175.115|url_27|2011-5-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n101.92.9.112|url_12|2012-1-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n113.108.207.12|url_24|2011-3-20|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n179.141.87.220|url_18|2007-10-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n46.10.118.101|url_20|2009-7-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n91.67.84.155|url_20|2012-7-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n102.142.34.164|url_22|2010-7-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n203.67.94.61|url_14|2007-7-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n229.121.13.143|url_19|2010-4-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n209.154.189.12|url_16|2011-4-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n57.113.29.197|url_13|2008-9-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n132.90.139.12|url_16|2007-10-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n101.21.109.146|url_29|2009-2-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n171.69.34.255|url_29|2009-2-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n11.114.192.13|url_25|2008-9-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n37.188.212.141|url_15|2011-1-21|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n102.40.251.47|url_26|2010-7-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n136.85.230.245|url_17|2010-8-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n68.96.194.82|url_29|2007-10-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n62.126.40.210|url_29|2011-2-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n12.81.184.191|url_11|2008-1-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n12.232.205.52|url_18|2008-1-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n227.83.79.30|url_25|2008-6-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n88.222.17.152|url_21|2007-10-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n55.87.23.63|url_22|2008-8-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n54.41.77.25|url_18|2012-12-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n203.83.250.233|url_10|2009-4-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n42.13.134.196|url_15|2012-9-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n224.51.182.133|url_27|2008-11-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n180.209.212.98|url_27|2008-6-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n29.173.47.29|url_24|2011-9-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n251.153.164.73|url_18|2008-3-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n195.164.244.58|url_23|2010-12-21|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n96.167.244.51|url_18|2007-2-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n131.169.48.126|url_19|2009-6-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n171.151.109.83|url_12|2011-6-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n150.87.176.48|url_22|2008-10-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n56.172.201.54|TPCHQuery3ITCaseurl_25|2012-11-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n175.241.83.44|url_13|2008-2-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n105.222.1.251|url_18|2012-7-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n195.117.130.95|url_10|2012-4-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n10.139.236.176|url_14|2011-4-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n207.100.168.191|url_22|2007-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n196.129.126.177|url_25|2008-4-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n170.239.116.200|url_27|2010-3-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n99.79.118.85|url_13|2008-3-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n112.65.132.135|url_15|2010-8-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n109.15.235.196|url_14|2012-8-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n240.201.229.137|url_21|2008-9-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n74.53.245.171|url_18|2007-6-19|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n158.230.101.250|url_17|2011-4-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n198.197.213.210|url_11|2012-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n1.54.145.90|url_11|2009-6-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n2.236.14.86|url_13|2007-9-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n203.180.186.150|url_16|2010-2-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n135.83.247.101|url_22|2007-12-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n54.214.72.16|url_12|2007-5-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n238.115.186.34|url_10|2007-5-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n6.251.55.92|url_26|2007-5-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n196.96.11.111|url_16|2007-11-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n209.40.86.220|url_24|2009-5-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n130.208.66.140|url_19|2011-9-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n176.157.170.178|url_27|2008-12-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n103.4.119.128|url_15|2010-6-19|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n31.181.160.159|url_12|2009-8-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n166.238.60.79|url_23|2009-2-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n64.165.114.139|url_19|2007-9-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n11.45.238.55|url_26|2011-8-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n189.121.92.228|url_18|2008-1-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n137.114.181.208|url_14|2007-6-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n165.194.234.136|url_18|2012-3-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n210.145.85.234|url_10|2007-9-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n227.37.135.138|url_21|2010-5-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n39.87.120.86|url_25|2007-2-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n107.144.159.246|url_11|2010-7-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n160.38.166.236|url_15|2009-6-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n79.44.39.160|url_10|2008-12-19|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n143.52.62.175|url_19|2011-12-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n68.54.137.193|url_19|2007-6-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n199.137.128.158|url_27|2008-4-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n10.0.80.61|url_10|2011-3-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n4.30.48.164|url_29|2007-2-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n136.29.50.223|url_12|2008-3-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n83.101.200.110|url_23|2009-1-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n11.149.83.246|url_29|2010-9-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n154.119.20.134|url_14|2011-1-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n191.124.167.123|url_15|2009-6-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n27.158.167.38|url_11|2011-5-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n16.197.156.206|url_16|2009-2-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n222.150.206.233|url_20|2012-2-11|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n198.59.29.225|url_21|2007-2-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n182.91.244.40|url_18|2010-5-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n23.110.45.72|url_28|2008-6-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n94.241.8.36|url_11|2007-7-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n226.223.202.210|url_17|2007-10-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n73.16.194.132|url_14|2012-7-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n195.45.98.110|url_13|2012-2-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n189.123.80.178|url_29|2011-1-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n190.134.174.18|url_23|2011-12-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n133.54.252.245|url_13|2011-3-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n244.29.167.182|url_18|2012-10-11|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n125.32.251.232|url_26|2010-4-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n74.139.30.20|url_16|2012-2-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n100.73.180.209|url_29|2010-4-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n133.155.158.147|url_16|2011-11-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n185.53.212.102|url_15|2010-12-19|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n154.189.125.92|url_27|2007-10-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n12.209.166.107|url_26|2007-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n106.99.152.22|url_25|2011-12-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n37.120.32.53|url_22|2008-12-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n29.17.125.185|url_12|2011-8-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n233.125.12.14|url_19|2011-2-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n241.78.212.114|url_25|2007-12-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n153.183.247.90|url_18|2011-9-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n245.43.17.177|url_15|2012-4-21|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n55.13.54.220|url_24|2008-11-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n104.149.82.217|url_10|2011-9-26|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n36.15.167.145|url_24|2008-1-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n145.149.81.203|url_20|2008-5-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n68.89.4.115|url_18|2007-7-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n236.88.134.53|url_15|2010-5-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n180.140.58.209|url_29|2012-8-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n138.46.241.237|url_17|2010-11-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n254.217.79.58|url_29|2007-1-11|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n142.184.197.136|url_10|2007-11-3|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n216.118.94.220|url_12|2007-2-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n53.99.54.0|url_14|2008-3-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n95.151.221.37|url_28|2009-5-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n46.110.43.78|url_27|2007-11-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n172.96.203.180|url_11|2012-1-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n22.188.231.143|url_21|2007-10-23|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n216.46.80.239|url_22|2009-9-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n103.213.7.86|url_26|2007-12-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n186.204.3.180|url_27|2012-1-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n129.197.116.192|url_10|2012-5-1|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n8.164.181.242|url_24|2008-11-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n145.52.12.132|url_28|2012-8-6|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n20.22.62.146|url_11|2007-4-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n233.255.32.151|url_19|2008-6-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n31.233.226.148|url_24|2011-8-4|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n57.130.120.117|url_25|2008-12-9|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n29.98.249.152|url_21|2011-8-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n25.187.66.122|url_20|2008-12-17|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n236.205.44.215|url_26|2008-9-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n18.40.99.157|url_23|2012-1-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n204.221.88.206|url_24|2012-11-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n199.5.94.240|url_24|2011-9-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n57.175.34.24|url_14|2009-12-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n130.25.116.220|url_10|2007-6-5|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n134.174.12.250|url_22|2011-6-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n162.185.114.212|url_13|2011-8-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n8.113.137.95|url_14|2011-6-22|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n176.253.5.99|url_12|2010-4-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n3.110.24.0|url_12|2009-6-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n159.128.152.207|url_17|2012-2-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n104.145.150.244|url_10|2012-2-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n203.19.224.207|url_12|2012-9-24|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n225.163.125.108|url_20|2010-4-8|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n197.137.29.71|url_21|2007-10-25|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n29.207.144.144|url_12|2012-7-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n139.222.222.113|url_14|2010-4-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n169.225.20.141|url_29|2012-2-18|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n137.86.141.104|url_26|2012-3-10|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n193.100.2.122|url_24|2011-12-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n20.105.209.161|url_13|2010-2-7|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n116.81.52.207|url_11|2007-4-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n141.88.224.116|url_19|2009-4-12|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n72.198.58.37|url_26|2012-2-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n13.37.92.90|url_22|2011-5-16|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n191.163.173.142|url_24|2012-5-2|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n183.57.175.105|url_27|2007-8-13|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n230.212.34.87|url_10|2010-12-21|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n133.150.217.96|url_24|2012-7-27|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|\n62.254.96.239|url_24|2011-5-15|0.12|Mozilla Firefox 3.1|de|de|Nothing special|124|"

org.apache.flink.test.testdata.WordCountData

Modifier and Type	Constant Field	Value
public static final String	COUNTS	"machen 1\nzeit 2\nheerscharen 1\nkeiner 2\nmeine 3\nfuehr 1\ntriumph 1\nkommst 1\nfrei 1\nschaffen 1\ngesinde 1\nlangbeinigen 1\nschalk 1\nbesser 1\nsolang 1\nmeer 4\nfragst 1\ngabriel 1\nselbst 2\nbin 1\nsich 7\ndu 11\nsogar 1\ngeht 1\nimmer 4\nmensch 2\nbefestigt 1\nlebt 2\nmag 3\nengeln 2\nbreiten 1\nblitzendes 1\ntags 1\nsie 2\nplagen 2\nallzu 1\nmeisten 1\no 1\npfade 1\nkennst 1\nnichts 3\ngedanken 1\nbefriedigt 1\nmich 6\ns 3\nes 8\nverneinen 1\ner 13\ngleich 1\nbaeumchen 1\ndonnergang 1\nwunderlich 1\nreise 1\nurquell 1\ndoch 3\naufs 2\ntoten 1\nniemals 1\neine 2\nhab 1\ndarfst 1\nda 5\ngen 1\neinem 2\nteil 1\ndas 7\nspeise 1\nwenig 1\nsterne 1\ngeb 1\nwelten 1\nalle 3\ntoent 1\ngras 1\nfelsen 1\nkette 1\nich 14\nfuer 2\nals 3\nmein 1\nschoene 1\nverzeih 1\nschwankender 1\nwie 9\nmenschlich 1\ngaertner 1\ntaetigkeit 1\nbange 1\nliebe 1\nsei 2\nseh 1\ntollheit 1\nam 6\nmichael 1\ngeist 1\nab 1\nnahst 1\nvollendet 1\nliebt 1\nbrausen 1\nnase 1\nerlaubt 1\nweiss 2\nschnellem 1\ndeinem 1\ngleichem 1\ngaerung 1\ndauernden 1\ndeines 1\nvorgeschriebne 1\nirdisch 1\nworte 1\nverehren 1\nhohen 2\nweise 2\nkuenft 1\nwerdende 1\nwette 2\nwuetend 1\nerscheinung 1\ngar 2\nverlieren 1\nbraucht 1\nweiter 1\ntrank 1\ntierischer 1\nwohl 1\nverteilen 1\nverhoehnt 1\nschaeumt 1\nhimmelslichts 1\nunbedingte 1\nherzlich 1\nanblick 2\nnennt 1\ngruent 1\nbluet 1\nleichnam 1\nerschlaffen 1\njammertagen 1\nzieh 1\nihm 3\nbesondre 1\nihn 5\ngrossen 1\nvollen 1\nihr 7\nboten 1\nvoller 1\nsingt 1\nmuhme 1\nschon 1\nlast 1\nkleine 1\nparadieseshelle 1\nnein 1\nechten 1\nunter 1\nbei 1\nherr 11\ngern 3\nsphaerenlauf 1\nstets 1\nganze 1\nbraechte 1\nfordert 1\nschoensten 1\nherrlich 2\ngegeben 1\nallein 2\nreichen 1\nschauervoller 1\nmusst 1\nrecht 1\nbleibt 1\npracht 1\ntreibt 1\nbefangen 1\nwas 2\nmenschen 3\njede 1\nhohe 1\ntiefsten 1\nbilden 1\ndrum 1\ngibt 2\nguter 1\nfuerwahr 1\nim 3\ngrund 1\nin 9\nhoechste 1\nschliesst 1\nfels 1\nsteh 1\neuer 1\nerster 1\nersten 3\ngoettersoehne 1\nbrechen 1\ntiefen 1\nfrucht 1\nkreis 1\nsiehst 1\nwege 1\nist 8\nzikaden 1\nfrischen 1\nruh 1\ndeine 2\nmaus 1\nbrudersphaeren 1\nnachher 1\neuch 4\ngnaden 1\nanzuklagen 1\nschlange 1\nstaerke 2\nerde 4\nverlaub 1\nsanfte 1\nholden 1\nsonst 1\ntreten 1\nsahst 1\nalten 1\num 1\nwieder 1\nalter 1\naltes 1\nnun 1\nlieb 1\ngesellen 1\nerscheinen 1\nwirkt 2\nhaettst 2\nnur 7\ntiefbewegte 1\nlachen 2\ndrange 1\nschlag 1\nschein 1\nmuss 1\nverworren 1\nweges 1\nallen 1\ngewoehnlich 1\nalles 1\nhalb 1\nstuerme 1\nspringt 1\nsollt 1\nklarheit 1\nso 6\nerfassen 1\nliedchen 1\nprolog 1\nzur 1\nfressen 1\nzum 1\nfaust 2\nerzengel 2\njahre 1\nsonn 1\nraphael 1\nland 2\nlang 1\ngelange 1\nlust 2\nwelt 1\nsehe 1\nihre 1\njedes 1\nerfreut 1\nseiner 1\ndenn 1\nwandeln 1\nwechselt 1\njeden 1\ndort 1\nschlecht 1\nwenigsten 1\nwuerd 1\nschranken 1\nbewusst 2\nseinem 2\ngehasst 1\nsein 1\nmeinem 1\nmeinen 1\npathos 1\nherrn 1\nlange 2\nherab 1\ndiesen 1\nihren 1\nberuehmte 1\ngoethe 1\ntag 3\ntier 1\nquark 1\ndank 1\nseine 1\nteufel 2\nzweck 1\nwenn 7\nsoll 1\nwirkung 1\nerlaubnis 1\nlebendig 1\nuns 1\nleicht 1\ngewiss 1\nschnell 1\nund 29\ngerne 1\nrechten 1\numher 2\nvernunft 1\ngrase 1\nnach 1\nleben 1\ngott 1\nder 29\ndes 5\ndoktor 1\nbeschaemt 1\ndreht 1\nhabe 1\nsagen 2\nbekennen 1\ndunklen 1\nwettet 1\nden 9\nmephistopheles 9\ndem 4\nauch 4\nkann 2\narmen 1\nmir 9\nstrebt 1\ngut 2\nmit 11\nbald 2\nhimmlischen 1\nhimmel 3\nnoch 3\nkannst 1\ndeinesgleichen 1\nflammt 1\nergruenden 2\nnacht 1\nscheint 1\nferne 2\ntragoedie 1\nabgewoehnt 1\nreizt 1\ngeistern 1\nnicht 10\nsacht 1\nunbegreiflich 2\nschnelle 1\neinmal 1\nwerd 1\nwerke 2\nbegraebt 1\nknecht 1\nrings 1\nwird 1\nkatze 1\nhuete 1\nfortgerissen 1\ngebt 1\nhuebsch 1\nhast 1\nirrt 1\nbefinde 1\nsind 2\nfuehren 2\nfliegt 1\newig 3\nbrust 2\nsonne 1\nsprechen 1\nein 3\nstrasse 1\nvon 8\nueberlassen 1\ndir 4\nvom 3\nzu 11\nschwebt 1\ndie 22\nvor 2\nwangen 1\nwettgesang 1\ndonnerschlags 1\nfind 1\ndich 3\numfass 1\nverboten 1\nlaeg 1\nnie 1\ndrei 2\ndauern 1\ntoren 1\ndauert 1\nverheeren 1\nfliegend 1\naus 1\nstaub 1\nfluessen 1\nhaus 1\nauf 5\ndient 2\ntiefer 1\nnaeh 1\nzieren 1\n"
public static final String	COUNTS_AS_TUPLES	"(machen,1)\n(zeit,2)\n(heerscharen,1)\n(keiner,2)\n(meine,3)\n(fuehr,1)\n(triumph,1)\n(kommst,1)\n(frei,1)\n(schaffen,1)\n(gesinde,1)\n(langbeinigen,1)\n(schalk,1)\n(besser,1)\n(solang,1)\n(meer,4)\n(fragst,1)\n(gabriel,1)\n(selbst,2)\n(bin,1)\n(sich,7)\n(du,11)\n(sogar,1)\n(geht,1)\n(immer,4)\n(mensch,2)\n(befestigt,1)\n(lebt,2)\n(mag,3)\n(engeln,2)\n(breiten,1)\n(blitzendes,1)\n(tags,1)\n(sie,2)\n(plagen,2)\n(allzu,1)\n(meisten,1)\n(o,1)\n(pfade,1)\n(kennst,1)\n(nichts,3)\n(gedanken,1)\n(befriedigt,1)\n(mich,6)\n(s,3)\n(es,8)\n(verneinen,1)\n(er,13)\n(gleich,1)\n(baeumchen,1)\n(donnergang,1)\n(wunderlich,1)\n(reise,1)\n(urquell,1)\n(doch,3)\n(aufs,2)\n(toten,1)\n(niemals,1)\n(eine,2)\n(hab,1)\n(darfst,1)\n(da,5)\n(gen,1)\n(einem,2)\n(teil,1)\n(das,7)\n(speise,1)\n(wenig,1)\n(sterne,1)\n(geb,1)\n(welten,1)\n(alle,3)\n(toent,1)\n(gras,1)\n(felsen,1)\n(kette,1)\n(ich,14)\n(fuer,2)\n(als,3)\n(mein,1)\n(schoene,1)\n(verzeih,1)\n(schwankender,1)\n(wie,9)\n(menschlich,1)\n(gaertner,1)\n(taetigkeit,1)\n(bange,1)\n(liebe,1)\n(sei,2)\n(seh,1)\n(tollheit,1)\n(am,6)\n(michael,1)\n(geist,1)\n(ab,1)\n(nahst,1)\n(vollendet,1)\n(liebt,1)\n(brausen,1)\n(nase,1)\n(erlaubt,1)\n(weiss,2)\n(schnellem,1)\n(deinem,1)\n(gleichem,1)\n(gaerung,1)\n(dauernden,1)\n(deines,1)\n(vorgeschriebne,1)\n(irdisch,1)\n(worte,1)\n(verehren,1)\n(hohen,2)\n(weise,2)\n(kuenft,1)\n(werdende,1)\n(wette,2)\n(wuetend,1)\n(erscheinung,1)\n(gar,2)\n(verlieren,1)\n(braucht,1)\n(weiter,1)\n(trank,1)\n(tierischer,1)\n(wohl,1)\n(verteilen,1)\n(verhoehnt,1)\n(schaeumt,1)\n(himmelslichts,1)\n(unbedingte,1)\n(herzlich,1)\n(anblick,2)\n(nennt,1)\n(gruent,1)\n(bluet,1)\n(leichnam,1)\n(erschlaffen,1)\n(jammertagen,1)\n(zieh,1)\n(ihm,3)\n(besondre,1)\n(ihn,5)\n(grossen,1)\n(vollen,1)\n(ihr,7)\n(boten,1)\n(voller,1)\n(singt,1)\n(muhme,1)\n(schon,1)\n(last,1)\n(kleine,1)\n(paradieseshelle,1)\n(nein,1)\n(echten,1)\n(unter,1)\n(bei,1)\n(herr,11)\n(gern,3)\n(sphaerenlauf,1)\n(stets,1)\n(ganze,1)\n(braechte,1)\n(fordert,1)\n(schoensten,1)\n(herrlich,2)\n(gegeben,1)\n(allein,2)\n(reichen,1)\n(schauervoller,1)\n(musst,1)\n(recht,1)\n(bleibt,1)\n(pracht,1)\n(treibt,1)\n(befangen,1)\n(was,2)\n(menschen,3)\n(jede,1)\n(hohe,1)\n(tiefsten,1)\n(bilden,1)\n(drum,1)\n(gibt,2)\n(guter,1)\n(fuerwahr,1)\n(im,3)\n(grund,1)\n(in,9)\n(hoechste,1)\n(schliesst,1)\n(fels,1)\n(steh,1)\n(euer,1)\n(erster,1)\n(ersten,3)\n(goettersoehne,1)\n(brechen,1)\n(tiefen,1)\n(frucht,1)\n(kreis,1)\n(siehst,1)\n(wege,1)\n(ist,8)\n(zikaden,1)\n(frischen,1)\n(ruh,1)\n(deine,2)\n(maus,1)\n(brudersphaeren,1)\n(nachher,1)\n(euch,4)\n(gnaden,1)\n(anzuklagen,1)\n(schlange,1)\n(staerke,2)\n(erde,4)\n(verlaub,1)\n(sanfte,1)\n(holden,1)\n(sonst,1)\n(treten,1)\n(sahst,1)\n(alten,1)\n(um,1)\n(wieder,1)\n(alter,1)\n(altes,1)\n(nun,1)\n(lieb,1)\n(gesellen,1)\n(erscheinen,1)\n(wirkt,2)\n(haettst,2)\n(nur,7)\n(tiefbewegte,1)\n(lachen,2)\n(drange,1)\n(schlag,1)\n(schein,1)\n(muss,1)\n(verworren,1)\n(weges,1)\n(allen,1)\n(gewoehnlich,1)\n(alles,1)\n(halb,1)\n(stuerme,1)\n(springt,1)\n(sollt,1)\n(klarheit,1)\n(so,6)\n(erfassen,1)\n(liedchen,1)\n(prolog,1)\n(zur,1)\n(fressen,1)\n(zum,1)\n(faust,2)\n(erzengel,2)\n(jahre,1)\n(sonn,1)\n(raphael,1)\n(land,2)\n(lang,1)\n(gelange,1)\n(lust,2)\n(welt,1)\n(sehe,1)\n(ihre,1)\n(jedes,1)\n(erfreut,1)\n(seiner,1)\n(denn,1)\n(wandeln,1)\n(wechselt,1)\n(jeden,1)\n(dort,1)\n(schlecht,1)\n(wenigsten,1)\n(wuerd,1)\n(schranken,1)\n(bewusst,2)\n(seinem,2)\n(gehasst,1)\n(sein,1)\n(meinem,1)\n(meinen,1)\n(pathos,1)\n(herrn,1)\n(lange,2)\n(herab,1)\n(diesen,1)\n(ihren,1)\n(beruehmte,1)\n(goethe,1)\n(tag,3)\n(tier,1)\n(quark,1)\n(dank,1)\n(seine,1)\n(teufel,2)\n(zweck,1)\n(wenn,7)\n(soll,1)\n(wirkung,1)\n(erlaubnis,1)\n(lebendig,1)\n(uns,1)\n(leicht,1)\n(gewiss,1)\n(schnell,1)\n(und,29)\n(gerne,1)\n(rechten,1)\n(umher,2)\n(vernunft,1)\n(grase,1)\n(nach,1)\n(leben,1)\n(gott,1)\n(der,29)\n(des,5)\n(doktor,1)\n(beschaemt,1)\n(dreht,1)\n(habe,1)\n(sagen,2)\n(bekennen,1)\n(dunklen,1)\n(wettet,1)\n(den,9)\n(mephistopheles,9)\n(dem,4)\n(auch,4)\n(kann,2)\n(armen,1)\n(mir,9)\n(strebt,1)\n(gut,2)\n(mit,11)\n(bald,2)\n(himmlischen,1)\n(himmel,3)\n(noch,3)\n(kannst,1)\n(deinesgleichen,1)\n(flammt,1)\n(ergruenden,2)\n(nacht,1)\n(scheint,1)\n(ferne,2)\n(tragoedie,1)\n(abgewoehnt,1)\n(reizt,1)\n(geistern,1)\n(nicht,10)\n(sacht,1)\n(unbegreiflich,2)\n(schnelle,1)\n(einmal,1)\n(werd,1)\n(werke,2)\n(begraebt,1)\n(knecht,1)\n(rings,1)\n(wird,1)\n(katze,1)\n(huete,1)\n(fortgerissen,1)\n(gebt,1)\n(huebsch,1)\n(hast,1)\n(irrt,1)\n(befinde,1)\n(sind,2)\n(fuehren,2)\n(fliegt,1)\n(ewig,3)\n(brust,2)\n(sonne,1)\n(sprechen,1)\n(ein,3)\n(strasse,1)\n(von,8)\n(ueberlassen,1)\n(dir,4)\n(vom,3)\n(zu,11)\n(schwebt,1)\n(die,22)\n(vor,2)\n(wangen,1)\n(wettgesang,1)\n(donnerschlags,1)\n(find,1)\n(dich,3)\n(umfass,1)\n(verboten,1)\n(laeg,1)\n(nie,1)\n(drei,2)\n(dauern,1)\n(toren,1)\n(dauert,1)\n(verheeren,1)\n(fliegend,1)\n(aus,1)\n(staub,1)\n(fluessen,1)\n(haus,1)\n(auf,5)\n(dient,2)\n(tiefer,1)\n(naeh,1)\n(zieren,1)\n"
public static final String	STREAMING_COUNTS_AS_TUPLES	"(machen,1)\n(zeit,1)\n(zeit,2)\n(heerscharen,1)\n(keiner,1)\n(keiner,2)\n(meine,1)\n(meine,2)\n(meine,3)\n(fuehr,1)\n(triumph,1)\n(kommst,1)\n(frei,1)\n(schaffen,1)\n(gesinde,1)\n(langbeinigen,1)\n(schalk,1)\n(besser,1)\n(solang,1)\n(meer,1)\n(meer,2)\n(meer,3)\n(meer,4)\n(fragst,1)\n(gabriel,1)\n(selbst,1)\n(selbst,2)\n(bin,1)\n(sich,1)\n(sich,2)\n(sich,3)\n(sich,4)\n(sich,5)\n(sich,6)\n(sich,7)\n(du,1)\n(du,2)\n(du,3)\n(du,4)\n(du,5)\n(du,6)\n(du,7)\n(du,8)\n(du,9)\n(du,10)\n(du,11)\n(sogar,1)\n(geht,1)\n(immer,1)\n(immer,2)\n(immer,3)\n(immer,4)\n(mensch,1)\n(mensch,2)\n(befestigt,1)\n(lebt,1)\n(lebt,2)\n(mag,1)\n(mag,2)\n(mag,3)\n(engeln,1)\n(engeln,2)\n(breiten,1)\n(blitzendes,1)\n(tags,1)\n(sie,1)\n(sie,2)\n(plagen,1)\n(plagen,2)\n(allzu,1)\n(meisten,1)\n(o,1)\n(pfade,1)\n(kennst,1)\n(nichts,1)\n(nichts,2)\n(nichts,3)\n(gedanken,1)\n(befriedigt,1)\n(mich,1)\n(mich,2)\n(mich,3)\n(mich,4)\n(mich,5)\n(mich,6)\n(s,1)\n(s,2)\n(s,3)\n(es,1)\n(es,2)\n(es,3)\n(es,4)\n(es,5)\n(es,6)\n(es,7)\n(es,8)\n(verneinen,1)\n(er,1)\n(er,2)\n(er,3)\n(er,4)\n(er,5)\n(er,6)\n(er,7)\n(er,8)\n(er,9)\n(er,10)\n(er,11)\n(er,12)\n(er,13)\n(gleich,1)\n(baeumchen,1)\n(donnergang,1)\n(wunderlich,1)\n(reise,1)\n(urquell,1)\n(doch,1)\n(doch,2)\n(doch,3)\n(aufs,1)\n(aufs,2)\n(toten,1)\n(niemals,1)\n(eine,1)\n(eine,2)\n(hab,1)\n(darfst,1)\n(da,1)\n(da,2)\n(da,3)\n(da,4)\n(da,5)\n(gen,1)\n(einem,1)\n(einem,2)\n(teil,1)\n(das,1)\n(das,2)\n(das,3)\n(das,4)\n(das,5)\n(das,6)\n(das,7)\n(speise,1)\n(wenig,1)\n(sterne,1)\n(geb,1)\n(welten,1)\n(alle,1)\n(alle,2)\n(alle,3)\n(toent,1)\n(gras,1)\n(felsen,1)\n(kette,1)\n(ich,1)\n(ich,2)\n(ich,3)\n(ich,4)\n(ich,5)\n(ich,6)\n(ich,7)\n(ich,8)\n(ich,9)\n(ich,10)\n(ich,11)\n(ich,12)\n(ich,13)\n(ich,14)\n(fuer,1)\n(fuer,2)\n(als,1)\n(als,2)\n(als,3)\n(mein,1)\n(schoene,1)\n(verzeih,1)\n(schwankender,1)\n(wie,1)\n(wie,2)\n(wie,3)\n(wie,4)\n(wie,5)\n(wie,6)\n(wie,7)\n(wie,8)\n(wie,9)\n(menschlich,1)\n(gaertner,1)\n(taetigkeit,1)\n(bange,1)\n(liebe,1)\n(sei,1)\n(sei,2)\n(seh,1)\n(tollheit,1)\n(am,1)\n(am,2)\n(am,3)\n(am,4)\n(am,5)\n(am,6)\n(michael,1)\n(geist,1)\n(ab,1)\n(nahst,1)\n(vollendet,1)\n(liebt,1)\n(brausen,1)\n(nase,1)\n(erlaubt,1)\n(weiss,1)\n(weiss,2)\n(schnellem,1)\n(deinem,1)\n(gleichem,1)\n(gaerung,1)\n(dauernden,1)\n(deines,1)\n(vorgeschriebne,1)\n(irdisch,1)\n(worte,1)\n(verehren,1)\n(hohen,1)\n(hohen,2)\n(weise,1)\n(weise,2)\n(kuenft,1)\n(werdende,1)\n(wette,1)\n(wette,2)\n(wuetend,1)\n(erscheinung,1)\n(gar,1)\n(gar,2)\n(verlieren,1)\n(braucht,1)\n(weiter,1)\n(trank,1)\n(tierischer,1)\n(wohl,1)\n(verteilen,1)\n(verhoehnt,1)\n(schaeumt,1)\n(himmelslichts,1)\n(unbedingte,1)\n(herzlich,1)\n(anblick,1)\n(anblick,2)\n(nennt,1)\n(gruent,1)\n(bluet,1)\n(leichnam,1)\n(erschlaffen,1)\n(jammertagen,1)\n(zieh,1)\n(ihm,1)\n(ihm,2)\n(ihm,3)\n(besondre,1)\n(ihn,1)\n(ihn,2)\n(ihn,3)\n(ihn,4)\n(ihn,5)\n(grossen,1)\n(vollen,1)\n(ihr,1)\n(ihr,2)\n(ihr,3)\n(ihr,4)\n(ihr,5)\n(ihr,6)\n(ihr,7)\n(boten,1)\n(voller,1)\n(singt,1)\n(muhme,1)\n(schon,1)\n(last,1)\n(kleine,1)\n(paradieseshelle,1)\n(nein,1)\n(echten,1)\n(unter,1)\n(bei,1)\n(herr,1)\n(herr,2)\n(herr,3)\n(herr,4)\n(herr,5)\n(herr,6)\n(herr,7)\n(herr,8)\n(herr,9)\n(herr,10)\n(herr,11)\n(gern,1)\n(gern,2)\n(gern,3)\n(sphaerenlauf,1)\n(stets,1)\n(ganze,1)\n(braechte,1)\n(fordert,1)\n(schoensten,1)\n(herrlich,1)\n(herrlich,2)\n(gegeben,1)\n(allein,1)\n(allein,2)\n(reichen,1)\n(schauervoller,1)\n(musst,1)\n(recht,1)\n(bleibt,1)\n(pracht,1)\n(treibt,1)\n(befangen,1)\n(was,1)\n(was,2)\n(menschen,1)\n(menschen,2)\n(menschen,3)\n(jede,1)\n(hohe,1)\n(tiefsten,1)\n(bilden,1)\n(drum,1)\n(gibt,1)\n(gibt,2)\n(guter,1)\n(fuerwahr,1)\n(im,1)\n(im,2)\n(im,3)\n(grund,1)\n(in,1)\n(in,2)\n(in,3)\n(in,4)\n(in,5)\n(in,6)\n(in,7)\n(in,8)\n(in,9)\n(hoechste,1)\n(schliesst,1)\n(fels,1)\n(steh,1)\n(euer,1)\n(erster,1)\n(ersten,1)\n(ersten,2)\n(ersten,3)\n(goettersoehne,1)\n(brechen,1)\n(tiefen,1)\n(frucht,1)\n(kreis,1)\n(siehst,1)\n(wege,1)\n(ist,1)\n(ist,2)\n(ist,3)\n(ist,4)\n(ist,5)\n(ist,6)\n(ist,7)\n(ist,8)\n(zikaden,1)\n(frischen,1)\n(ruh,1)\n(deine,1)\n(deine,2)\n(maus,1)\n(brudersphaeren,1)\n(nachher,1)\n(euch,1)\n(euch,2)\n(euch,3)\n(euch,4)\n(gnaden,1)\n(anzuklagen,1)\n(schlange,1)\n(staerke,1)\n(staerke,2)\n(erde,1)\n(erde,2)\n(erde,3)\n(erde,4)\n(verlaub,1)\n(sanfte,1)\n(holden,1)\n(sonst,1)\n(treten,1)\n(sahst,1)\n(alten,1)\n(um,1)\n(wieder,1)\n(alter,1)\n(altes,1)\n(nun,1)\n(lieb,1)\n(gesellen,1)\n(erscheinen,1)\n(wirkt,1)\n(wirkt,2)\n(haettst,1)\n(haettst,2)\n(nur,1)\n(nur,2)\n(nur,3)\n(nur,4)\n(nur,5)\n(nur,6)\n(nur,7)\n(tiefbewegte,1)\n(lachen,1)\n(lachen,2)\n(drange,1)\n(schlag,1)\n(schein,1)\n(muss,1)\n(verworren,1)\n(weges,1)\n(allen,1)\n(gewoehnlich,1)\n(alles,1)\n(halb,1)\n(stuerme,1)\n(springt,1)\n(sollt,1)\n(klarheit,1)\n(so,1)\n(so,2)\n(so,3)\n(so,4)\n(so,5)\n(so,6)\n(erfassen,1)\n(liedchen,1)\n(prolog,1)\n(zur,1)\n(fressen,1)\n(zum,1)\n(faust,1)\n(faust,2)\n(erzengel,1)\n(erzengel,2)\n(jahre,1)\n(sonn,1)\n(raphael,1)\n(land,1)\n(land,2)\n(lang,1)\n(gelange,1)\n(lust,1)\n(lust,2)\n(welt,1)\n(sehe,1)\n(ihre,1)\n(jedes,1)\n(erfreut,1)\n(seiner,1)\n(denn,1)\n(wandeln,1)\n(wechselt,1)\n(jeden,1)\n(dort,1)\n(schlecht,1)\n(wenigsten,1)\n(wuerd,1)\n(schranken,1)\n(bewusst,1)\n(bewusst,2)\n(seinem,1)\n(seinem,2)\n(gehasst,1)\n(sein,1)\n(meinem,1)\n(meinen,1)\n(pathos,1)\n(herrn,1)\n(lange,1)\n(lange,2)\n(herab,1)\n(diesen,1)\n(ihren,1)\n(beruehmte,1)\n(goethe,1)\n(tag,1)\n(tag,2)\n(tag,3)\n(tier,1)\n(quark,1)\n(dank,1)\n(seine,1)\n(teufel,1)\n(teufel,2)\n(zweck,1)\n(wenn,1)\n(wenn,2)\n(wenn,3)\n(wenn,4)\n(wenn,5)\n(wenn,6)\n(wenn,7)\n(soll,1)\n(wirkung,1)\n(erlaubnis,1)\n(lebendig,1)\n(uns,1)\n(leicht,1)\n(gewiss,1)\n(schnell,1)\n(und,1)\n(und,2)\n(und,3)\n(und,4)\n(und,5)\n(und,6)\n(und,7)\n(und,8)\n(und,9)\n(und,10)\n(und,11)\n(und,12)\n(und,13)\n(und,14)\n(und,15)\n(und,16)\n(und,17)\n(und,18)\n(und,19)\n(und,20)\n(und,21)\n(und,22)\n(und,23)\n(und,24)\n(und,25)\n(und,26)\n(und,27)\n(und,28)\n(und,29)\n(gerne,1)\n(rechten,1)\n(umher,1)\n(umher,2)\n(vernunft,1)\n(grase,1)\n(nach,1)\n(leben,1)\n(gott,1)\n(der,1)\n(der,2)\n(der,3)\n(der,4)\n(der,5)\n(der,6)\n(der,7)\n(der,8)\n(der,9)\n(der,10)\n(der,11)\n(der,12)\n(der,13)\n(der,14)\n(der,15)\n(der,16)\n(der,17)\n(der,18)\n(der,19)\n(der,20)\n(der,21)\n(der,22)\n(der,23)\n(der,24)\n(der,25)\n(der,26)\n(der,27)\n(der,28)\n(der,29)\n(des,1)\n(des,2)\n(des,3)\n(des,4)\n(des,5)\n(doktor,1)\n(beschaemt,1)\n(dreht,1)\n(habe,1)\n(sagen,1)\n(sagen,2)\n(bekennen,1)\n(dunklen,1)\n(wettet,1)\n(den,1)\n(den,2)\n(den,3)\n(den,4)\n(den,5)\n(den,6)\n(den,7)\n(den,8)\n(den,9)\n(mephistopheles,1)\n(mephistopheles,2)\n(mephistopheles,3)\n(mephistopheles,4)\n(mephistopheles,5)\n(mephistopheles,6)\n(mephistopheles,7)\n(mephistopheles,8)\n(mephistopheles,9)\n(dem,1)\n(dem,2)\n(dem,3)\n(dem,4)\n(auch,1)\n(auch,2)\n(auch,3)\n(auch,4)\n(kann,1)\n(kann,2)\n(armen,1)\n(mir,1)\n(mir,2)\n(mir,3)\n(mir,4)\n(mir,5)\n(mir,6)\n(mir,7)\n(mir,8)\n(mir,9)\n(strebt,1)\n(gut,1)\n(gut,2)\n(mit,1)\n(mit,2)\n(mit,3)\n(mit,4)\n(mit,5)\n(mit,6)\n(mit,7)\n(mit,8)\n(mit,9)\n(mit,10)\n(mit,11)\n(bald,1)\n(bald,2)\n(himmlischen,1)\n(himmel,1)\n(himmel,2)\n(himmel,3)\n(noch,1)\n(noch,2)\n(noch,3)\n(kannst,1)\n(deinesgleichen,1)\n(flammt,1)\n(ergruenden,1)\n(ergruenden,2)\n(nacht,1)\n(scheint,1)\n(ferne,1)\n(ferne,2)\n(tragoedie,1)\n(abgewoehnt,1)\n(reizt,1)\n(geistern,1)\n(nicht,1)\n(nicht,2)\n(nicht,3)\n(nicht,4)\n(nicht,5)\n(nicht,6)\n(nicht,7)\n(nicht,8)\n(nicht,9)\n(nicht,10)\n(sacht,1)\n(unbegreiflich,1)\n(unbegreiflich,2)\n(schnelle,1)\n(einmal,1)\n(werd,1)\n(werke,1)\n(werke,2)\n(begraebt,1)\n(knecht,1)\n(rings,1)\n(wird,1)\n(katze,1)\n(huete,1)\n(fortgerissen,1)\n(gebt,1)\n(huebsch,1)\n(hast,1)\n(irrt,1)\n(befinde,1)\n(sind,1)\n(sind,2)\n(fuehren,1)\n(fuehren,2)\n(fliegt,1)\n(ewig,1)\n(ewig,2)\n(ewig,3)\n(brust,1)\n(brust,2)\n(sonne,1)\n(sprechen,1)\n(ein,1)\n(ein,2)\n(ein,3)\n(strasse,1)\n(von,1)\n(von,2)\n(von,3)\n(von,4)\n(von,5)\n(von,6)\n(von,7)\n(von,8)\n(ueberlassen,1)\n(dir,1)\n(dir,2)\n(dir,3)\n(dir,4)\n(vom,1)\n(vom,2)\n(vom,3)\n(zu,1)\n(zu,2)\n(zu,3)\n(zu,4)\n(zu,5)\n(zu,6)\n(zu,7)\n(zu,8)\n(zu,9)\n(zu,10)\n(zu,11)\n(schwebt,1)\n(die,1)\n(die,2)\n(die,3)\n(die,4)\n(die,5)\n(die,6)\n(die,7)\n(die,8)\n(die,9)\n(die,10)\n(die,11)\n(die,12)\n(die,13)\n(die,14)\n(die,15)\n(die,16)\n(die,17)\n(die,18)\n(die,19)\n(die,20)\n(die,21)\n(die,22)\n(vor,1)\n(vor,2)\n(wangen,1)\n(wettgesang,1)\n(donnerschlags,1)\n(find,1)\n(dich,1)\n(dich,2)\n(dich,3)\n(umfass,1)\n(verboten,1)\n(laeg,1)\n(nie,1)\n(drei,1)\n(drei,2)\n(dauern,1)\n(toren,1)\n(dauert,1)\n(verheeren,1)\n(fliegend,1)\n(aus,1)\n(staub,1)\n(fluessen,1)\n(haus,1)\n(auf,1)\n(auf,2)\n(auf,3)\n(auf,4)\n(auf,5)\n(dient,1)\n(dient,2)\n(tiefer,1)\n(naeh,1)\n(zieren,1)\n"
public static final String	TEXT	"Goethe - Faust: Der Tragoedie erster Teil\nProlog im Himmel.\nDer Herr. Die himmlischen Heerscharen. Nachher Mephistopheles. Die drei\nErzengel treten vor.\nRAPHAEL: Die Sonne toent, nach alter Weise, In Brudersphaeren Wettgesang,\nUnd ihre vorgeschriebne Reise Vollendet sie mit Donnergang. Ihr Anblick\ngibt den Engeln Staerke, Wenn keiner Sie ergruenden mag; die unbegreiflich\nhohen Werke Sind herrlich wie am ersten Tag.\nGABRIEL: Und schnell und unbegreiflich schnelle Dreht sich umher der Erde\nPracht; Es wechselt Paradieseshelle Mit tiefer, schauervoller Nacht. Es\nschaeumt das Meer in breiten Fluessen Am tiefen Grund der Felsen auf, Und\nFels und Meer wird fortgerissen Im ewig schnellem Sphaerenlauf.\nMICHAEL: Und Stuerme brausen um die Wette Vom Meer aufs Land, vom Land\naufs Meer, und bilden wuetend eine Kette Der tiefsten Wirkung rings umher.\nDa flammt ein blitzendes Verheeren Dem Pfade vor des Donnerschlags. Doch\ndeine Boten, Herr, verehren Das sanfte Wandeln deines Tags.\nZU DREI: Der Anblick gibt den Engeln Staerke, Da keiner dich ergruenden\nmag, Und alle deine hohen Werke Sind herrlich wie am ersten Tag.\nMEPHISTOPHELES: Da du, o Herr, dich einmal wieder nahst Und fragst, wie\nalles sich bei uns befinde, Und du mich sonst gewoehnlich gerne sahst, So\nsiehst du mich auch unter dem Gesinde. Verzeih, ich kann nicht hohe Worte\nmachen, Und wenn mich auch der ganze Kreis verhoehnt; Mein Pathos braechte\ndich gewiss zum Lachen, Haettst du dir nicht das Lachen abgewoehnt. Von\nSonn\' und Welten weiss ich nichts zu sagen, Ich sehe nur, wie sich die\nMenschen plagen. Der kleine Gott der Welt bleibt stets von gleichem\nSchlag, Und ist so wunderlich als wie am ersten Tag. Ein wenig besser\nwuerd er leben, Haettst du ihm nicht den Schein des Himmelslichts gegeben;\nEr nennt\'s Vernunft und braucht\'s allein, Nur tierischer als jedes Tier\nzu sein. Er scheint mir, mit Verlaub von euer Gnaden, Wie eine der\nlangbeinigen Zikaden, Die immer fliegt und fliegend springt Und gleich im\nGras ihr altes Liedchen singt; Und laeg er nur noch immer in dem Grase! In\njeden Quark begraebt er seine Nase.\nDER HERR: Hast du mir weiter nichts zu sagen? Kommst du nur immer\nanzuklagen? Ist auf der Erde ewig dir nichts recht?\nMEPHISTOPHELES: Nein Herr! ich find es dort, wie immer, herzlich\nschlecht. Die Menschen dauern mich in ihren Jammertagen, Ich mag sogar\ndie armen selbst nicht plagen.\nDER HERR: Kennst du den Faust?\nMEPHISTOPHELES: Den Doktor?\nDER HERR: Meinen Knecht!\nMEPHISTOPHELES: Fuerwahr! er dient Euch auf besondre Weise. Nicht irdisch\nist des Toren Trank noch Speise. Ihn treibt die Gaerung in die Ferne, Er\nist sich seiner Tollheit halb bewusst; Vom Himmel fordert er die schoensten\nSterne Und von der Erde jede hoechste Lust, Und alle Naeh und alle Ferne\nBefriedigt nicht die tiefbewegte Brust.\nDER HERR: Wenn er mir auch nur verworren dient, So werd ich ihn bald in\ndie Klarheit fuehren. Weiss doch der Gaertner, wenn das Baeumchen gruent, Das\nBluet und Frucht die kuenft\'gen Jahre zieren.\nMEPHISTOPHELES: Was wettet Ihr? den sollt Ihr noch verlieren! Wenn Ihr\nmir die Erlaubnis gebt, Ihn meine Strasse sacht zu fuehren.\nDER HERR: Solang er auf der Erde lebt, So lange sei dir\'s nicht verboten,\nEs irrt der Mensch so lang er strebt.\nMEPHISTOPHELES: Da dank ich Euch; denn mit den Toten Hab ich mich niemals\ngern befangen. Am meisten lieb ich mir die vollen, frischen Wangen. Fuer\neinem Leichnam bin ich nicht zu Haus; Mir geht es wie der Katze mit der Maus.\nDER HERR: Nun gut, es sei dir ueberlassen! Zieh diesen Geist von seinem\nUrquell ab, Und fuehr ihn, kannst du ihn erfassen, Auf deinem Wege mit\nherab, Und steh beschaemt, wenn du bekennen musst: Ein guter Mensch, in\nseinem dunklen Drange, Ist sich des rechten Weges wohl bewusst.\nMEPHISTOPHELES: Schon gut! nur dauert es nicht lange. Mir ist fuer meine\nWette gar nicht bange. Wenn ich zu meinem Zweck gelange, Erlaubt Ihr mir\nTriumph aus voller Brust. Staub soll er fressen, und mit Lust, Wie meine\nMuhme, die beruehmte Schlange.\nDER HERR: Du darfst auch da nur frei erscheinen; Ich habe deinesgleichen\nnie gehasst. Von allen Geistern, die verneinen, ist mir der Schalk am\nwenigsten zur Last. Des Menschen Taetigkeit kann allzu leicht erschlaffen,\ner liebt sich bald die unbedingte Ruh; Drum geb ich gern ihm den Gesellen\nzu, Der reizt und wirkt und muss als Teufel schaffen. Doch ihr, die echten\nGoettersoehne, Erfreut euch der lebendig reichen Schoene! Das Werdende, das\newig wirkt und lebt, Umfass euch mit der Liebe holden Schranken, Und was\nin schwankender Erscheinung schwebt, Befestigt mit dauernden Gedanken!\n(Der Himmel schliesst, die Erzengel verteilen sich.)\nMEPHISTOPHELES (allein): Von Zeit zu Zeit seh ich den Alten gern, Und\nhuete mich, mit ihm zu brechen. Es ist gar huebsch von einem grossen Herrn,\nSo menschlich mit dem Teufel selbst zu sprechen."

org.apache.flink.test.util.MiniClusterResource

Modifier and Type	Constant Field	Value
public static final String	CODEBASE_KEY	"codebase"
public static final String	NEW_CODEBASE	"new"

org.apache.flink.test.util.TestBaseUtils

Modifier and Type	Constant Field	Value
protected static final long	DEFAULT_AKKA_ASK_TIMEOUT	1000L
protected static final String	DEFAULT_AKKA_STARTUP_TIMEOUT	"60 s"
protected static final int	MINIMUM_HEAP_SIZE_MB	192
protected static final long	TASK_MANAGER_MEMORY_SIZE	80L

org.apache.flink.util.AbstractID

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

org.apache.flink.util.ExceptionUtils

Modifier and Type	Constant Field	Value
public static final String	STRINGIFIED_NULL_EXCEPTION	"(null)"

org.apache.flink.yarn.Utils

Modifier and Type	Constant Field	Value
public static final String	KEYTAB_FILE_NAME	"krb5.keytab"
public static final String	KRB5_FILE_NAME	"krb5.conf"
public static final String	YARN_SITE_FILE_NAME	"yarn-site.xml"

org.apache.flink.yarn.YarnConfigKeys

Modifier and Type	Constant Field	Value
public static final String	ENV_APP_ID	"_APP_ID"
public static final String	ENV_CLIENT_HOME_DIR	"_CLIENT_HOME_DIR"
public static final String	ENV_CLIENT_SHIP_FILES	"_CLIENT_SHIP_FILES"
public static final String	ENV_DETACHED	"_DETACHED"
public static final String	ENV_DYNAMIC_PROPERTIES	"_DYNAMIC_PROPERTIES"
public static final String	ENV_FLINK_CLASSPATH	"_FLINK_CLASSPATH"
public static final String	ENV_HADOOP_USER_NAME	"HADOOP_USER_NAME"
public static final String	ENV_KRB5_PATH	"_KRB5_PATH"
public static final String	ENV_SLOTS	"_SLOTS"
public static final String	ENV_TM_COUNT	"_CLIENT_TM_COUNT"
public static final String	ENV_TM_MEMORY	"_CLIENT_TM_MEMORY"
public static final String	ENV_YARN_SITE_XML_PATH	"_YARN_SITE_XML_PATH"
public static final String	ENV_ZOOKEEPER_NAMESPACE	"_ZOOKEEPER_NAMESPACE"
public static final String	FLINK_JAR_PATH	"_FLINK_JAR_PATH"
public static final String	FLINK_YARN_FILES	"_FLINK_YARN_FILES"
public static final String	KEYTAB_PATH	"_KEYTAB_PATH"
public static final String	KEYTAB_PRINCIPAL	"_KEYTAB_PRINCIPAL"

org.apache.flink.yarn.cli.FlinkYarnSessionCli

Modifier and Type	Constant Field	Value
public static final String	CONFIG_FILE_LOG4J_NAME	"log4j.properties"
public static final String	CONFIG_FILE_LOGBACK_NAME	"logback.xml"

org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

Modifier and Type	Constant Field	Value
public static final String	JOB_GRAPH_FILE_PATH	"flink.jobgraph.path"

org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

Modifier and Type	Constant Field	Value
public static final String	FLINK_RECOVERY_DATA_DIR	"flink_recovery_data"