Flink版本WC

深藏阁楼爱情的钟 2022-12-27 04:45 141阅读 0赞

### Flink版本WC ###

wc是一个非常经典的大数据例子，下面我们运行一下wc

flink run -m yarn-cluster -yn 4 -yjm 1024 -ytm 1024 /opt/cloudera/parcels/FLINK/lib/flink/examples/streaming/WordCount.jar --input hdfs://192.168.2.100:8020/data/tmp/wc/input/ --output hdfs://192.168.2.100:8020/data/tmp/wc/output/

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYXpoYWd1_size_16_color_FFFFFF_t_70]  
在完成列表中查看  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYXpoYWd1_size_16_color_FFFFFF_t_70 1]  
点击列表查看详细信息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYXpoYWd1_size_16_color_FFFFFF_t_70 2]  
查看结果  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYXpoYWd1_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYXpoYWd1_size_16_color_FFFFFF_t_70]: /images/20221120/fd437c883f1444d7a8e87b5d1057144d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYXpoYWd1_size_16_color_FFFFFF_t_70 1]: /images/20221120/b7ad930a93784c19888e51d6fbcfa019.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYXpoYWd1_size_16_color_FFFFFF_t_70 2]: /images/20221120/afb1d2f7713042919568e1d377762fa6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYXpoYWd1_size_16_color_FFFFFF_t_70 3]: /images/20221120/11070b21b0c442ca865682b6498f0461.png

发表评论取消回复

表情：

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

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

相关阅读

相关【大数据入门核心技术-Flink】（六）Flink版本WordCount-Scala版本

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

绝地灬酷狼/ 2024年03月03日 08:51/ 0 赞/ 96 阅读

相关【大数据入门核心技术-Flink】（五）Flink版本WordCount-Java版本

一、环境部署 [【大数据入门核心技术-Flink】（二）Flink安装部署-本地模式][-Flink_Flink_-] [【大数据入门核心技术-Flink】（三）Fli

客官°小女子只卖身不卖艺/ 2024年03月03日 08:49/ 0 赞/ 116 阅读

相关 Flink版本WC

Flink版本WC wc是一个非常经典的大数据例子，下面我们运行一下wc flink run -m yarn-cluster -yn 4 -yjm 102

深藏阁楼爱情的钟/ 2022年12月27日 04:45/ 0 赞/ 142 阅读

相关 wc命令

linux中的wc命令(word count) 可以用来统计计数， eg1:统计文件的行数 wc -l filename eg2: 统计文件中某一个

Dear 丶/ 2022年10月22日 14:50/ 0 赞/ 192 阅读

相关 wc命令

Linux系统中的wc(Word Count)命令的功能为统计指定文件中的字节数、字数、行数，并将统计结果显示输出。 1．命令格式： wc \[选项\]文件... 2．命

朱雀/ 2022年09月17日 14:19/ 0 赞/ 184 阅读

相关【Flink】 Flink与Kafka版本对应关系

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

￡神魔★判官ぃ/ 2022年08月31日 12:20/ 0 赞/ 649 阅读

相关 linux命令 wc

Linux系统中的wc(Word Count)命令的功能为统计指定文件中的字节数、字数、行数，并将统计结果显示输出。 1．命令格式： wc \[选项\]文件... 2．命

落日映苍穹つ/ 2022年08月22日 00:10/ 0 赞/ 180 阅读

相关【零基础学flink】flink实战(idea版本)

回顾上一小节中我们介绍了flink的安装，以及flink word count的实现，本文主要介绍如何使用idea开发flink项目一、新建Maven项目这

川长思鸟来/ 2022年02月14日 07:47/ 0 赞/ 271 阅读

相关 WC2019游记

day-4 WC居然还要把THUWC的被子搬到另一个寝室楼...早上就忙着跑来跑去，顺便去报了个到。话说WC居然也有签名板这种东西，犹豫了一下还是把我的名字签上了。为

淩亂°似流年/ 2022年01月05日 22:37/ 0 赞/ 211 阅读

相关 Linux wc命令

Linux wc命令用于计算字数。利用wc指令我们可以计算文件的Byte数、字数、或是列数，若不指定文件名称、或是所给予的文件名为"-"，则wc指令会从标准输入设备读取数据。

灰太狼/ 2020年05月26日 14:07/ 0 赞/ 637 阅读