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.
ConstantRankNumberColumnRemoveRule Planner rule that removes the output column of rank number iff there is an equality condition for the rank column.
ConstantRankNumberColumnRemoveRule.ConstantRankNumberColumnRemoveRuleConfig Rule configuration.
EnumerableToLogicalTableScan Rule that converts an EnumerableTableScan into a LogicalTableScan.
EnumerableToLogicalTableScan.EnumerableToLogicalTableScanConfig Rule configuration.
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.
FlinkCalcMergeRule Planner rule that merges a Calc onto a Calc.
FlinkCalcMergeRule.FlinkCalcMergeRuleConfig 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.
FlinkFilterProjectTransposeRule Extends calcite's FilterProjectTransposeRule for streaming scenario, modification: does not transpose the top filter references field which generated by non-deterministic function.
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.
FlinkLimit0RemoveRule Planner rule that rewrites `limit 0` to empty Values.
FlinkLimit0RemoveRule.FlinkLimit0RemoveRuleConfig 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.
ImmutableConstantRankNumberColumnRemoveRule.ConstantRankNumberColumnRemoveRuleConfig Immutable implementation of ConstantRankNumberColumnRemoveRule.ConstantRankNumberColumnRemoveRuleConfig.
ImmutableConstantRankNumberColumnRemoveRule.ConstantRankNumberColumnRemoveRuleConfig.Builder Builds instances of type ConstantRankNumberColumnRemoveRuleConfig.
ImmutableEnumerableToLogicalTableScan.EnumerableToLogicalTableScanConfig Immutable implementation of EnumerableToLogicalTableScan.EnumerableToLogicalTableScanConfig.
ImmutableEnumerableToLogicalTableScan.EnumerableToLogicalTableScanConfig.Builder Builds instances of type EnumerableToLogicalTableScanConfig.
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.
ImmutableFlinkCalcMergeRule.FlinkCalcMergeRuleConfig Immutable implementation of FlinkCalcMergeRule.FlinkCalcMergeRuleConfig.
ImmutableFlinkCalcMergeRule.FlinkCalcMergeRuleConfig.Builder Builds instances of type FlinkCalcMergeRuleConfig.
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.
ImmutableFlinkLimit0RemoveRule.FlinkLimit0RemoveRuleConfig Immutable implementation of FlinkLimit0RemoveRule.FlinkLimit0RemoveRuleConfig.
ImmutableFlinkLimit0RemoveRule.FlinkLimit0RemoveRuleConfig.Builder Builds instances of type FlinkLimit0RemoveRuleConfig.
ImmutableJoinTableFunctionScanToCorrelateRule.Config Immutable implementation of JoinTableFunctionScanToCorrelateRule.Config.
ImmutableJoinTableFunctionScanToCorrelateRule.Config.Builder Builds instances of type Config.
ImmutableLogicalUnnestRule.LogicalUnnestRuleConfig Immutable implementation of LogicalUnnestRule.LogicalUnnestRuleConfig.
ImmutableLogicalUnnestRule.LogicalUnnestRuleConfig.Builder Builds instances of type LogicalUnnestRuleConfig.
ImmutableProjectSnapshotTransposeRule.Config Immutable implementation of ProjectSnapshotTransposeRule.Config.
ImmutableProjectSnapshotTransposeRule.Config.Builder Builds instances of type Config.
ImmutablePushFilterIntoLegacyTableSourceScanRule.PushFilterIntoLegacyTableSourceScanRuleConfig Immutable implementation of PushFilterIntoLegacyTableSourceScanRule.PushFilterIntoLegacyTableSourceScanRuleConfig.
ImmutablePushFilterIntoLegacyTableSourceScanRule.PushFilterIntoLegacyTableSourceScanRuleConfig.Builder Builds instances of type PushFilterIntoLegacyTableSourceScanRuleConfig.
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.
ImmutableReplaceIntersectWithSemiJoinRule.ReplaceIntersectWithSemiJoinRuleConfig Immutable implementation of ReplaceIntersectWithSemiJoinRule.ReplaceIntersectWithSemiJoinRuleConfig.
ImmutableReplaceIntersectWithSemiJoinRule.ReplaceIntersectWithSemiJoinRuleConfig.Builder Builds instances of type ReplaceIntersectWithSemiJoinRuleConfig.
ImmutableReplaceMinusWithAntiJoinRule.ReplaceMinusWithAntiJoinRuleConfig Immutable implementation of ReplaceMinusWithAntiJoinRule.ReplaceMinusWithAntiJoinRuleConfig.
ImmutableReplaceMinusWithAntiJoinRule.ReplaceMinusWithAntiJoinRuleConfig.Builder Builds instances of type ReplaceMinusWithAntiJoinRuleConfig.
ImmutableRewriteMinusAllRule.RewriteMinusAllRuleConfig Immutable implementation of RewriteMinusAllRule.RewriteMinusAllRuleConfig.
ImmutableRewriteMinusAllRule.RewriteMinusAllRuleConfig.Builder Builds instances of type RewriteMinusAllRuleConfig.
ImmutableUncollectToTableFunctionScanRule.UncollectToTableFunctionScanRuleConfig Immutable implementation of UncollectToTableFunctionScanRule.UncollectToTableFunctionScanRuleConfig.
ImmutableUncollectToTableFunctionScanRule.UncollectToTableFunctionScanRuleConfig.Builder Builds instances of type UncollectToTableFunctionScanRuleConfig.
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.
LogicalUnnestRule Planner rule that rewrites UNNEST to explode function.
LogicalUnnestRule.LogicalUnnestRuleConfig Rule configuration.
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.
PushFilterIntoLegacyTableSourceScanRule Planner rule that tries to push a filter into a FilterableTableSource.
PushFilterIntoLegacyTableSourceScanRule.PushFilterIntoLegacyTableSourceScanRuleConfig Rule configuration.
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.
ReplaceIntersectWithSemiJoinRule Planner rule that replaces distinct Intersect with a distinct Aggregate on a SEMI Join.
ReplaceIntersectWithSemiJoinRule.ReplaceIntersectWithSemiJoinRuleConfig Rule configuration.
ReplaceMinusWithAntiJoinRule Planner rule that replaces distinct Minus (SQL keyword: EXCEPT) with a distinct Aggregate on an ANTI Join.
ReplaceMinusWithAntiJoinRule.ReplaceMinusWithAntiJoinRuleConfig Rule configuration.
RewriteMinusAllRule Replaces logical Minus operator using a combination of union all, aggregate and table function.
RewriteMinusAllRule.RewriteMinusAllRuleConfig Rule configuration.
SubQueryDecorrelator.Result Result describing the relational expression after decorrelation and where to find the equivalent non-correlated expressions and correlated conditions.
UncollectToTableFunctionScanRule Planner rule that converts Uncollect values to TableFunctionScan.
UncollectToTableFunctionScanRule.UncollectToTableFunctionScanRuleConfig
WindowAggregateReduceFunctionsRule Rule to convert complex aggregation functions into simpler ones.
WrapJsonAggFunctionArgumentsRule.Config Configuration for WrapJsonAggFunctionArgumentsRule.