|
代码：
package day01
import org.apache.flink.streaming.api.scala._
object Demo02Stream {
def main(args: Array[String]): Unit = {
//创建流计算
val env = StreamExecutionEnvironment.getExecutionEnvironment
val value: DataStream[String] = env.socketTextStream("node7-1", 9999)
val res= value.flatMap(_.split(" "))
.filter(_!="w")
.map((_,1))
.keyBy(0)
.sum(1)
res.print("stream print").setParallelism(1)
env.execute("stream job")
}
}
起zookeeper和hadoop以及flink，并且打开网页node7-1:8081
起nc，没有的话 yum -y install nc ,下载一下
[root@node7-1 ~]# nc -lk 9999
运行代码，在nc输数据可以输出来。
idea中双击运行这个jar,会出现它的路径。在本地找到这个文件。
把jar包放进去
填写，并且提交。
正常
点击你刚才的任务
okk! | 
转播
