HadoopのWordCountをJava8のStreamで実装してみた

勉強がてら、Java8のStreamを使ってHadoopのサンプルコードのWordCountを実装してみた。
@daiki_kameyaに手伝ってもらった。

    public static void main(String[] args) throws Exception {
        Path path = FileSystems.getDefault().getPath("input.txt");

        Files.lines(path).flatMap(line -> Arrays.stream(line.split(" ")))
                .collect(Collectors.groupingBy(s -> s, Collectors.counting()))
                .forEach((k, v) -> System.out.println(k + ":" + v));
    }