Class FlinkSourceFilter

java.lang.Object
org.apache.iceberg.flink.FlinkSourceFilter
All Implemented Interfaces:
Serializable, org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.table.data.RowData>, org.apache.flink.api.common.functions.Function

public class FlinkSourceFilter extends Object implements org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.table.data.RowData>
See Also:
  • Constructor Details

    • FlinkSourceFilter

      public FlinkSourceFilter(Schema schema, Expression expr, boolean caseSensitive)
  • Method Details

    • filter

      public boolean filter(org.apache.flink.table.data.RowData value)
      Specified by:
      filter in interface org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.table.data.RowData>