Package org.apache.iceberg.flink

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:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlinkSourceFilter(Schema schema, Expression expr, boolean caseSensitive)

Method Summary

Modifier and Type	Method	Description
boolean	filter(org.apache.flink.table.data.RowData value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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>