org.apache.flink.configuration

Class ExecutionOptions

java.lang.Object

org.apache.flink.configuration.ExecutionOptions

@PublicEvolving
public class ExecutionOptions
extends Object

ConfigOptions specific for a single execution of a user program.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<BatchShuffleMode>	BATCH_SHUFFLE_MODE
static ConfigOption<java.time.Duration>	BUFFER_TIMEOUT
static ConfigOption<Boolean>	BUFFER_TIMEOUT_ENABLED
static long	DISABLED_NETWORK_BUFFER_TIMEOUT A special marker value for disabling buffer timeout.
static long	FLUSH_AFTER_EVERY_RECORD A special marker value for flushing network buffers after each record.
static ConfigOption<RuntimeExecutionMode>	RUNTIME_MODE
static ConfigOption<Boolean>	SNAPSHOT_COMPRESSION Should be moved to ExecutionCheckpointingOptions along with ExecutionConfig#useSnapshotCompression, which should be put into CheckpointConfig.
static ConfigOption<Boolean>	SORT_INPUTS
static ConfigOption<MemorySize>	SORTED_INPUTS_MEMORY
static ConfigOption<Boolean>	USE_BATCH_STATE_BACKEND

Constructor Summary

Constructors

Constructor and Description
ExecutionOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

DISABLED_NETWORK_BUFFER_TIMEOUT

public static final long DISABLED_NETWORK_BUFFER_TIMEOUT

A special marker value for disabling buffer timeout.

See Also:

Constant Field Values

FLUSH_AFTER_EVERY_RECORD

public static final long FLUSH_AFTER_EVERY_RECORD

A special marker value for flushing network buffers after each record.

See Also:

Constant Field Values

RUNTIME_MODE

public static final ConfigOption<RuntimeExecutionMode> RUNTIME_MODE

BATCH_SHUFFLE_MODE

public static final ConfigOption<BatchShuffleMode> BATCH_SHUFFLE_MODE

SNAPSHOT_COMPRESSION

public static final ConfigOption<Boolean> SNAPSHOT_COMPRESSION

Should be moved to ExecutionCheckpointingOptions along with ExecutionConfig#useSnapshotCompression, which should be put into CheckpointConfig.

BUFFER_TIMEOUT_ENABLED

public static final ConfigOption<Boolean> BUFFER_TIMEOUT_ENABLED

BUFFER_TIMEOUT

public static final ConfigOption<java.time.Duration> BUFFER_TIMEOUT

SORT_INPUTS

public static final ConfigOption<Boolean> SORT_INPUTS

SORTED_INPUTS_MEMORY

public static final ConfigOption<MemorySize> SORTED_INPUTS_MEMORY

USE_BATCH_STATE_BACKEND

public static final ConfigOption<Boolean> USE_BATCH_STATE_BACKEND

Constructor Detail

ExecutionOptions

public ExecutionOptions()