用flink最新版本写一个wordcount程序

好的，您可以参考以下代码编写flink的wordcount程序:

import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;

public class WordCount {

  public static void main(String[] args) throws Exception {

    final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

    DataSet<String> text = env.readTextFile("input.txt");

    DataSet<Tuple2<String, Integer>> counts =
      text.flatMap(new Tokenizer())
          .groupBy(0)
          .sum(1);

    counts.print();

    env.execute("WordCount Example");
  }

  public static final class Tokenizer implements FlatMapFunction<String, Tuple2<String, Integer>> {

    @Override
    public void flatMap(String value, Collector<Tuple2<String, Integer>> out) {
      String[] tokens = value.toLowerCase().split("\\W+");

      for (String token : tokens) {
        if (token.length() > 0) {
          out.collect(new Tuple2<String, Integer>(token, 1));
        }
      }
    }
  }
}

其中的Tokenize函数用于将输入的文本进行分词，FlatMapFunction是Flink中的一个常用接口。 groupBy(0)指将每个单词分到一个组中，sum(1)将每个单词的出现次数累加起来。

您需要将上述代码保存为一个Java文件，例如WordCount.java，然后使用Flink命令运行此程序。

注意，除了flink的环境安装之外，还需要准备一个输入文件，例如input.txt，来进行单词计数。

希望对您有所帮助！