Package 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.

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ExecutionConfigOptions.AsyncOutputMode	Output mode for asynchronous operations, equivalent to .
static enum	ExecutionConfigOptions.LegacyCastBehaviour	Deprecated.
static enum	ExecutionConfigOptions.NestedEnforcer	The enforcer to check the constraints on nested types.
static enum	ExecutionConfigOptions.NotNullEnforcer	The enforcer to guarantee NOT NULL column constraint when writing data into sink.
static enum	ExecutionConfigOptions.RetryStrategy	Retry strategy in the case of failure.
static enum	ExecutionConfigOptions.RowtimeInserter	Rowtime attribute insertion strategy for the sink.
static enum	ExecutionConfigOptions.SinkKeyedShuffle	Shuffle by primary key before sink.
static enum	ExecutionConfigOptions.SinkUpsertMaterializeStrategy	SinkUpsertMaterializer strategy.
static enum	ExecutionConfigOptions.TypeLengthEnforcer	The enforcer to guarantee that length of CHAR/VARCHAR/BINARY/VARBINARY columns is respected when writing data into a sink.
static enum	ExecutionConfigOptions.UidGeneration	Strategy for generating transformation UIDs for remapping state to operators during restore.
static enum	ExecutionConfigOptions.UpsertMaterialize	Upsert materialize strategy before sink.

Field Summary

Fields

Modifier and Type	Field	Description
static final ConfigOption<Duration>	IDLE_STATE_RETENTION
static final ConfigOption<Integer>	TABLE_EXEC_ASYNC_LOOKUP_BUFFER_CAPACITY
static final ConfigOption<Boolean>	TABLE_EXEC_ASYNC_LOOKUP_KEY_ORDERED
static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode>	TABLE_EXEC_ASYNC_LOOKUP_OUTPUT_MODE
static final ConfigOption<Duration>	TABLE_EXEC_ASYNC_LOOKUP_TIMEOUT
static final ConfigOption<Integer>	TABLE_EXEC_ASYNC_ML_PREDICT_MAX_CONCURRENT_OPERATIONS
static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode>	TABLE_EXEC_ASYNC_ML_PREDICT_OUTPUT_MODE
static final ConfigOption<Duration>	TABLE_EXEC_ASYNC_ML_PREDICT_TIMEOUT
static final ConfigOption<Integer>	TABLE_EXEC_ASYNC_SCALAR_MAX_ATTEMPTS
static final ConfigOption<Integer>	TABLE_EXEC_ASYNC_SCALAR_MAX_CONCURRENT_OPERATIONS
static final ConfigOption<Duration>	TABLE_EXEC_ASYNC_SCALAR_RETRY_DELAY
static final ConfigOption<ExecutionConfigOptions.RetryStrategy>	TABLE_EXEC_ASYNC_SCALAR_RETRY_STRATEGY
static final ConfigOption<Duration>	TABLE_EXEC_ASYNC_SCALAR_TIMEOUT
static final ConfigOption<Boolean>	TABLE_EXEC_ASYNC_STATE_ENABLED
static final ConfigOption<Integer>	TABLE_EXEC_ASYNC_TABLE_MAX_CONCURRENT_OPERATIONS
static final ConfigOption<Integer>	TABLE_EXEC_ASYNC_TABLE_MAX_RETRIES
static final ConfigOption<Duration>	TABLE_EXEC_ASYNC_TABLE_RETRY_DELAY
static final ConfigOption<ExecutionConfigOptions.RetryStrategy>	TABLE_EXEC_ASYNC_TABLE_RETRY_STRATEGY
static final ConfigOption<Duration>	TABLE_EXEC_ASYNC_TABLE_TIMEOUT
static final ConfigOption<Integer>	TABLE_EXEC_ASYNC_VECTOR_SEARCH_MAX_CONCURRENT_OPERATIONS
static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode>	TABLE_EXEC_ASYNC_VECTOR_SEARCH_OUTPUT_MODE
static final ConfigOption<Duration>	TABLE_EXEC_ASYNC_VECTOR_SEARCH_TIMEOUT
static final ConfigOption<Boolean>	TABLE_EXEC_DEDUPLICATE_INSERT_UPDATE_AFTER_SENSITIVE_ENABLED
static final ConfigOption<Boolean>	TABLE_EXEC_DEDUPLICATE_MINIBATCH_COMPACT_CHANGES_ENABLED
static final ConfigOption<Boolean>	TABLE_EXEC_DELTA_JOIN_CACHE_ENABLED
static final ConfigOption<Long>	TABLE_EXEC_DELTA_JOIN_LEFT_CACHE_SIZE
static final ConfigOption<Long>	TABLE_EXEC_DELTA_JOIN_RIGHT_CACHE_SIZE
static final ConfigOption<String>	TABLE_EXEC_DISABLED_OPERATORS
static final ConfigOption<Duration>	TABLE_EXEC_INTERVAL_JOIN_MIN_CLEAN_UP_INTERVAL
static final ConfigOption<ExecutionConfigOptions.LegacyCastBehaviour>	TABLE_EXEC_LEGACY_CAST_BEHAVIOUR
static final ConfigOption<Double>	TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_DISTINCT_VALUE_RATE_THRESHOLD
static final ConfigOption<Boolean>	TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_ENABLED
static final ConfigOption<Long>	TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_SAMPLING_THRESHOLD
static final ConfigOption<Duration>	TABLE_EXEC_MINIBATCH_ALLOW_LATENCY
static final ConfigOption<Boolean>	TABLE_EXEC_MINIBATCH_ENABLED
static final ConfigOption<Long>	TABLE_EXEC_MINIBATCH_SIZE
static final ConfigOption<Boolean>	TABLE_EXEC_OPERATOR_FUSION_CODEGEN_ENABLED
static final ConfigOption<Long>	TABLE_EXEC_RANK_TOPN_CACHE_SIZE
static final ConfigOption<Integer>	TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM
static final ConfigOption<MemorySize>	TABLE_EXEC_RESOURCE_EXTERNAL_BUFFER_MEMORY
static final ConfigOption<MemorySize>	TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY
static final ConfigOption<MemorySize>	TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY
static final ConfigOption<MemorySize>	TABLE_EXEC_RESOURCE_SORT_MEMORY
static final ConfigOption<Boolean>	TABLE_EXEC_SIMPLIFY_OPERATOR_NAME_ENABLED
static final ConfigOption<ExecutionConfigOptions.SinkKeyedShuffle>	TABLE_EXEC_SINK_KEYED_SHUFFLE
static final ConfigOption<ExecutionConfigOptions.NestedEnforcer>	TABLE_EXEC_SINK_NESTED_CONSTRAINT_ENFORCER
static final ConfigOption<ExecutionConfigOptions.NotNullEnforcer>	TABLE_EXEC_SINK_NOT_NULL_ENFORCER
static final ConfigOption<Boolean>	TABLE_EXEC_SINK_REQUIRE_ON_CONFLICT
static final ConfigOption<ExecutionConfigOptions.RowtimeInserter>	TABLE_EXEC_SINK_ROWTIME_INSERTER
static final ConfigOption<ExecutionConfigOptions.TypeLengthEnforcer>	TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER
static final ConfigOption<ExecutionConfigOptions.UpsertMaterialize>	TABLE_EXEC_SINK_UPSERT_MATERIALIZE
static final ConfigOption<Long>	TABLE_EXEC_SINK_UPSERT_MATERIALIZE_ADAPTIVE_THRESHOLD_HIGH
static final ConfigOption<Long>	TABLE_EXEC_SINK_UPSERT_MATERIALIZE_ADAPTIVE_THRESHOLD_LOW
static final ConfigOption<ExecutionConfigOptions.SinkUpsertMaterializeStrategy>	TABLE_EXEC_SINK_UPSERT_MATERIALIZE_STRATEGY
static final ConfigOption<Boolean>	TABLE_EXEC_SORT_ASYNC_MERGE_ENABLED
static final ConfigOption<Integer>	TABLE_EXEC_SORT_DEFAULT_LIMIT
static final ConfigOption<Integer>	TABLE_EXEC_SORT_MAX_NUM_FILE_HANDLES
static final ConfigOption<Boolean>	TABLE_EXEC_SOURCE_CDC_EVENTS_DUPLICATE
static final ConfigOption<Duration>	TABLE_EXEC_SOURCE_IDLE_TIMEOUT
static final ConfigOption<MemorySize>	TABLE_EXEC_SPILL_COMPRESSION_BLOCK_SIZE
static final ConfigOption<Boolean>	TABLE_EXEC_SPILL_COMPRESSION_ENABLED
static final ConfigOption<String>	TABLE_EXEC_UID_FORMAT
static final ConfigOption<ExecutionConfigOptions.UidGeneration>	TABLE_EXEC_UID_GENERATION
static final ConfigOption<Integer>	TABLE_EXEC_WINDOW_AGG_BUFFER_SIZE_LIMIT	See org.apache.flink.table.runtime.operators.window.grouping.HeapWindowsGrouping.
static final ConfigOption<Integer>	UNBOUNDED_OVER_VERSION

Constructor Summary

Constructors

Constructor	Description
ExecutionConfigOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

IDLE_STATE_RETENTION

public static final ConfigOption<Duration> IDLE_STATE_RETENTION

TABLE_EXEC_SOURCE_IDLE_TIMEOUT

public static final ConfigOption<Duration> TABLE_EXEC_SOURCE_IDLE_TIMEOUT

TABLE_EXEC_SOURCE_CDC_EVENTS_DUPLICATE

public static final ConfigOption<Boolean> TABLE_EXEC_SOURCE_CDC_EVENTS_DUPLICATE

TABLE_EXEC_SINK_NOT_NULL_ENFORCER

public static final ConfigOption<ExecutionConfigOptions.NotNullEnforcer> TABLE_EXEC_SINK_NOT_NULL_ENFORCER

TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER

public static final ConfigOption<ExecutionConfigOptions.TypeLengthEnforcer> TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER

TABLE_EXEC_SINK_NESTED_CONSTRAINT_ENFORCER

public static final ConfigOption<ExecutionConfigOptions.NestedEnforcer> TABLE_EXEC_SINK_NESTED_CONSTRAINT_ENFORCER

TABLE_EXEC_SINK_UPSERT_MATERIALIZE

public static final ConfigOption<ExecutionConfigOptions.UpsertMaterialize> TABLE_EXEC_SINK_UPSERT_MATERIALIZE

TABLE_EXEC_SINK_UPSERT_MATERIALIZE_ADAPTIVE_THRESHOLD_LOW

public static final ConfigOption<Long> TABLE_EXEC_SINK_UPSERT_MATERIALIZE_ADAPTIVE_THRESHOLD_LOW

TABLE_EXEC_SINK_UPSERT_MATERIALIZE_ADAPTIVE_THRESHOLD_HIGH

public static final ConfigOption<Long> TABLE_EXEC_SINK_UPSERT_MATERIALIZE_ADAPTIVE_THRESHOLD_HIGH

TABLE_EXEC_SINK_UPSERT_MATERIALIZE_STRATEGY

public static final ConfigOption<ExecutionConfigOptions.SinkUpsertMaterializeStrategy> TABLE_EXEC_SINK_UPSERT_MATERIALIZE_STRATEGY

TABLE_EXEC_SINK_KEYED_SHUFFLE

public static final ConfigOption<ExecutionConfigOptions.SinkKeyedShuffle> TABLE_EXEC_SINK_KEYED_SHUFFLE

TABLE_EXEC_SINK_ROWTIME_INSERTER

public static final ConfigOption<ExecutionConfigOptions.RowtimeInserter> TABLE_EXEC_SINK_ROWTIME_INSERTER

TABLE_EXEC_SINK_REQUIRE_ON_CONFLICT

public static final ConfigOption<Boolean> TABLE_EXEC_SINK_REQUIRE_ON_CONFLICT

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<MemorySize> 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<MemorySize> TABLE_EXEC_RESOURCE_EXTERNAL_BUFFER_MEMORY

TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY

public static final ConfigOption<MemorySize> TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY

TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY

public static final ConfigOption<MemorySize> TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY

TABLE_EXEC_RESOURCE_SORT_MEMORY

public static final ConfigOption<MemorySize> 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_LOCAL_HASH_AGG_ADAPTIVE_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_ENABLED

TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_SAMPLING_THRESHOLD

public static final ConfigOption<Long> TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_SAMPLING_THRESHOLD

TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_DISTINCT_VALUE_RATE_THRESHOLD

public static final ConfigOption<Double> TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_DISTINCT_VALUE_RATE_THRESHOLD

TABLE_EXEC_ASYNC_LOOKUP_KEY_ORDERED

public static final ConfigOption<Boolean> TABLE_EXEC_ASYNC_LOOKUP_KEY_ORDERED

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<Duration> TABLE_EXEC_ASYNC_LOOKUP_TIMEOUT

TABLE_EXEC_ASYNC_LOOKUP_OUTPUT_MODE

public static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode> TABLE_EXEC_ASYNC_LOOKUP_OUTPUT_MODE

TABLE_EXEC_ASYNC_SCALAR_MAX_CONCURRENT_OPERATIONS

public static final ConfigOption<Integer> TABLE_EXEC_ASYNC_SCALAR_MAX_CONCURRENT_OPERATIONS

TABLE_EXEC_ASYNC_SCALAR_TIMEOUT

public static final ConfigOption<Duration> TABLE_EXEC_ASYNC_SCALAR_TIMEOUT

TABLE_EXEC_ASYNC_SCALAR_RETRY_STRATEGY

public static final ConfigOption<ExecutionConfigOptions.RetryStrategy> TABLE_EXEC_ASYNC_SCALAR_RETRY_STRATEGY

TABLE_EXEC_ASYNC_SCALAR_RETRY_DELAY

public static final ConfigOption<Duration> TABLE_EXEC_ASYNC_SCALAR_RETRY_DELAY

TABLE_EXEC_ASYNC_SCALAR_MAX_ATTEMPTS

public static final ConfigOption<Integer> TABLE_EXEC_ASYNC_SCALAR_MAX_ATTEMPTS

TABLE_EXEC_ASYNC_TABLE_MAX_CONCURRENT_OPERATIONS

public static final ConfigOption<Integer> TABLE_EXEC_ASYNC_TABLE_MAX_CONCURRENT_OPERATIONS

TABLE_EXEC_ASYNC_TABLE_TIMEOUT

public static final ConfigOption<Duration> TABLE_EXEC_ASYNC_TABLE_TIMEOUT

TABLE_EXEC_ASYNC_TABLE_RETRY_STRATEGY

public static final ConfigOption<ExecutionConfigOptions.RetryStrategy> TABLE_EXEC_ASYNC_TABLE_RETRY_STRATEGY

TABLE_EXEC_ASYNC_TABLE_RETRY_DELAY

public static final ConfigOption<Duration> TABLE_EXEC_ASYNC_TABLE_RETRY_DELAY

TABLE_EXEC_ASYNC_TABLE_MAX_RETRIES

public static final ConfigOption<Integer> TABLE_EXEC_ASYNC_TABLE_MAX_RETRIES

TABLE_EXEC_ASYNC_ML_PREDICT_MAX_CONCURRENT_OPERATIONS

public static final ConfigOption<Integer> TABLE_EXEC_ASYNC_ML_PREDICT_MAX_CONCURRENT_OPERATIONS

TABLE_EXEC_ASYNC_ML_PREDICT_TIMEOUT

public static final ConfigOption<Duration> TABLE_EXEC_ASYNC_ML_PREDICT_TIMEOUT

TABLE_EXEC_ASYNC_ML_PREDICT_OUTPUT_MODE

public static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode> TABLE_EXEC_ASYNC_ML_PREDICT_OUTPUT_MODE

TABLE_EXEC_ASYNC_VECTOR_SEARCH_MAX_CONCURRENT_OPERATIONS

public static final ConfigOption<Integer> TABLE_EXEC_ASYNC_VECTOR_SEARCH_MAX_CONCURRENT_OPERATIONS

TABLE_EXEC_ASYNC_VECTOR_SEARCH_TIMEOUT

public static final ConfigOption<Duration> TABLE_EXEC_ASYNC_VECTOR_SEARCH_TIMEOUT

TABLE_EXEC_ASYNC_VECTOR_SEARCH_OUTPUT_MODE

public static final ConfigOption<ExecutionConfigOptions.AsyncOutputMode> TABLE_EXEC_ASYNC_VECTOR_SEARCH_OUTPUT_MODE

TABLE_EXEC_MINIBATCH_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_MINIBATCH_ENABLED

TABLE_EXEC_MINIBATCH_ALLOW_LATENCY

public static final ConfigOption<Duration> 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_OPERATOR_FUSION_CODEGEN_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_OPERATOR_FUSION_CODEGEN_ENABLED

TABLE_EXEC_LEGACY_CAST_BEHAVIOUR

public static final ConfigOption<ExecutionConfigOptions.LegacyCastBehaviour> TABLE_EXEC_LEGACY_CAST_BEHAVIOUR

TABLE_EXEC_RANK_TOPN_CACHE_SIZE

public static final ConfigOption<Long> TABLE_EXEC_RANK_TOPN_CACHE_SIZE

TABLE_EXEC_SIMPLIFY_OPERATOR_NAME_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_SIMPLIFY_OPERATOR_NAME_ENABLED

TABLE_EXEC_DEDUPLICATE_INSERT_UPDATE_AFTER_SENSITIVE_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_DEDUPLICATE_INSERT_UPDATE_AFTER_SENSITIVE_ENABLED

TABLE_EXEC_DEDUPLICATE_MINIBATCH_COMPACT_CHANGES_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_DEDUPLICATE_MINIBATCH_COMPACT_CHANGES_ENABLED

UNBOUNDED_OVER_VERSION

public static final ConfigOption<Integer> UNBOUNDED_OVER_VERSION

TABLE_EXEC_UID_GENERATION

public static final ConfigOption<ExecutionConfigOptions.UidGeneration> TABLE_EXEC_UID_GENERATION

TABLE_EXEC_UID_FORMAT

public static final ConfigOption<String> TABLE_EXEC_UID_FORMAT

TABLE_EXEC_INTERVAL_JOIN_MIN_CLEAN_UP_INTERVAL

public static final ConfigOption<Duration> TABLE_EXEC_INTERVAL_JOIN_MIN_CLEAN_UP_INTERVAL

TABLE_EXEC_ASYNC_STATE_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_ASYNC_STATE_ENABLED

TABLE_EXEC_DELTA_JOIN_CACHE_ENABLED

public static final ConfigOption<Boolean> TABLE_EXEC_DELTA_JOIN_CACHE_ENABLED

TABLE_EXEC_DELTA_JOIN_LEFT_CACHE_SIZE

public static final ConfigOption<Long> TABLE_EXEC_DELTA_JOIN_LEFT_CACHE_SIZE

TABLE_EXEC_DELTA_JOIN_RIGHT_CACHE_SIZE

public static final ConfigOption<Long> TABLE_EXEC_DELTA_JOIN_RIGHT_CACHE_SIZE

Constructor Details

ExecutionConfigOptions

public ExecutionConfigOptions()