Interface FilterCondition

  • All Superinterfaces:
    org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, Serializable

    public interface FilterCondition
    extends org.apache.flink.api.common.functions.RichFunction
    Interface for code generated filter condition function on single RowData.
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      boolean apply​(org.apache.flink.table.data.RowData in)  
      • Methods inherited from interface org.apache.flink.api.common.functions.RichFunction

        close, getIterationRuntimeContext, getRuntimeContext, open, open, setRuntimeContext
    • Method Detail

      • apply

        boolean apply​(org.apache.flink.table.data.RowData in)
        Returns:
        true if the filter condition stays true for the input row