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 and Description
static class	ExecutionConfigOptions.AsyncOutputMode Output mode for asynchronous operations, equivalent to AsyncDataStream.OutputMode.
static class	ExecutionConfigOptions.LegacyCastBehaviour Deprecated.
static class	ExecutionConfigOptions.NotNullEnforcer The enforcer to guarantee NOT NULL column constraint when writing data into sink.
static class	ExecutionConfigOptions.RetryStrategy Retry strategy in the case of failure.
static class	ExecutionConfigOptions.RowtimeInserter Rowtime attribute insertion strategy for the sink.
static class	ExecutionConfigOptions.SinkKeyedShuffle Shuffle by primary key before sink.
static class	ExecutionConfigOptions.TypeLengthEnforcer The enforcer to guarantee that length of CHAR/VARCHAR/BINARY/VARBINARY columns is respected when writing data into a sink.
static class	ExecutionConfigOptions.UidGeneration Strategy for generating transformation UIDs for remapping state to operators during restore.
static class	ExecutionConfigOptions.UpsertMaterialize Upsert materialize strategy before sink.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Duration>	IDLE_STATE_RETENTION
static ConfigOption<Integer>	TABLE_EXEC_ASYNC_LOOKUP_BUFFER_CAPACITY
static ConfigOption<ExecutionConfigOptions.AsyncOutputMode>	TABLE_EXEC_ASYNC_LOOKUP_OUTPUT_MODE
static ConfigOption<Duration>	TABLE_EXEC_ASYNC_LOOKUP_TIMEOUT
static ConfigOption<Integer>	TABLE_EXEC_ASYNC_SCALAR_BUFFER_CAPACITY
static ConfigOption<Integer>	TABLE_EXEC_ASYNC_SCALAR_MAX_ATTEMPTS
static ConfigOption<Duration>	TABLE_EXEC_ASYNC_SCALAR_RETRY_DELAY
static ConfigOption<ExecutionConfigOptions.RetryStrategy>	TABLE_EXEC_ASYNC_SCALAR_RETRY_STRATEGY
static ConfigOption<Duration>	TABLE_EXEC_ASYNC_SCALAR_TIMEOUT
static ConfigOption<Boolean>	TABLE_EXEC_DEDUPLICATE_INSERT_UPDATE_AFTER_SENSITIVE_ENABLED
static ConfigOption<Boolean>	TABLE_EXEC_DEDUPLICATE_MINIBATCH_COMPACT_CHANGES_ENABLED
static ConfigOption<String>	TABLE_EXEC_DISABLED_OPERATORS
static ConfigOption<Duration>	TABLE_EXEC_INTERVAL_JOIN_MIN_CLEAN_UP_INTERVAL
static ConfigOption<ExecutionConfigOptions.LegacyCastBehaviour>	TABLE_EXEC_LEGACY_CAST_BEHAVIOUR
static ConfigOption<Boolean>	TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS Deprecated. Use TABLE_EXEC_UID_GENERATION instead.
static ConfigOption<Double>	TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_DISTINCT_VALUE_RATE_THRESHOLD
static ConfigOption<Boolean>	TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_ENABLED
static ConfigOption<Long>	TABLE_EXEC_LOCAL_HASH_AGG_ADAPTIVE_SAMPLING_THRESHOLD
static ConfigOption<Duration>	TABLE_EXEC_MINIBATCH_ALLOW_LATENCY
static ConfigOption<Boolean>	TABLE_EXEC_MINIBATCH_ENABLED
static ConfigOption<Long>	TABLE_EXEC_MINIBATCH_SIZE
static ConfigOption<Boolean>	TABLE_EXEC_OPERATOR_FUSION_CODEGEN_ENABLED
static ConfigOption<Long>	TABLE_EXEC_RANK_TOPN_CACHE_SIZE
static ConfigOption<Integer>	TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM
static ConfigOption<MemorySize>	TABLE_EXEC_RESOURCE_EXTERNAL_BUFFER_MEMORY
static ConfigOption<MemorySize>	TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY
static ConfigOption<MemorySize>	TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY
static ConfigOption<MemorySize>	TABLE_EXEC_RESOURCE_SORT_MEMORY
static ConfigOption<String>	TABLE_EXEC_SHUFFLE_MODE Deprecated. Use ExecutionOptions.BATCH_SHUFFLE_MODE instead.
static ConfigOption<Boolean>	TABLE_EXEC_SIMPLIFY_OPERATOR_NAME_ENABLED
static ConfigOption<ExecutionConfigOptions.SinkKeyedShuffle>	TABLE_EXEC_SINK_KEYED_SHUFFLE
static ConfigOption<ExecutionConfigOptions.NotNullEnforcer>	TABLE_EXEC_SINK_NOT_NULL_ENFORCER
static ConfigOption<ExecutionConfigOptions.RowtimeInserter>	TABLE_EXEC_SINK_ROWTIME_INSERTER
static ConfigOption<ExecutionConfigOptions.TypeLengthEnforcer>	TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER
static ConfigOption<ExecutionConfigOptions.UpsertMaterialize>	TABLE_EXEC_SINK_UPSERT_MATERIALIZE
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<Boolean>	TABLE_EXEC_SOURCE_CDC_EVENTS_DUPLICATE
static ConfigOption<Duration>	TABLE_EXEC_SOURCE_IDLE_TIMEOUT
static ConfigOption<MemorySize>	TABLE_EXEC_SPILL_COMPRESSION_BLOCK_SIZE
static ConfigOption<Boolean>	TABLE_EXEC_SPILL_COMPRESSION_ENABLED
static ConfigOption<String>	TABLE_EXEC_UID_FORMAT
static ConfigOption<ExecutionConfigOptions.UidGeneration>	TABLE_EXEC_UID_GENERATION
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

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_UPSERT_MATERIALIZE

public static final ConfigOption<ExecutionConfigOptions.UpsertMaterialize> TABLE_EXEC_SINK_UPSERT_MATERIALIZE

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_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_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_BUFFER_CAPACITY

public static final ConfigOption<Integer> TABLE_EXEC_ASYNC_SCALAR_BUFFER_CAPACITY

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_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_SHUFFLE_MODE

@Deprecated
public static final ConfigOption<String> TABLE_EXEC_SHUFFLE_MODE

Deprecated. Use ExecutionOptions.BATCH_SHUFFLE_MODE instead.

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

TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS

@Deprecated
public static final ConfigOption<Boolean> TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS

Deprecated. Use TABLE_EXEC_UID_GENERATION instead.

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

Constructor Detail

ExecutionConfigOptions

public ExecutionConfigOptions()