Interface | Description |
---|---|
FlinkFilterJoinRule.Predicate |
Predicate that returns whether a filter is valid in the ON clause of a
join for this particular kind of join.
|
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. |
FlinkFilterJoinRule |
Planner rule that pushes filters above and
within a join node into the join node and/or its children nodes.
|
FlinkFilterJoinRule.FlinkFilterIntoJoinRule |
Rule that tries to push filter expressions into a join
condition and into the inputs of the join.
|
FlinkFilterJoinRule.FlinkJoinConditionPushRule |
Rule that pushes parts of the join condition to its inputs.
|
FlinkJoinPushExpressionsRule |
Planner rule that pushes down expressions in "equal" join condition.
|
FlinkJoinToMultiJoinRule |
Planner rule to flatten a tree of
LogicalJoin s
into a single MultiJoin with N inputs. |
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
SemiJoin s down in a tree past
a Filter . |
FlinkSemiAntiJoinJoinTransposeRule |
Planner rule that pushes a
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
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.