Package org.apache.flink.table.api.config

Class OptimizerConfigOptions

java.lang.Object

org.apache.flink.table.api.config.OptimizerConfigOptions

@PublicEvolving
public class OptimizerConfigOptions
extends Object

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	OptimizerConfigOptions.AdaptiveBroadcastJoinStrategy	Strategies used for TABLE_OPTIMIZER_ADAPTIVE_BROADCAST_JOIN_STRATEGY.
static enum	OptimizerConfigOptions.AdaptiveSkewedJoinOptimizationStrategy	Strategies used for TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_STRATEGY.
static enum	OptimizerConfigOptions.DeltaJoinStrategy	Strategy for delta join.
static enum	OptimizerConfigOptions.NonDeterministicUpdateStrategy	Strategy for handling non-deterministic updates.

Field Summary

Fields

Modifier and Type	Field	Description
static final ConfigOption<OptimizerConfigOptions.AdaptiveBroadcastJoinStrategy>	TABLE_OPTIMIZER_ADAPTIVE_BROADCAST_JOIN_STRATEGY
static final ConfigOption<Double>	TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_SKEWED_FACTOR
static final ConfigOption<MemorySize>	TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_SKEWED_THRESHOLD
static final ConfigOption<OptimizerConfigOptions.AdaptiveSkewedJoinOptimizationStrategy>	TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_STRATEGY
static final ConfigOption<AggregatePhaseStrategy>	TABLE_OPTIMIZER_AGG_PHASE_STRATEGY
static final ConfigOption<Long>	TABLE_OPTIMIZER_BROADCAST_JOIN_THRESHOLD
static final ConfigOption<Integer>	TABLE_OPTIMIZER_BUSHY_JOIN_REORDER_THRESHOLD
static final ConfigOption<OptimizerConfigOptions.DeltaJoinStrategy>	TABLE_OPTIMIZER_DELTA_JOIN_STRATEGY
static final ConfigOption<Integer>	TABLE_OPTIMIZER_DISTINCT_AGG_SPLIT_BUCKET_NUM
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_DISTINCT_AGG_SPLIT_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_DYNAMIC_FILTERING_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_INCREMENTAL_AGG_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_JOIN_REORDER_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_MULTI_JOIN_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_MULTIPLE_INPUT_ENABLED
static final ConfigOption<OptimizerConfigOptions.NonDeterministicUpdateStrategy>	TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY
static final ConfigOption<Integer>	TABLE_OPTIMIZER_PTF_MAX_TABLES
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_REUSE_OPTIMIZE_BLOCK_WITH_DIGEST_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_REUSE_SINK_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_REUSE_SUB_PLAN_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_RUNTIME_FILTER_ENABLED
static final ConfigOption<MemorySize>	TABLE_OPTIMIZER_RUNTIME_FILTER_MAX_BUILD_DATA_SIZE	The data volume of build side needs to be under this value.
static final ConfigOption<Double>	TABLE_OPTIMIZER_RUNTIME_FILTER_MIN_FILTER_RATIO	The filtering ratio of runtime filter needs to be over this value.
static final ConfigOption<MemorySize>	TABLE_OPTIMIZER_RUNTIME_FILTER_MIN_PROBE_DATA_SIZE	The data volume of probe side needs to be over this value.
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_SOURCE_REPORT_STATISTICS_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_SQL2REL_PROJECT_MERGE_ENABLED
static final ConfigOption<Boolean>	TABLE_OPTIMIZER_UNIONALL_AS_BREAKPOINT_ENABLED

Constructor Summary

Constructors

Constructor	Description
OptimizerConfigOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

TABLE_OPTIMIZER_AGG_PHASE_STRATEGY

public static final ConfigOption<AggregatePhaseStrategy> TABLE_OPTIMIZER_AGG_PHASE_STRATEGY

TABLE_OPTIMIZER_BROADCAST_JOIN_THRESHOLD

public static final ConfigOption<Long> TABLE_OPTIMIZER_BROADCAST_JOIN_THRESHOLD

TABLE_OPTIMIZER_DISTINCT_AGG_SPLIT_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_DISTINCT_AGG_SPLIT_ENABLED

TABLE_OPTIMIZER_DISTINCT_AGG_SPLIT_BUCKET_NUM

public static final ConfigOption<Integer> TABLE_OPTIMIZER_DISTINCT_AGG_SPLIT_BUCKET_NUM

TABLE_OPTIMIZER_REUSE_SUB_PLAN_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_REUSE_SUB_PLAN_ENABLED

TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED

TABLE_OPTIMIZER_REUSE_SINK_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_REUSE_SINK_ENABLED

TABLE_OPTIMIZER_SOURCE_REPORT_STATISTICS_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_SOURCE_REPORT_STATISTICS_ENABLED

TABLE_OPTIMIZER_JOIN_REORDER_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_JOIN_REORDER_ENABLED

TABLE_OPTIMIZER_BUSHY_JOIN_REORDER_THRESHOLD

public static final ConfigOption<Integer> TABLE_OPTIMIZER_BUSHY_JOIN_REORDER_THRESHOLD

TABLE_OPTIMIZER_MULTIPLE_INPUT_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_MULTIPLE_INPUT_ENABLED

TABLE_OPTIMIZER_DYNAMIC_FILTERING_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_DYNAMIC_FILTERING_ENABLED

TABLE_OPTIMIZER_RUNTIME_FILTER_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_RUNTIME_FILTER_ENABLED

TABLE_OPTIMIZER_ADAPTIVE_BROADCAST_JOIN_STRATEGY

public static final ConfigOption<OptimizerConfigOptions.AdaptiveBroadcastJoinStrategy> TABLE_OPTIMIZER_ADAPTIVE_BROADCAST_JOIN_STRATEGY

TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_STRATEGY

public static final ConfigOption<OptimizerConfigOptions.AdaptiveSkewedJoinOptimizationStrategy> TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_STRATEGY

TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_SKEWED_FACTOR

public static final ConfigOption<Double> TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_SKEWED_FACTOR

TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_SKEWED_THRESHOLD

public static final ConfigOption<MemorySize> TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_SKEWED_THRESHOLD

TABLE_OPTIMIZER_RUNTIME_FILTER_MAX_BUILD_DATA_SIZE

public static final ConfigOption<MemorySize> TABLE_OPTIMIZER_RUNTIME_FILTER_MAX_BUILD_DATA_SIZE

The data volume of build side needs to be under this value. If the data volume of build side is too large, the building overhead will be too large, which may lead to a negative impact on job performance.

TABLE_OPTIMIZER_RUNTIME_FILTER_MIN_PROBE_DATA_SIZE

public static final ConfigOption<MemorySize> TABLE_OPTIMIZER_RUNTIME_FILTER_MIN_PROBE_DATA_SIZE

The data volume of probe side needs to be over this value. If the data volume on the probe side is too small, the overhead of building runtime filter is not worth it.

TABLE_OPTIMIZER_RUNTIME_FILTER_MIN_FILTER_RATIO

public static final ConfigOption<Double> TABLE_OPTIMIZER_RUNTIME_FILTER_MIN_FILTER_RATIO

The filtering ratio of runtime filter needs to be over this value. A low filter rate is not worth it to build runtime filter.

TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY

public static final ConfigOption<OptimizerConfigOptions.NonDeterministicUpdateStrategy> TABLE_OPTIMIZER_NONDETERMINISTIC_UPDATE_STRATEGY

TABLE_OPTIMIZER_SQL2REL_PROJECT_MERGE_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_SQL2REL_PROJECT_MERGE_ENABLED

TABLE_OPTIMIZER_UNIONALL_AS_BREAKPOINT_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_UNIONALL_AS_BREAKPOINT_ENABLED

TABLE_OPTIMIZER_REUSE_OPTIMIZE_BLOCK_WITH_DIGEST_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_REUSE_OPTIMIZE_BLOCK_WITH_DIGEST_ENABLED

TABLE_OPTIMIZER_MULTI_JOIN_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_MULTI_JOIN_ENABLED

TABLE_OPTIMIZER_INCREMENTAL_AGG_ENABLED

public static final ConfigOption<Boolean> TABLE_OPTIMIZER_INCREMENTAL_AGG_ENABLED

TABLE_OPTIMIZER_PTF_MAX_TABLES

public static final ConfigOption<Integer> TABLE_OPTIMIZER_PTF_MAX_TABLES

TABLE_OPTIMIZER_DELTA_JOIN_STRATEGY

public static final ConfigOption<OptimizerConfigOptions.DeltaJoinStrategy> TABLE_OPTIMIZER_DELTA_JOIN_STRATEGY

Constructor Details

OptimizerConfigOptions

public OptimizerConfigOptions()