Package | Description |
---|---|
org.apache.flink.configuration | |
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.runtime.jobmanager |
Modifier and Type | Field and Description |
---|---|
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<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<Boolean> |
TaskManagerOptions.EXIT_ON_FATAL_AKKA_ERROR
Deprecated.
Only introduced in 1.2.1 to not change the default behaviour
|
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<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> |
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> |
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<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> |
HighAvailabilityOptions.ZOOKEEPER_CONNECTION_TIMEOUT |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_MAX_RETRY_ATTEMPTS |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_RETRY_WAIT |
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.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_RM_CONTAINER_IMAGE_NAME |
static ConfigOption<String> |
MesosTaskManagerParameters.MESOS_RM_CONTAINER_TYPE |
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 |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
JobManagerOptions.MAX_ATTEMPTS_HISTORY_SIZE
The maximum number of prior execution attempts kept in history.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.