- 链接地址:https://blog.csdn.net/weixin_44911081/article/details/122793645
- 链接标题:Flink实现WordCount案例_flink wordwithcount-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:3390
文章浏览阅读861次。案例需求:需求:使用netcat工具向9999端口不断的发送数据,通过flink读取端口数据并统计不同单词出现的次数。代码实现:import org.apache.flink.streaming.api.scala._//导入隐式函数依赖//import org.apache.flink.streaming.api.scala._import org.apache.flink.streaming.api.windowing.time.Timeobject WordCountFromSocke_flink wordwithcount
版权声明:本文发布于特牛生活网 内容均来源于互联网 如有侵权联系删除