今天就跟大家聊聊有關Flink中指定算子的方式是什么，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

創新互聯是一家專業的成都網站建設公司，我們專注成都網站制作、成都網站建設、網絡營銷、企業網站建設，買鏈接，一元廣告為企業客戶提供一站式建站解決方案，能帶給客戶新的互聯網理念。從網站結構的規劃UI設計到用戶體驗提高，創新互聯力求做到盡善盡美。

我們之前在使用flatMap時，傳了一個new FlatMapFunction匿名內部類。而這僅僅是其中的一種方式。

方式一：實現MapFunction接口

最簡單的方式就是實現一個MapFunction接口，例如：

text.flatMap(new MyFlatMapFunction()).keyBy(new KeySelector<WC, Object>() {
            @Override
            public Object getKey(WC value) throws Exception {
                return value.word;
            }
        }).timeWindow(Time.seconds(5)).sum("count").print().setParallelism(1);
public static class MyFlatMapFunction implements FlatMapFunction<String, WC> {
        @Override
        public void flatMap(String value, Collector<WC> out) throws Exception {
            String[] tokens = value.toLowerCase().split(",");
            for (String token : tokens) {
                if (token.length() > 0) {
                    out.collect(new WC(token, 1));
                }
            }
        }
    }

方式二：匿名內部類

這種方式就是我們之前一直使用的方式。

方式三：java8 Lambdas

方式四：Rich functions

text.flatMap(new RichFlatMapFunction<String, WC>() {
            @Override
            public void flatMap(String value, Collector<WC> out) throws Exception {
                String[] tokens = value.toLowerCase().split(",");
                for (String token : tokens) {
                    if (token.length() > 0) {
                        out.collect(new WC(token, 1));
                    }
                }
            }
        })

繼承一個RichFlatMapFunction類

看完上述內容，你們對Flink中指定算子的方式是什么有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注創新互聯行業資訊頻道，感謝大家的支持。

本文題目：Flink中指定算子的方式是什么
URL地址：http://www.2m8n56k.cn/article8/jphsop.html

成都網站建設公司_創新互聯，為您提供定制網站、響應式網站、網站改版、App開發、網站設計、做網站

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：[email protected]。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯