org.apache.flink.table.planner.plan.optimize.program

Class FlinkRecomputeStatisticsProgram

java.lang.Object

org.apache.flink.table.planner.plan.optimize.program.FlinkRecomputeStatisticsProgram

All Implemented Interfaces:

org.apache.flink.table.planner.plan.optimize.program.FlinkOptimizeProgram<org.apache.flink.table.planner.plan.optimize.program.BatchOptimizeContext>

public class FlinkRecomputeStatisticsProgram
extends Object
implements org.apache.flink.table.planner.plan.optimize.program.FlinkOptimizeProgram<org.apache.flink.table.planner.plan.optimize.program.BatchOptimizeContext>

A FlinkOptimizeProgram that recompute statistics after partition pruning and filter push down.

It's a very heavy operation to get statistics from catalogs or connectors, so this centralized way can avoid getting statistics again and again.

Constructor Summary

Constructors

Constructor and Description
FlinkRecomputeStatisticsProgram()

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.rel.RelNode	optimize(org.apache.calcite.rel.RelNode root, org.apache.flink.table.planner.plan.optimize.program.BatchOptimizeContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkRecomputeStatisticsProgram

public FlinkRecomputeStatisticsProgram()

Method Detail

optimize

public org.apache.calcite.rel.RelNode optimize(org.apache.calcite.rel.RelNode root,
                                               org.apache.flink.table.planner.plan.optimize.program.BatchOptimizeContext context)

Specified by:

optimize in interface org.apache.flink.table.planner.plan.optimize.program.FlinkOptimizeProgram<org.apache.flink.table.planner.plan.optimize.program.BatchOptimizeContext>