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 |
---|---|
CalcPythonCorrelateTransposeRule |
Rule will transpose the conditions after the Python correlate node if the join type is inner
join.
|
ExtendedAggregateExtractProjectRule |
Rule to extract a
Project from a LogicalAggregate , a
LogicalWindowAggregate or a TableAggregate and push it down towards the input. |
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.
|
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 . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.