Uses of Package
org.apache.flink.table.planner.plan.rules.logical

Packages that use org.apache.flink.table.planner.plan.rules.logical

Package	Description
org.apache.flink.table.planner.plan.rules.logical

Classes in org.apache.flink.table.planner.plan.rules.logical used by org.apache.flink.table.planner.plan.rules.logical

Class and Description
AsyncCalcSplitRule.AsyncCalcSplitOnePerCalcRule.State State object used to keep track of whether a match has been found yet.
CalcPythonCorrelateTransposeRule Rule will transpose the conditions after the Python correlate node if the join type is inner join.
EventTimeTemporalJoinRewriteRule.Config Configuration for EventTimeTemporalJoinRewriteRule.
FlinkAggregateExpandDistinctAggregatesRule Planner rule that expands distinct aggregates (such as COUNT(DISTINCT x)) from a Aggregate.
FlinkAggregateJoinTransposeRule Planner rule that pushes an Aggregate past a Join.
FlinkAggregateRemoveRule Planner rule that removes a Aggregate if its aggregate functions are SUM, MIN, MAX, AUXILIARY_GROUP with no filterArgs, and the underlying relational expression is already distinct.
FlinkBushyJoinReorderRule Flink bushy join reorder rule, which will convert MultiJoin to a bushy join tree.
FlinkBushyJoinReorderRule.Config Rule configuration.
FlinkFilterJoinRule Planner rule that pushes filters above and within a join node into the join node and/or its children nodes.
FlinkFilterJoinRule.Config Rule configuration.
FlinkFilterJoinRule.FlinkFilterIntoJoinRule Rule that tries to push filter expressions into a join condition and into the inputs of the join.
FlinkFilterJoinRule.FlinkFilterIntoJoinRule.FlinkFilterIntoJoinRuleConfig Rule configuration.
FlinkFilterJoinRule.FlinkJoinConditionPushRule Rule that pushes parts of the join condition to its inputs.
FlinkFilterJoinRule.FlinkJoinConditionPushRule.FlinkFilterJoinRuleConfig Rule configuration.
FlinkFilterJoinRule.Predicate Predicate that returns whether a filter is valid in the ON clause of a join for this particular kind of join.
FlinkJoinPushExpressionsRule Planner rule that pushes down expressions in "equal" join condition.
FlinkJoinReorderRule Flink join reorder rule, which can change the join order of input relNode tree.
FlinkJoinReorderRule.Config Rule configuration.
FlinkJoinToMultiJoinRule Flink Planner rule to flatten a tree of LogicalJoins into a single MultiJoin with N inputs.
FlinkJoinToMultiJoinRule.Config Rule configuration.
FlinkProjectJoinTransposeRule Planner rule that pushes a Project past a Join by splitting the projection into a projection on top of each child of the join.
FlinkSemiAntiJoinFilterTransposeRule Planner rule that pushes semi-join down in a tree past a Filter.
FlinkSemiAntiJoinJoinTransposeRule Planner rule that pushes a org.apache.calcite.rel.core.SemiJoin down in a tree past a Join in order to trigger other rules that will convert SemiJoins.
FlinkSemiAntiJoinProjectTransposeRule Planner rule that pushes a org.apache.calcite.rel.core.SemiJoin down in a tree past a Project.
ImmutableEventTimeTemporalJoinRewriteRule.Config Immutable implementation of EventTimeTemporalJoinRewriteRule.Config.
ImmutableEventTimeTemporalJoinRewriteRule.Config.Builder Builds instances of type Config.
ImmutableFlinkBushyJoinReorderRule.Config Immutable implementation of FlinkBushyJoinReorderRule.Config.
ImmutableFlinkBushyJoinReorderRule.Config.Builder Builds instances of type Config.
ImmutableFlinkFilterIntoJoinRuleConfig Immutable implementation of FlinkFilterJoinRule.FlinkFilterIntoJoinRule.FlinkFilterIntoJoinRuleConfig.
ImmutableFlinkFilterIntoJoinRuleConfig.Builder Builds instances of type ImmutableFlinkFilterIntoJoinRuleConfig.
ImmutableFlinkFilterJoinRuleConfig Immutable implementation of FlinkFilterJoinRule.FlinkJoinConditionPushRule.FlinkFilterJoinRuleConfig.
ImmutableFlinkFilterJoinRuleConfig.Builder Builds instances of type ImmutableFlinkFilterJoinRuleConfig.
ImmutableFlinkJoinReorderRule.Config Immutable implementation of FlinkJoinReorderRule.Config.
ImmutableFlinkJoinReorderRule.Config.Builder Builds instances of type Config.
ImmutableFlinkJoinToMultiJoinRule.Config Immutable implementation of FlinkJoinToMultiJoinRule.Config.
ImmutableFlinkJoinToMultiJoinRule.Config.Builder Builds instances of type Config.
ImmutableJoinTableFunctionScanToCorrelateRule.Config Immutable implementation of JoinTableFunctionScanToCorrelateRule.Config.
ImmutableJoinTableFunctionScanToCorrelateRule.Config.Builder Builds instances of type Config.
ImmutableProjectSnapshotTransposeRule.Config Immutable implementation of ProjectSnapshotTransposeRule.Config.
ImmutableProjectSnapshotTransposeRule.Config.Builder Builds instances of type Config.
ImmutablePushProjectIntoTableSourceScanRule.Config Immutable implementation of PushProjectIntoTableSourceScanRule.Config.
ImmutablePushProjectIntoTableSourceScanRule.Config.Builder Builds instances of type Config.
ImmutableRemoveUnreachableCoalesceArgumentsRule.Config Immutable implementation of RemoveUnreachableCoalesceArgumentsRule.Config.
ImmutableRemoveUnreachableCoalesceArgumentsRule.Config.Builder Builds instances of type Config.
ImmutableWrapJsonAggFunctionArgumentsRule.Config Immutable implementation of WrapJsonAggFunctionArgumentsRule.Config.
ImmutableWrapJsonAggFunctionArgumentsRule.Config.Builder Builds instances of type Config.
JoinTableFunctionScanToCorrelateRule Rule that rewrites Join on TableFunctionScan to Correlate.
JoinTableFunctionScanToCorrelateRule.Config Configuration for JoinTableFunctionScanToCorrelateRule.
ProjectSnapshotTransposeRule.Config Configuration for ProjectSnapshotTransposeRule.
ProjectWatermarkAssignerTransposeRule Transpose between the LogicalWatermarkAssigner and LogicalProject.
ProjectWindowTableFunctionTransposeRule Planner rule that pushes a LogicalProject into a LogicalTableFunctionScan which contains a Window table function call by splitting the projection into a projection on top of child of the TableFunctionScan.
PushFilterInCalcIntoTableSourceScanRule Pushes a filter condition from the FlinkLogicalCalc and into a FlinkLogicalTableSourceScan.
PushFilterIntoSourceScanRuleBase Base class for rules that push down filters into table scan.
PushFilterIntoTableSourceScanRule Planner rule that tries to push a filter into a LogicalTableScan, which table is a TableSourceTable.
PushLimitIntoTableSourceScanRule Planner rule that tries to push limit into a FlinkLogicalTableSourceScan, which table is a TableSourceTable.
PushPartitionIntoTableSourceScanRule Planner rule that tries to push partition evaluated by filter condition into a LogicalTableScan.
PushProjectIntoTableSourceScanRule Pushes a LogicalProject into a LogicalTableScan.
PushProjectIntoTableSourceScanRule.Config Configuration for PushProjectIntoTableSourceScanRule.
PushWatermarkIntoTableSourceScanAcrossCalcRule Rule to push the FlinkLogicalWatermarkAssigner across the FlinkLogicalCalc to the FlinkLogicalTableSourceScan.
PushWatermarkIntoTableSourceScanRule Rule to push the FlinkLogicalWatermarkAssigner into the FlinkLogicalTableSourceScan.
PushWatermarkIntoTableSourceScanRuleBase Base rule for interface SupportsWatermarkPushDown and SupportsSourceWatermark.
PythonCorrelateSplitRule Rule will split the Python FlinkLogicalTableFunctionScan with Java calls or the Java FlinkLogicalTableFunctionScan with Python calls into a FlinkLogicalCalc which will be the left input of the new FlinkLogicalCorrelate and a new FlinkLogicalTableFunctionScan.
PythonMapMergeRule Rule will merge Python FlinkLogicalCalc used in Map operation, Flatten FlinkLogicalCalc and Python FlinkLogicalCalc used in Map operation together.
PythonMapRenameRule Rule which renames the field names of the Flatten FlinkLogicalCalc which is right after a FlinkLogicalCalc representing a Python Map operation to the output names of the map function.
RedundantRankNumberColumnRemoveRule Planner rule that removes the output column of rank number iff the rank number column is not used by successor calc.
RemoteCalcCallFinder Finds whether a RexNode contains remote calls or not.
RemoveUnreachableCoalesceArgumentsRule Removes unreachable BuiltInFunctionDefinitions.COALESCE arguments.
RemoveUnreachableCoalesceArgumentsRule.Config Configuration for RemoveUnreachableCoalesceArgumentsRule.
SubQueryDecorrelator.Result Result describing the relational expression after decorrelation and where to find the equivalent non-correlated expressions and correlated conditions.
WrapJsonAggFunctionArgumentsRule.Config Configuration for WrapJsonAggFunctionArgumentsRule.