flink1.12.x Streaming Dataflow:source、Transformation、sink和对应程序代码
linux nc命令(tcp服务器)
flink1.12.x 实现wordcount-上传到flink集群,flink run执行jar-读写HDFS文件
flink1.12.x DataStream实现wordcount- 连接socket(TCP)服务器-lambda简化写法
maven-resources-plugin:jar:2.6 is missing, no dependency information available
在maven中添加cloudera库
flink1.12.x DataSet实现wordcount
flink1.12.x standalone独立集群模式-测试wordcount(读写HDFS文件)
flink1.12.x local单机模式-支持 HDFS(hadoop3)、测试wordcount(读写HDFS文件)
flink1.12.x local单机模式-原理(图)