Flink入门示例（Word Count，数据来源为Socket）

男娘i 2022-11-06 10:56 182阅读 0赞

以下演示一个简单的Flink Word Count程序。

数据来源为Socket，端口9999。

基于Flink `1.11`。

import org.apache.flink.api.common.functions.FlatMapFunction;
    import org.apache.flink.api.java.tuple.Tuple2;
    import org.apache.flink.streaming.api.datastream.DataStream;
    import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
    import org.apache.flink.streaming.api.windowing.time.Time;
    import org.apache.flink.util.Collector;
    
    public class WindowWordCount { 
    
        public static void main(String[] args) throws Exception { 
    
            StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    
            DataStream<Tuple2<String, Integer>> dataStream = env
                    .socketTextStream("localhost", 9999)
                    .flatMap(new Splitter())
                    .keyBy(value -> value.f0).timeWindow(Time.seconds(5)).sum(1);
    
            dataStream.print();
    
            env.execute("Window WordCount");
        }
    
        public static class Splitter implements FlatMapFunction<String, Tuple2<String, Integer>> { 
            @Override
            public void flatMap(String sentence, Collector<Tuple2<String, Integer>> out) { 
                for (String word : sentence.split(" ")) { 
                    out.collect(new Tuple2<>(word, 1));
                }
            }
        }
    }

官方文档：

https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/datastream\_api.html

发表评论取消回复

表情：

评论列表（有 0 条评论，182人围观）

还没有评论，来说两句吧...

相关阅读

相关【大数据入门核心技术-Flink】（七）Flink实现从Socket读取数据并WordCount

目录一、环境部署二、代码三、运行 -------------------- 一、环境部署 [【大数据入门核心技术-Flink】（二）Flink安装部署-

我不是女神ヾ/ 2024年03月02日 08:12/ 0 赞/ 116 阅读

相关 Flink快速入门wordcount示例（scala版）

引依赖： ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ3h1ZWxpYW5nLm

我会带着你远行/ 2023年10月07日 09:12/ 0 赞/ 86 阅读

相关 0050-mapreduce入门-word count

文章目录 1. 说明 2. 添加依赖 3. 编写代码 3.1 Mapper程序

清疚/ 2023年07月14日 10:56/ 0 赞/ 98 阅读

相关 Flink示例——Flink-CDC

Flink示例——Flink-CDC 版本信息 <table> <thead> <tr> <th>产品</th> <th>版本</th>

你的名字/ 2022年11月19日 04:14/ 0 赞/ 473 阅读

相关 Flink入门示例（Word Count，数据来源为Socket）

以下演示一个简单的Flink Word Count程序。数据来源为Socket，端口9999。基于Flink `1.11`。 import org.apach

男娘i/ 2022年11月06日 10:56/ 0 赞/ 183 阅读

相关 word_count实践操作

最基础的Work\_count： Map.py import sys import time import re p = re.compile(r'\\w+')

快来打我*/ 2022年05月15日 14:07/ 0 赞/ 262 阅读

相关 Flink 简单入门示例

Flink 简单入门示例 1.Flink读取Socket流，实现Word Count示例 import org.apache.flink.streaming

￡神魔★判官ぃ/ 2022年04月23日 06:08/ 0 赞/ 647 阅读

相关【Flink入门】Flink自定义Source读取MySQL数据

在前一篇博客中 [【Flink入门】Flink读取Kafka数据Demo][Flink_Flink_Kafka_Demo] 已经简单介绍了Flink读取Kafka数据并通过De

╰半夏微凉°/ 2021年09月25日 04:44/ 0 赞/ 981 阅读

相关【Flink入门】Flink读取Kafka数据Demo

flink算子操作主要分为三大部分：source(数据读取)、transform(数据处理)、sink(数据输出)，这篇博客简单聊聊flink读取kafka数据在控制台打印的D

超、凢脫俗/ 2021年09月25日 04:40/ 0 赞/ 809 阅读

相关 Flink流处理入门和socket发送数据

Flink流处理入门和socket发送数据 Flink初步使用 Flink流处理程序运行前提 Socket发送数据补充spark相关东西原理：基础数据结构：RDD...

谁借莪１个温暖的怀抱￠/ 2021年05月17日 14:09/ 0 赞/ 746 阅读