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:
-
Constructor Summary
-
Method Summary
-
Constructor Details
-
FlinkSourceFilter
-
-
Method Details
-
filter
public boolean filter(org.apache.flink.table.data.RowData value) - Specified by:
filter
in interfaceorg.apache.flink.api.common.functions.FilterFunction<org.apache.flink.table.data.RowData>
-