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

Interface FlinkFilterJoinRule.Predicate

Enclosing class:

FlinkFilterJoinRule<C extends FlinkFilterJoinRule.Config>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public 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. If not, Calcite will push it back to above the join.

Method Summary

Modifier and Type	Method and Description
boolean	apply(org.apache.calcite.rel.core.Join join, org.apache.calcite.rel.core.JoinRelType joinType, org.apache.calcite.rex.RexNode exp)

Method Detail

apply

boolean apply(org.apache.calcite.rel.core.Join join,
              org.apache.calcite.rel.core.JoinRelType joinType,
              org.apache.calcite.rex.RexNode exp)