org.apache.flink.table.api.config

Class ExecutionConfigOptions

java.lang.Object

org.apache.flink.table.api.config.ExecutionConfigOptions

@PublicEvolving
public class ExecutionConfigOptions
extends Object

This class holds configuration constants used by Flink's table module.

This is only used for the Blink planner.

NOTE: All option keys in this class must start with "table.exec".

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExecutionConfigOptions.NotNullEnforcer The enforcer to guarantee NOT NULL column constraint when writing data into sink.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Integer>	TABLE_EXEC_ASYNC_LOOKUP_BUFFER_CAPACITY
static ConfigOption<String>	TABLE_EXEC_ASYNC_LOOKUP_TIMEOUT
static ConfigOption<String>	TABLE_EXEC_DISABLED_OPERATORS
static ConfigOption<String>	TABLE_EXEC_MINIBATCH_ALLOW_LATENCY
static ConfigOption<Boolean>	TABLE_EXEC_MINIBATCH_ENABLED
static ConfigOption<Long>	TABLE_EXEC_MINIBATCH_SIZE
static ConfigOption<Integer>	TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM
static ConfigOption<String>	TABLE_EXEC_RESOURCE_EXTERNAL_BUFFER_MEMORY
static ConfigOption<String>	TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY
static ConfigOption<String>	TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY
static ConfigOption<String>	TABLE_EXEC_RESOURCE_SORT_MEMORY
static ConfigOption<String>	TABLE_EXEC_SHUFFLE_MODE
static ConfigOption<ExecutionConfigOptions.NotNullEnforcer>	TABLE_EXEC_SINK_NOT_NULL_ENFORCER
static ConfigOption<Boolean>	TABLE_EXEC_SORT_ASYNC_MERGE_ENABLED
static ConfigOption<Integer>	TABLE_EXEC_SORT_DEFAULT_LIMIT
static ConfigOption<Integer>	TABLE_EXEC_SORT_MAX_NUM_FILE_HANDLES
static ConfigOption<String>	TABLE_EXEC_SOURCE_IDLE_TIMEOUT
static ConfigOption<String>	TABLE_EXEC_SPILL_COMPRESSION_BLOCK_SIZE
static ConfigOption<Boolean>	TABLE_EXEC_SPILL_COMPRESSION_ENABLED
static ConfigOption<Integer>	TABLE_EXEC_WINDOW_AGG_BUFFER_SIZE_LIMIT See org.apache.flink.table.runtime.operators.window.grouping.HeapWindowsGrouping.

Constructor Summary

Constructors

Constructor and Description
ExecutionConfigOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

TABLE_EXEC_SOURCE_IDLE_TIMEOUT

public static final ConfigOption<String> TABLE_EXEC_SOURCE_IDLE_TIMEOUT

TABLE_EXEC_SINK_NOT_NULL_ENFORCER

public static final ConfigOption<ExecutionConfigOptions.NotNullEnforcer> TABLE_EXEC_SINK_NOT_NULL_ENFORCER

TABLE_EXEC_SORT_DEFAULT_LIMIT

public static final ConfigOption<Integer> TABLE_EXEC_SORT_DEFAULT_LIMIT

TABLE_EXEC_SORT_MAX_NUM_FILE_HANDLES

public static final ConfigOption<Integer> TABLE_EXEC_SORT_MAX_NUM_FILE_HANDLES

TABLE_EXEC_SORT_ASYNC_MERGE_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_SORT_ASYNC_MERGE_ENABLED

TABLE_EXEC_SPILL_COMPRESSION_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_SPILL_COMPRESSION_ENABLED

TABLE_EXEC_SPILL_COMPRESSION_BLOCK_SIZE

public static final ConfigOption<String> TABLE_EXEC_SPILL_COMPRESSION_BLOCK_SIZE

TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM

public static final ConfigOption<Integer> TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM

TABLE_EXEC_RESOURCE_EXTERNAL_BUFFER_MEMORY

public static final ConfigOption<String> TABLE_EXEC_RESOURCE_EXTERNAL_BUFFER_MEMORY

TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY

public static final ConfigOption<String> TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY

TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY

public static final ConfigOption<String> TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY

TABLE_EXEC_RESOURCE_SORT_MEMORY

public static final ConfigOption<String> TABLE_EXEC_RESOURCE_SORT_MEMORY

TABLE_EXEC_WINDOW_AGG_BUFFER_SIZE_LIMIT

public static final ConfigOption<Integer> TABLE_EXEC_WINDOW_AGG_BUFFER_SIZE_LIMIT

See org.apache.flink.table.runtime.operators.window.grouping.HeapWindowsGrouping.

TABLE_EXEC_ASYNC_LOOKUP_BUFFER_CAPACITY

public static final ConfigOption<Integer> TABLE_EXEC_ASYNC_LOOKUP_BUFFER_CAPACITY

TABLE_EXEC_ASYNC_LOOKUP_TIMEOUT

public static final ConfigOption<String> TABLE_EXEC_ASYNC_LOOKUP_TIMEOUT

TABLE_EXEC_MINIBATCH_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_MINIBATCH_ENABLED

TABLE_EXEC_MINIBATCH_ALLOW_LATENCY

public static final ConfigOption<String> TABLE_EXEC_MINIBATCH_ALLOW_LATENCY

TABLE_EXEC_MINIBATCH_SIZE

public static final ConfigOption<Long> TABLE_EXEC_MINIBATCH_SIZE

TABLE_EXEC_DISABLED_OPERATORS

public static final ConfigOption<String> TABLE_EXEC_DISABLED_OPERATORS

TABLE_EXEC_SHUFFLE_MODE

public static final ConfigOption<String> TABLE_EXEC_SHUFFLE_MODE

Constructor Detail

ExecutionConfigOptions

public ExecutionConfigOptions()