Flink中Filter怎么用

小编给大家分享一下Flink中Filter怎么用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

Filter算子：对数据流进行过滤，只返回为true的数据

示例环境

java.version: 1.8.xflink.version: 1.11.1

示例数据源 （项目码云下载）

Flink 系例 之 搭建开发环境与数据

Fliter.java

import com.flink.examples.DataSource;import org.apache.flink.api.common.functions.FilterFunction;import org.apache.flink.api.java.tuple.Tuple3;import org.apache.flink.streaming.api.datastream.DataStream;import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;import java.util.List;/** * @Description Filter算子：对数据流进行过滤，只返回为true的数据 */public class Filter {    /**     * 遍历集合，只打印性别为男性的记录     * @param args     * @throws Exception     */    public static void main(String[] args) throws Exception {        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();        List> tuple3List = DataSource.getTuple3ToList();        DataStream> dataStream = env.fromCollection(tuple3List).filter(new FilterFunction>() {            @Override            public boolean filter(Tuple3 tuple3) throws Exception {                //性别（1男，2女）                return tuple3.f1.equals("man");            }        });        dataStream.print();        env.execute("flink Filter job");    }}

打印结果

4> (吴八,man,30)3> (张三,man,20)1> (王五,man,29)

以上是"Flink中Filter怎么用"这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注行业资讯频道！