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. |
FlinkFilterJoinRule
Planner rule that pushes filters above and
within a join node into the join node and/or its children nodes.
|
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.
|
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.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.