Package org.apache.flink.table.runtime.generated

Interface JoinCondition

  • All Superinterfaces:
    org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, Serializable
    All Known Implementing Classes:
    JoinConditionWithNullFilters
    public interface JoinCondition
extends org.apache.flink.api.common.functions.RichFunction
    Interface for code generated condition function for [[org.apache.calcite.rel.core.Join]].

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      boolean apply​(org.apache.flink.table.data.RowData in1, org.apache.flink.table.data.RowData in2)  

      • Methods inherited from interface org.apache.flink.api.common.functions.RichFunction

        close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

    • Method Detail

      • apply

        boolean apply​(org.apache.flink.table.data.RowData in1,
              org.apache.flink.table.data.RowData in2)
        Returns:
        true if the join condition stays true for the joined row (in1, in2)