Flink 入门案例：实现WordCount

package com.xum.flinks

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


object WordCountExample 
{
  def main(args: Array[String]) 
  {
    // 文件目录
    val logFile = "./example.txt"
    
    // 获取批处理的执行环境
    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    env.setParallelism(2)
    
    // 读取文件
    val text: DataStream[String] = env.readTextFile(logFile)
    
    // 引入隐式转换
    import org.apache.flink.api.scala._
    
    // 单词统计
    val counts = text.flatMap(_.split(" "))
                     .map((_,1))
                     .keyBy(0)
                     .sum(1)

    //输出结果
    counts.print()
 
    // 执行
    env.execute("Flink WordCount Example")
  }
}