Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
JobManagerOptions.ADDRESS
The config parameter defining the network address to connect to
for communication with the job manager.
|
static ConfigOption<String> |
AkkaOptions.AKKA_ASK_TIMEOUT
Timeout for akka ask calls
|
static ConfigOption<String> |
AkkaOptions.AKKA_TCP_TIMEOUT
The Akka tcp connection timeout.
|
static ConfigOption<String> |
AkkaOptions.AKKA_WATCH_HEARTBEAT_INTERVAL
The Akka death watch heartbeat interval.
|
static ConfigOption<String> |
AkkaOptions.AKKA_WATCH_HEARTBEAT_PAUSE
The maximum acceptable Akka death watch heartbeat pause.
|
static ConfigOption<String> |
JobManagerOptions.ARCHIVE_DIR
The location where the JobManager stores the archives of completed jobs.
|
static ConfigOption<Integer> |
QueryableStateOptions.CLIENT_LOOKUP_RETRIES
Number of retries on location lookup failures.
|
static ConfigOption<Integer> |
QueryableStateOptions.CLIENT_LOOKUP_RETRY_DELAY
Retry delay on location lookup failures (millis).
|
static ConfigOption<Integer> |
QueryableStateOptions.CLIENT_NETWORK_THREADS
Number of network (event loop) threads for the KvState client (0 => Use number of available cores).
|
static ConfigOption<String> |
ConfigConstants.DEFAULT_JOB_MANAGER_WEB_FRONTEND_ADDRESS
The config key for the address of the JobManager web frontend.
|
static ConfigOption<Integer> |
CoreOptions.DEFAULT_PARALLELISM_KEY |
static ConfigOption<String> |
JobManagerOptions.EXECUTION_FAILOVER_STRATEGY
The maximum number of prior execution attempts kept in history.
|
static ConfigOption<Boolean> |
TaskManagerOptions.EXIT_ON_FATAL_AKKA_ERROR
Whether the quarantine monitor for task managers shall be started.
|
static ConfigOption<String> |
CoreOptions.FLINK_JM_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_TM_JVM_OPTIONS |
static ConfigOption<String> |
HighAvailabilityOptions.HA_CLUSTER_ID
The ID of the Flink cluster, used to separate multiple Flink clusters
Needs to be set for standalone clusters, is automatically inferred in YARN and Mesos.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_JOB_DELAY
The time before a JobManager after a fail over recovers the current jobs.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_JOB_MANAGER_PORT_RANGE
Optional port (range) used by the job manager in high-availability mode.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_MODE
Defines high-availability mode used for the cluster execution.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_STORAGE_PATH
File system path (URI) where Flink persists metadata in high-availability setups
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_QUORUM
The ZooKeeper quorum to use, when running Flink in a high-availability mode with ZooKeeper.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_ROOT
The root path under which Flink stores its entries in ZooKeeper
|
static ConfigOption<Long> |
HeartbeatManagerOptions.HEARTBEAT_INTERVAL
Time interval for requesting heartbeat from sender side
|
static ConfigOption<Long> |
HeartbeatManagerOptions.HEARTBEAT_TIMEOUT
Timeout for requesting and receiving heartbeat for both sender and receiver sides
|
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_DIRS
Comma-separated list of directories which the HistoryServer polls for new archives.
|
static ConfigOption<Long> |
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_REFRESH_INTERVAL
The interval at which the HistoryServer polls
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_DIRS for new archives. |
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_WEB_ADDRESS
The address under which the HistoryServer web-frontend is accessible.
|
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_WEB_DIR
The local directory used by the HistoryServer web-frontend.
|
static ConfigOption<Integer> |
HistoryServerOptions.HISTORY_SERVER_WEB_PORT
The port under which the HistoryServer web-frontend is accessible.
|
static ConfigOption<Long> |
HistoryServerOptions.HISTORY_SERVER_WEB_REFRESH_INTERVAL
The refresh interval for the HistoryServer web-frontend in milliseconds.
|
static ConfigOption<Boolean> |
HistoryServerOptions.HISTORY_SERVER_WEB_SSL_ENABLED
Enables/Disables SSL support for the HistoryServer web-frontend.
|
static ConfigOption<Integer> |
JobManagerOptions.JOB_MANAGER_HEAP_MEMORY
JVM heap size (in megabytes) for the JobManager
|
static ConfigOption<String> |
ResourceManagerOptions.JOB_TIMEOUT
Timeout for jobs which don't have a job manager as leader assigned.
|
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_CONTEXTS |
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_KEYTAB |
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_PRINCIPAL |
static ConfigOption<Boolean> |
SecurityOptions.KERBEROS_LOGIN_USETICKETCACHE |
static ConfigOption<Boolean> |
TaskManagerOptions.KILL_ON_OUT_OF_MEMORY
Whether to kill the TaskManager when the task thread throws an OutOfMemoryError
|
static ConfigOption<Integer> |
MetricOptions.LATENCY_HISTORY_SIZE
The number of measured latencies to maintain at each operator
|
static ConfigOption<Float> |
TaskManagerOptions.MANAGED_MEMORY_FRACTION
Fraction of free memory allocated by the memory manager if
TaskManagerOptions.MANAGED_MEMORY_SIZE is
not set. |
static ConfigOption<Boolean> |
TaskManagerOptions.MANAGED_MEMORY_PRE_ALLOCATE
Whether TaskManager managed memory should be pre-allocated when the TaskManager is starting.
|
static ConfigOption<Long> |
TaskManagerOptions.MANAGED_MEMORY_SIZE
Amount of memory to be allocated by the task manager's memory manager (in megabytes).
|
static ConfigOption<Integer> |
JobManagerOptions.MAX_ATTEMPTS_HISTORY_SIZE
The maximum number of prior execution attempts kept in history.
|
static ConfigOption<Integer> |
CoreOptions.MAX_RETAINED_CHECKPOINTS
The maximum number of completed checkpoint instances to retain.
|
static ConfigOption<Boolean> |
TaskManagerOptions.MEMORY_OFF_HEAP
Memory allocation method (JVM heap or off-heap), used for managed memory of the TaskManager
as well as the network buffers.
|
static ConfigOption<Integer> |
TaskManagerOptions.MEMORY_SEGMENT_SIZE
Size of memory buffers used by the network stack and the memory manager (in bytes).
|
static ConfigOption<Float> |
TaskManagerOptions.NETWORK_BUFFERS_MEMORY_FRACTION
Fraction of JVM memory to use for network buffers.
|
static ConfigOption<Long> |
TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MAX
Maximum memory size for network buffers (in bytes)
|
static ConfigOption<Long> |
TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MIN
Minimum memory size for network buffers (in bytes)
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_BUFFERS_PER_CHANNEL
Number of network buffers to use for each outgoing/incoming channel (subpartition/input channel).
|
static ConfigOption<Boolean> |
TaskManagerOptions.NETWORK_DETAILED_METRICS
Boolean flag to enable/disable more detailed metrics about inbound/outbound network queue
lengths.
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_EXTRA_BUFFERS_PER_GATE
Number of extra network buffers to use for each outgoing/incoming gate (result partition/input gate).
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_NUM_BUFFERS
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_REQUEST_BACKOFF_INITIAL
Minimum backoff for partition requests of input channels.
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_REQUEST_BACKOFF_MAX
Maximum backoff for partition requests of input channels.
|
static ConfigOption<Integer> |
JobManagerOptions.PORT
The config parameter defining the network port to connect to
for communication with the job manager.
|
static ConfigOption<String> |
MetricOptions.REPORTERS_LIST
The list of named reporters.
|
static ConfigOption<Long> |
JobManagerOptions.RESOURCE_MANAGER_RECONNECT_INTERVAL
This option specifies the interval in order to trigger a resource manager reconnection if the connection
to the resource manager has been lost.
|
static ConfigOption<String> |
MetricOptions.SCOPE_DELIMITER
The delimiter used to assemble the metric identifier.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_JM
The scope format string that is applied to all metrics scoped to a JobManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_JM_JOB
The scope format string that is applied to all metrics scoped to a job on a JobManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_OPERATOR
The scope format string that is applied to all metrics scoped to an operator.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TASK
The scope format string that is applied to all metrics scoped to a task.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TM
The scope format string that is applied to all metrics scoped to a TaskManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TM_JOB
The scope format string that is applied to all metrics scoped to a job on a TaskManager.
|
static ConfigOption<Integer> |
QueryableStateOptions.SERVER_ASYNC_QUERY_THREADS
Number of async query threads for the KvStateServerHandler (0 => #slots).
|
static ConfigOption<Boolean> |
QueryableStateOptions.SERVER_ENABLE
Flag to indicate whether to start the queryable state server.
|
static ConfigOption<Integer> |
QueryableStateOptions.SERVER_NETWORK_THREADS
Number of network (event loop) threads for the KvState server (0 => #slots).
|
static ConfigOption<Integer> |
QueryableStateOptions.SERVER_PORT
Port to bind KvState server to (0 => pick random available port).
|
static ConfigOption<String> |
CoreOptions.STATE_BACKEND |
static ConfigOption<Long> |
TaskManagerOptions.TASK_CANCELLATION_INTERVAL
Time interval in milliseconds between two successive task cancellation
attempts.
|
static ConfigOption<Long> |
TaskManagerOptions.TASK_CANCELLATION_TIMEOUT
Timeout in milliseconds after which a task cancellation times out and
leads to a fatal TaskManager error.
|
static ConfigOption<Long> |
TaskManagerOptions.TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT
The maximum number of bytes that a checkpoint alignment may buffer.
|
static ConfigOption<Integer> |
TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY
JVM heap size (in megabytes) for the TaskManagers
|
static ConfigOption<String> |
JobManagerOptions.WEB_ACCESS_CONTROL_ALLOW_ORIGIN
The config parameter defining the Access-Control-Allow-Origin header for all
responses from the web-frontend.
|
static ConfigOption<Integer> |
JobManagerOptions.WEB_ARCHIVE_COUNT
The config parameter defining the number of archived jobs for the jobmanager.
|
static ConfigOption<Integer> |
JobManagerOptions.WEB_BACKPRESSURE_CLEANUP_INTERVAL
Time after which cached stats are cleaned up if not accessed.
|
static ConfigOption<Integer> |
JobManagerOptions.WEB_BACKPRESSURE_DELAY
Delay between stack trace samples to determine back pressure.
|
static ConfigOption<Integer> |
JobManagerOptions.WEB_BACKPRESSURE_NUM_SAMPLES
Number of stack trace samples to take to determine back pressure.
|
static ConfigOption<Integer> |
JobManagerOptions.WEB_BACKPRESSURE_REFRESH_INTERVAL
Time after which available stats are deprecated and need to be refreshed (by resampling).
|
static ConfigOption<Integer> |
JobManagerOptions.WEB_CHECKPOINTS_HISTORY_SIZE
Config parameter defining the number of checkpoints to remember for recent history.
|
static ConfigOption<String> |
JobManagerOptions.WEB_LOG_PATH
The log file location (may be in /log for standalone but under log directory when using YARN).
|
static ConfigOption<Integer> |
JobManagerOptions.WEB_PORT
The port for the runtime monitor web-frontend server.
|
static ConfigOption<Boolean> |
JobManagerOptions.WEB_SSL_ENABLED
Config parameter to override SSL support for the JobManager Web UI
|
static ConfigOption<Boolean> |
JobManagerOptions.WEB_SUBMIT_ENABLE
Config parameter indicating whether jobs can be uploaded and run from the web-frontend.
|
static ConfigOption<String> |
JobManagerOptions.WEB_TMP_DIR
The config parameter defining the flink web directory to be used by the webmonitor.
|
static ConfigOption<String> |
JobManagerOptions.WEB_UPLOAD_DIR
The config parameter defining the directory for uploading the job jars.
|
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_CONNECTION_TIMEOUT |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_MAX_RETRY_ATTEMPTS |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_RETRY_WAIT |
static ConfigOption<String> |
HighAvailabilityOptions.ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH |
static ConfigOption<Boolean> |
SecurityOptions.ZOOKEEPER_SASL_DISABLE |
static ConfigOption<String> |
SecurityOptions.ZOOKEEPER_SASL_LOGIN_CONTEXT_NAME |
static ConfigOption<String> |
SecurityOptions.ZOOKEEPER_SASL_SERVICE_NAME |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT |
Modifier and Type | Method and Description |
---|---|
<T> ConfigOption<T> |
ConfigOptions.OptionBuilder.defaultValue(T value)
Creates a ConfigOption with the given default value.
|
ConfigOption<String> |
ConfigOptions.OptionBuilder.noDefaultValue()
Creates a string-valued option with no default value.
|
ConfigOption<T> |
ConfigOption.withDeprecatedKeys(String... deprecatedKeys)
Creates a new config option, using this option's key and default value, and
adding the given deprecated keys.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DelegatingConfiguration.contains(ConfigOption<?> configOption) |
boolean |
Configuration.contains(ConfigOption<?> configOption)
Checks whether there is an entry for the given config option
|
boolean |
DelegatingConfiguration.getBoolean(ConfigOption<Boolean> configOption) |
boolean |
Configuration.getBoolean(ConfigOption<Boolean> configOption)
Returns the value associated with the given config option as a boolean.
|
double |
DelegatingConfiguration.getDouble(ConfigOption<Double> configOption) |
double |
Configuration.getDouble(ConfigOption<Double> configOption)
Returns the value associated with the given config option as a
double . |
float |
DelegatingConfiguration.getFloat(ConfigOption<Float> configOption) |
float |
Configuration.getFloat(ConfigOption<Float> configOption)
Returns the value associated with the given config option as a float.
|
int |
DelegatingConfiguration.getInteger(ConfigOption<Integer> configOption) |
int |
Configuration.getInteger(ConfigOption<Integer> configOption)
Returns the value associated with the given config option as an integer.
|
long |
DelegatingConfiguration.getLong(ConfigOption<Long> configOption) |
long |
Configuration.getLong(ConfigOption<Long> configOption)
Returns the value associated with the given config option as a long integer.
|
String |
DelegatingConfiguration.getString(ConfigOption<String> configOption) |
String |
Configuration.getString(ConfigOption<String> configOption)
Returns the value associated with the given config option as a string.
|
String |
DelegatingConfiguration.getString(ConfigOption<String> configOption,
String overrideDefault) |
String |
Configuration.getString(ConfigOption<String> configOption,
String overrideDefault)
Returns the value associated with the given config option as a string.
|
String |
DelegatingConfiguration.getValue(ConfigOption<?> configOption) |
String |
Configuration.getValue(ConfigOption<?> configOption)
Returns the value associated with the given config option as a string.
|
void |
DelegatingConfiguration.setBoolean(ConfigOption<Boolean> key,
boolean value) |
void |
Configuration.setBoolean(ConfigOption<Boolean> key,
boolean value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setDouble(ConfigOption<Double> key,
double value) |
void |
Configuration.setDouble(ConfigOption<Double> key,
double value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setFloat(ConfigOption<Float> key,
float value) |
void |
Configuration.setFloat(ConfigOption<Float> key,
float value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setInteger(ConfigOption<Integer> key,
int value) |
void |
Configuration.setInteger(ConfigOption<Integer> key,
int value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setLong(ConfigOption<Long> key,
long value) |
void |
Configuration.setLong(ConfigOption<Long> key,
long value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setString(ConfigOption<String> key,
String value) |
void |
Configuration.setString(ConfigOption<String> key,
String value)
Adds the given value to the configuration object.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_CONSTRAINTS_HARD_HOSTATTR |
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_IMAGE_NAME |
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_TYPE |
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_VOLUMES |
static ConfigOption<Double> |
MesosTaskManagerParameters.MESOS_RM_TASKS_CPUS |
static ConfigOption<Integer> |
MesosTaskManagerParameters.MESOS_RM_TASKS_MEMORY_MB |
static ConfigOption<Integer> |
MesosTaskManagerParameters.MESOS_RM_TASKS_SLOTS |
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_TM_BOOTSTRAP_CMD |
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_TM_HOSTNAME |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
PythonOptions.DATA_TMP_DIR
The config parameter defining where the memory-mapped files will be created.
|
static ConfigOption<String> |
PythonOptions.DC_TMP_DIR
The config parameter defining where the flink python library and user supplied files will be uploaded to before
registering them with the Distributed Cache.
|
static ConfigOption<Long> |
PythonOptions.MMAP_FILE_SIZE
The config parameter defining the size of the memory-mapped files, in kb.
|
static ConfigOption<String> |
PythonOptions.PLAN_TMP_DIR
The config parameter defining where temporary plan-related files are stored on the client.
|
static ConfigOption<String> |
PythonOptions.PYTHON_BINARY_PATH
The config parameter defining the path to the python binary to use.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
NettyConfig.CLIENT_CONNECT_TIMEOUT_SECONDS |
static ConfigOption<Integer> |
NettyConfig.CONNECT_BACKLOG |
static ConfigOption<Integer> |
NettyConfig.NUM_ARENAS |
static ConfigOption<Integer> |
NettyConfig.NUM_THREADS_CLIENT |
static ConfigOption<Integer> |
NettyConfig.NUM_THREADS_SERVER |
static ConfigOption<Integer> |
NettyConfig.SEND_RECEIVE_BUFFER_SIZE |
static ConfigOption<String> |
NettyConfig.TRANSPORT_TYPE |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
YarnConfigOptions.APP_MASTER_RPC_ADDRESS
The hostname or address where the application master RPC system is listening.
|
static ConfigOption<Integer> |
YarnConfigOptions.APP_MASTER_RPC_PORT
The port where the application master RPC system is listening.
|
static ConfigOption<String> |
YarnConfigOptions.CLASSPATH_INCLUDE_USER_JAR
Defines whether user-jars are included in the system class path for per-job-clusters as well as their positioning
in the path.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.