使用Scala语言编写flinkc流处理程序，实现word count功能

以下是使用Scala语言编写flink流处理程序，实现word count功能的代码示例：

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

object WordCount {
  def main(args: Array[String]): Unit = {
    // 创建执行环境
    val env = StreamExecutionEnvironment.getExecutionEnvironment

    // 读取数据源（本例中从socket读取数据）
    val dataStream = env.socketTextStream("localhost", 9999)

    // 执行word count操作
    val wordCountStream = dataStream
      .flatMap(_.split(" "))
      .map((_, 1))
      .keyBy(0)
      .sum(1)

    // 打印结果
    wordCountStream.print()

    // 启动执行环境
    env.execute("word count")
  }
}

解析：

1. 创建执行环境：使用`StreamExecutionEnvironment.getExecutionEnvironment`方法创建执行环境。

2. 读取数据源：使用`env.socketTextStream`方法从socket读取数据。

3. 执行word count操作：使用`flatMap`方法将输入数据按空格切分成单词，使用`map`方法将每个单词映射为`(单词, 1)`的二元组，使用`keyBy`方法按照单词进行分组，使用`sum`方法对每个单词出现的次数进行累加。

4. 打印结果：使用`print`方法将结果输出到控制台。

5. 启动执行环境：使用`env.execute`方法启动执行环境。