org.apache.flink.table.plan.rules.logical

Class FlinkFilterJoinRule

java.lang.Object

org.apache.calcite.plan.RelOptRule

org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Direct Known Subclasses:

FlinkFilterJoinRule.FlinkFilterIntoJoinRule, FlinkFilterJoinRule.FlinkJoinConditionPushRule

public abstract class FlinkFilterJoinRule
extends org.apache.calcite.plan.RelOptRule

Planner rule that pushes filters above and within a join node into the join node and/or its children nodes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkFilterJoinRule.FlinkFilterIntoJoinRule Rule that tries to push filter expressions into a join condition and into the inputs of the join.
static class	FlinkFilterJoinRule.FlinkJoinConditionPushRule Rule that pushes parts of the join condition to its inputs.
static interface	FlinkFilterJoinRule.Predicate Predicate that returns whether a filter is valid in the ON clause of a join for this particular kind of join.

Field Summary

Fields

Modifier and Type	Field and Description
static FlinkFilterJoinRule	DUMB_FILTER_ON_JOIN Dumber version of FILTER_ON_JOIN.
static FlinkFilterJoinRule	FILTER_ON_JOIN Rule that pushes predicates from a Filter into the Join below them.
static FlinkFilterJoinRule	JOIN Rule that pushes predicates in a Join into the inputs to the join.
static FlinkFilterJoinRule.Predicate	TRUE_PREDICATE Predicate that always returns true.

Fields inherited from class org.apache.calcite.plan.RelOptRule

description, operands, relBuilderFactory

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FlinkFilterJoinRule(org.apache.calcite.plan.RelOptRuleOperand operand, String id, boolean smart, org.apache.calcite.tools.RelBuilderFactory relBuilderFactory, FlinkFilterJoinRule.Predicate predicate) Creates a FilterProjectTransposeRule with an explicit root operand and factories.
protected	FlinkFilterJoinRule(org.apache.calcite.plan.RelOptRuleOperand operand, String id, boolean smart, org.apache.calcite.rel.core.RelFactories.FilterFactory filterFactory, org.apache.calcite.rel.core.RelFactories.ProjectFactory projectFactory) Deprecated.
protected	FlinkFilterJoinRule(org.apache.calcite.plan.RelOptRuleOperand operand, String id, boolean smart, org.apache.calcite.rel.core.RelFactories.FilterFactory filterFactory, org.apache.calcite.rel.core.RelFactories.ProjectFactory projectFactory, FlinkFilterJoinRule.Predicate predicate) Deprecated.

Method Summary

Modifier and Type	Method and Description
protected void	perform(org.apache.calcite.plan.RelOptRuleCall call, org.apache.calcite.rel.core.Filter filter, org.apache.calcite.rel.core.Join join)
protected void	validateJoinFilters(List<org.apache.calcite.rex.RexNode> aboveFilters, List<org.apache.calcite.rex.RexNode> joinFilters, org.apache.calcite.rel.core.Join join, org.apache.calcite.rel.core.JoinRelType joinType) Validates that target execution framework can satisfy join filters.

Methods inherited from class org.apache.calcite.plan.RelOptRule

any, convert, convert, convertList, convertOperand, convertOperand, equals, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, matches, none, onMatch, operand, operand, operand, operand, operand, operandJ, operandJ, some, toString, unordered

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

TRUE_PREDICATE

public static final FlinkFilterJoinRule.Predicate TRUE_PREDICATE

Predicate that always returns true. With this predicate, every filter will be pushed into the ON clause.

FILTER_ON_JOIN

public static final FlinkFilterJoinRule FILTER_ON_JOIN

Rule that pushes predicates from a Filter into the Join below them.

DUMB_FILTER_ON_JOIN

public static final FlinkFilterJoinRule DUMB_FILTER_ON_JOIN

Dumber version of FILTER_ON_JOIN. Not intended for production use, but keeps some tests working for which FILTER_ON_JOIN is too smart.

JOIN

public static final FlinkFilterJoinRule JOIN

Rule that pushes predicates in a Join into the inputs to the join.

Constructor Detail

FlinkFilterJoinRule

protected FlinkFilterJoinRule(org.apache.calcite.plan.RelOptRuleOperand operand,
                              String id,
                              boolean smart,
                              org.apache.calcite.tools.RelBuilderFactory relBuilderFactory,
                              FlinkFilterJoinRule.Predicate predicate)

Creates a FilterProjectTransposeRule with an explicit root operand and factories.

FlinkFilterJoinRule

@Deprecated
protected FlinkFilterJoinRule(org.apache.calcite.plan.RelOptRuleOperand operand,
                                          String id,
                                          boolean smart,
                                          org.apache.calcite.rel.core.RelFactories.FilterFactory filterFactory,
                                          org.apache.calcite.rel.core.RelFactories.ProjectFactory projectFactory)

Deprecated.

Creates a FlinkFilterJoinRule with an explicit root operand and factories.

FlinkFilterJoinRule

@Deprecated
protected FlinkFilterJoinRule(org.apache.calcite.plan.RelOptRuleOperand operand,
                                          String id,
                                          boolean smart,
                                          org.apache.calcite.rel.core.RelFactories.FilterFactory filterFactory,
                                          org.apache.calcite.rel.core.RelFactories.ProjectFactory projectFactory,
                                          FlinkFilterJoinRule.Predicate predicate)

Deprecated.

Creates a FilterProjectTransposeRule with an explicit root operand and factories.

Method Detail

perform

protected void perform(org.apache.calcite.plan.RelOptRuleCall call,
                       org.apache.calcite.rel.core.Filter filter,
                       org.apache.calcite.rel.core.Join join)

validateJoinFilters

protected void validateJoinFilters(List<org.apache.calcite.rex.RexNode> aboveFilters,
                                   List<org.apache.calcite.rex.RexNode> joinFilters,
                                   org.apache.calcite.rel.core.Join join,
                                   org.apache.calcite.rel.core.JoinRelType joinType)

Validates that target execution framework can satisfy join filters.

If the join filter cannot be satisfied (for example, if it is l.c1 > r.c2 and the join only supports equi-join), removes the filter from joinFilters and adds it to aboveFilters.

The default implementation does nothing; i.e. the join can handle all conditions.

Parameters:

aboveFilters - Filter above Join

joinFilters - Filters in join condition

join - Join

joinType - JoinRelType could be different from type in Join due to outer join simplification.