Windows运行Flink的wordcount示例代码

墨蓝 2022-01-25 17:51 317阅读 0赞

1.下载netcat for windows，解压后将nc.exe放到windows的System32文件夹中

2.Flink官方示例代码写好以后，在Intellj Idea的运行配置那，配置一下参数接收相关参数，即，在Program arguments那加上 localhost 9000，即表示该类的main方法接收9000 socket端口发送过来的数据，如下两个图所示：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21lbmdndWRhb2tl_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21lbmdndWRhb2tl_size_16_color_FFFFFF_t_70 1][]

3.右键运行该类，启动

4.打开cmd窗口，输入命令：nc -L -p 9000 ，改命令为监听9000端口，同时，可以允许在当前cmd窗口中输入参数

5.在cmd窗口中输入参数，观察idea的console中打印的信息，如下所示：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21lbmdndWRhb2tl_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21lbmdndWRhb2tl_size_16_color_FFFFFF_t_70]: /images/20220126/ca990b6d99304be3afcbc4feb230bf85.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21lbmdndWRhb2tl_size_16_color_FFFFFF_t_70 1]: /images/20220126/1920b58ff2c545999c3abf1499bdb0a1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21lbmdndWRhb2tl_size_16_color_FFFFFF_t_70 2]: /images/20220126/3995a41e640246909aae0b6b30f94c55.png

发表评论取消回复

表情：

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

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

相关阅读

相关 Flink 1.17教程：wordcount maven工程java代码示例（批、流实现方式）

> 批、流实现wordcount代码示例 pom.xml <properties> <flink.version>1.17.0</fli

Dear 丶/ 2023年10月15日 14:35/ 0 赞/ 14 阅读

相关 flink wordcount示例

pom ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLm

缺乏、安全感/ 2023年10月06日 12:21/ 0 赞/ 155 阅读

相关 windows下运行hadoop的wordcount示例超详细过程

windows下运行hadoop的wordcount示例超详细过程 > 特别感谢参考博文中的两位博主的分享一.下载2个文件 `https://github.co

痛定思痛。/ 2023年05月22日 14:26/ 0 赞/ 19 阅读

相关 Flink流计算WordCount代码示例

代码 package com.zxl.flink import org.apache.flink.streaming.api.scala.Str

墨蓝/ 2022年09月11日 06:13/ 0 赞/ 507 阅读

相关 hadoop 自带示例wordcount 详细运行步骤

因为机器学习，接触到了数据挖掘；因为数据挖掘，接触到了大数据；因为大数据，接触到了Hadoop。之前有过hadoop的简单了解，但都是基于别人提供的hadoop来学习和使用，虽

矫情吗；*/ 2022年08月21日 10:42/ 0 赞/ 164 阅读

相关 Windows运行Flink的wordcount示例代码

1.下载netcat for windows，解压后将nc.exe放到windows的System32文件夹中 2.Flink官方示例代码写好以后，在Intellj Idea

墨蓝/ 2022年01月25日 17:51/ 0 赞/ 318 阅读

相关 Flink WordCount

程序结构 > 整个flink程序一共分为5步 1. 设定Flink执行环境 2. 创建和加载数据集 3. 对数据集指定转换操作逻辑 4. 指定计算结果输出位置 5.

拼搏现实的明天。/ 2021年11月09日 04:12/ 0 赞/ 400 阅读

相关 Flink java wordcount

Flnk java wordcount 前言项目的目录结构 pom文件 WindowWordCount.java

短命女/ 2021年09月25日 00:46/ 0 赞/ 633 阅读

相关【Flink入门】Flink流处理WordCount

目录先引入pom.xml文件 flink流处理代码 IDEA执行 -------------------- 前面已经学习了flink的批处理Wor

布满荆棘的人生/ 2021年09月23日 05:00/ 0 赞/ 554 阅读

相关 Flink WordCount实例讲解

摘要：本文主要讲了一个Flink的简单的可以本地运行的wordCount程序本文工程下载：[https://github.com/appleappleapple/B

小咪咪/ 2021年09月12日 05:54/ 0 赞/ 481 阅读