Package | Description |
---|---|
org.apache.flink.table.planner.plan.rules.logical |
Modifier and Type | Class and Description |
---|---|
class |
FlinkFilterJoinRule<C extends FlinkFilterJoinRule.Config>
Planner rule that pushes filters above and within a join node into the join node and/or its
children nodes.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
FlinkFilterJoinRule.FlinkFilterIntoJoinRule.Config
Rule configuration.
|
static interface |
FlinkFilterJoinRule.FlinkJoinConditionPushRule.Config
Rule configuration.
|
Modifier and Type | Method and Description |
---|---|
FlinkFilterJoinRule.Config |
FlinkFilterJoinRule.Config.withPredicate(FlinkFilterJoinRule.Predicate predicate)
Sets
getPredicate() ()}. |
FlinkFilterJoinRule.Config |
FlinkFilterJoinRule.Config.withSmart(boolean smart)
Sets
isSmart() . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.