Package | Description |
---|---|
org.apache.flink.table.plan.rules.logical |
Class and 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.Predicate
Predicate that returns whether a filter is valid in the ON clause of a join for this
particular kind of join.
|
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.