Flink-流处理wordcount

public class StreamWordCount {

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

        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        String inputPath = "D:\\IDEAWorkspace\\2017.3\\bigData\\Flink\\src\\main\\resources\\hello.txt";

        DataStream inputDataStream = env.readTextFile(inputPath);

        //对数据流进行转换操作
        DataStream> resDataStream = inputDataStream.flatMap(new MyFlatMapfunction())
                //流处理，来一条数据处理一条，根据元组的第一位进行分区
                .keyBy(0)
                .sum(1);//根据元组的第二个位置进行求和

        resDataStream.print();

        env.execute();

    }

    public static class MyFlatMapfunction implements FlatMapFunction>{

        private Tuple2 wordTuple = new Tuple2<>();

        @Override
        public void flatMap(String s, Collector> collector) throws Exception {
            String[] words = s.split(" ", -1);
            for (String word : words) {
                wordTuple.setFields(word,1);
                collector.collect(wordTuple);
            }
        }
    }
}