org.apache.flink.configuration

Class AkkaOptions

java.lang.Object

org.apache.flink.configuration.AkkaOptions

@PublicEvolving
public class AkkaOptions
extends Object

Akka configuration options.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	ASK_TIMEOUT Timeout for akka ask calls.
static ConfigOption<Double>	CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR
static ConfigOption<Integer>	CLIENT_SOCKET_WORKER_POOL_SIZE_MAX
static ConfigOption<Integer>	CLIENT_SOCKET_WORKER_POOL_SIZE_MIN
static ConfigOption<String>	CLIENT_TIMEOUT Timeout for all blocking calls on the client side.
static ConfigOption<Integer>	DISPATCHER_THROUGHPUT Maximum number of messages until another actor is executed by the same thread.
static ConfigOption<Double>	FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR
static ConfigOption<Integer>	FORK_JOIN_EXECUTOR_PARALLELISM_MAX
static ConfigOption<Integer>	FORK_JOIN_EXECUTOR_PARALLELISM_MIN
static ConfigOption<String>	FRAMESIZE Maximum framesize of akka messages.
static ConfigOption<Boolean>	JVM_EXIT_ON_FATAL_ERROR Exit JVM on fatal Akka errors.
static ConfigOption<Boolean>	LOG_LIFECYCLE_EVENTS Log lifecycle events.
static ConfigOption<String>	LOOKUP_TIMEOUT Timeout for all blocking calls that look up remote actors.
static ConfigOption<Long>	RETRY_GATE_CLOSED_FOR Milliseconds a gate should be closed for after a remote connection was disconnected.
static ConfigOption<Double>	SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR
static ConfigOption<Integer>	SERVER_SOCKET_WORKER_POOL_SIZE_MAX
static ConfigOption<Integer>	SERVER_SOCKET_WORKER_POOL_SIZE_MIN
static ConfigOption<Boolean>	SSL_ENABLED Override SSL support for the Akka transport.
static ConfigOption<String>	STARTUP_TIMEOUT Timeout for the startup of the actor system.
static ConfigOption<String>	TCP_TIMEOUT The Akka tcp connection timeout.
static ConfigOption<String>	TRANSPORT_HEARTBEAT_INTERVAL Heartbeat interval of the transport failure detector.
static ConfigOption<String>	TRANSPORT_HEARTBEAT_PAUSE Allowed heartbeat pause for the transport failure detector.
static ConfigOption<Double>	TRANSPORT_THRESHOLD Detection threshold of transport failure detector.
static ConfigOption<String>	WATCH_HEARTBEAT_INTERVAL The Akka death watch heartbeat interval.
static ConfigOption<String>	WATCH_HEARTBEAT_PAUSE The maximum acceptable Akka death watch heartbeat pause.
static ConfigOption<Integer>	WATCH_THRESHOLD Detection threshold for the phi accrual watch failure detector.

Constructor Summary

Constructors

Constructor and Description
AkkaOptions()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ASK_TIMEOUT

public static final ConfigOption<String> ASK_TIMEOUT

Timeout for akka ask calls.

WATCH_HEARTBEAT_INTERVAL

public static final ConfigOption<String> WATCH_HEARTBEAT_INTERVAL

The Akka death watch heartbeat interval.

WATCH_HEARTBEAT_PAUSE

public static final ConfigOption<String> WATCH_HEARTBEAT_PAUSE

The maximum acceptable Akka death watch heartbeat pause.

TCP_TIMEOUT

public static final ConfigOption<String> TCP_TIMEOUT

The Akka tcp connection timeout.

STARTUP_TIMEOUT

public static final ConfigOption<String> STARTUP_TIMEOUT

Timeout for the startup of the actor system.

TRANSPORT_HEARTBEAT_INTERVAL

public static final ConfigOption<String> TRANSPORT_HEARTBEAT_INTERVAL

Heartbeat interval of the transport failure detector.

TRANSPORT_HEARTBEAT_PAUSE

public static final ConfigOption<String> TRANSPORT_HEARTBEAT_PAUSE

Allowed heartbeat pause for the transport failure detector.

TRANSPORT_THRESHOLD

public static final ConfigOption<Double> TRANSPORT_THRESHOLD

Detection threshold of transport failure detector.

WATCH_THRESHOLD

public static final ConfigOption<Integer> WATCH_THRESHOLD

Detection threshold for the phi accrual watch failure detector.

SSL_ENABLED

public static final ConfigOption<Boolean> SSL_ENABLED

Override SSL support for the Akka transport.

FRAMESIZE

public static final ConfigOption<String> FRAMESIZE

Maximum framesize of akka messages.

DISPATCHER_THROUGHPUT

public static final ConfigOption<Integer> DISPATCHER_THROUGHPUT

Maximum number of messages until another actor is executed by the same thread.

LOG_LIFECYCLE_EVENTS

public static final ConfigOption<Boolean> LOG_LIFECYCLE_EVENTS

Log lifecycle events.

LOOKUP_TIMEOUT

public static final ConfigOption<String> LOOKUP_TIMEOUT

Timeout for all blocking calls that look up remote actors.

CLIENT_TIMEOUT

public static final ConfigOption<String> CLIENT_TIMEOUT

Timeout for all blocking calls on the client side.

JVM_EXIT_ON_FATAL_ERROR

public static final ConfigOption<Boolean> JVM_EXIT_ON_FATAL_ERROR

Exit JVM on fatal Akka errors.

RETRY_GATE_CLOSED_FOR

public static final ConfigOption<Long> RETRY_GATE_CLOSED_FOR

Milliseconds a gate should be closed for after a remote connection was disconnected.

FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR

public static final ConfigOption<Double> FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR

FORK_JOIN_EXECUTOR_PARALLELISM_MIN

public static final ConfigOption<Integer> FORK_JOIN_EXECUTOR_PARALLELISM_MIN

FORK_JOIN_EXECUTOR_PARALLELISM_MAX

public static final ConfigOption<Integer> FORK_JOIN_EXECUTOR_PARALLELISM_MAX

CLIENT_SOCKET_WORKER_POOL_SIZE_MIN

public static final ConfigOption<Integer> CLIENT_SOCKET_WORKER_POOL_SIZE_MIN

CLIENT_SOCKET_WORKER_POOL_SIZE_MAX

public static final ConfigOption<Integer> CLIENT_SOCKET_WORKER_POOL_SIZE_MAX

CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR

public static final ConfigOption<Double> CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR

SERVER_SOCKET_WORKER_POOL_SIZE_MIN

public static final ConfigOption<Integer> SERVER_SOCKET_WORKER_POOL_SIZE_MIN

SERVER_SOCKET_WORKER_POOL_SIZE_MAX

public static final ConfigOption<Integer> SERVER_SOCKET_WORKER_POOL_SIZE_MAX

SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR

public static final ConfigOption<Double> SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR

Constructor Detail

AkkaOptions

public AkkaOptions()