Package 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

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method 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)