小編給大家分享一下Flink中Filter怎么用，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

十余年的會同網(wǎng)站建設經驗，針對設計、前端、開發(fā)、售后、文案、推廣等六對一服務，響應快，48小時及時工作處理。營銷型網(wǎng)站建設的優(yōu)勢是能夠根據(jù)用戶設備顯示端的尺寸不同，自動調整會同建站的顯示方式，使網(wǎng)站能夠適用不同顯示終端，在瀏覽器中調整網(wǎng)站的寬度，無論在任何一種瀏覽器上瀏覽網(wǎng)站，都能展現(xiàn)優(yōu)雅布局與設計，從而大程度地提升瀏覽體驗。創(chuàng)新互聯(lián)建站從事“會同網(wǎng)站設計”,“會同網(wǎng)站推廣”以來，每個客戶項目都認真落實執(zhí)行。

Filter算子：對數(shù)據(jù)流進行過濾，只返回為true的數(shù)據(jù)

示例環(huán)境

java.version: 1.8.x
flink.version: 1.11.1

示例數(shù)據(jù)源 （項目碼云下載）

Flink 系例 之 搭建開發(fā)環(huán)境與數(shù)據(jù)

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算子：對數(shù)據(jù)流進行過濾，只返回為true的數(shù)據(jù)
 */
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怎么用”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道！