Package | Description |
---|---|
org.apache.flink.table.planner.plan.rules.logical |
Class and Description |
---|
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. |
FlinkJoinPushExpressionsRule
Planner rule that pushes down expressions in "equal" join condition.
|
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
org.apache.calcite.rel.core.SemiJoin s 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 SemiJoin s. |
FlinkSemiAntiJoinProjectTransposeRule
Planner rule that pushes
a
org.apache.calcite.rel.core.SemiJoin down in a tree past
a Project . |
SubQueryDecorrelator.Result
Result describing the relational expression after decorrelation
and where to find the equivalent non-correlated expressions and correlated conditions.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.