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));
	}