| Class | Description |
|---|---|
| FlinkDynamicPartitionPruningProgram |
Planner program that tries to do partition prune in the execution phase, which can translate a
BatchPhysicalTableSourceScan to a BatchPhysicalDynamicFilteringTableSourceScan
whose source is a partition source. |
| FlinkRecomputeStatisticsProgram |
A FlinkOptimizeProgram that recompute statistics after partition pruning and filter push down.
|
| FlinkRuntimeFilterProgram |
Planner program that tries to inject runtime filter for suitable join to improve join
performance.
|
Copyright © 2014–2025 The Apache Software Foundation. All rights reserved.