Flink wordCount

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.streaming.api.scala._

object WordCount {
  def main(args: Array[String]): Unit = {
    //设置环境
    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.createLocalEnvironment()
    //设置数据源
    val context: DataStream[String] = env.socketTextStream("node01", 9999)
    //计算逻辑
    val process: DataStream[(String, Int)] = context
      .flatMap(_.split(" "))
      .map((_, 1))
      .keyBy(_._1)
      .reduce((x, y) => {
        val key: String = x._1
        val value = x._2 + y._2
        (key, value)
      })
    //输出结果
    process.addSink(x => {
      print(x)
    })
    //提交任务
    env.execute("word count")
  }
}