Flink应用开发系列（十六）数据集转换之FilterFunction

本文的话，我们再介绍下FilterFunction。这里的FilterFunction主要是用于过滤数据的，当匹配的条件为true的话，就会保留数据，匹配条件为false的话，就会丢掉数据。实现FilterFunction的话，也有两种方式，分别是：

1、使用匿名内部类
2、继承RichFilterFunction类。

下面我们使用代码来演示下filterfunction，完整代码如下：

package org.example;

import org.apache.flink.api.common.functions.FilterFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;

public class DataSetFilterJob {

    public static void main(String[] args) throws Exception{

        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        DataSet<Integer> input = env.fromElements(2, 1);
        input.filter(new FilterFunction<Integer>() {
            @Override
            public boolean filter(Integer value) throws Exception {
                return value == 2;
            }
        }).print();

    }

}

运行下看看结果：

最后按照惯例，附上本案例的源码，登录后即可下载。