特牛生活网

Flink实现WordCount案例_flink wordwithcount-CSDN博客

网友收藏
文章浏览阅读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