Class | 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 |
SubQueryDecorrelator finds all correlated expressions in a SubQuery,
and gets an equivalent non-correlated relational expression tree and correlation conditions.
|
SubQueryDecorrelator.Result |
Result describing the relational expression after decorrelation
and where to find the equivalent non-correlated expressions and correlated conditions.
|
SubQueryDecorrelator.SubQueryRelDecorrelator |
Pull out all correlation conditions from a given subquery to top level,
and rebuild the subquery rel tree without correlation conditions.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.