WordCount の出力は、複数のファイルに格納されています。ただし、開発者は、ファイルがクラスターにとどまる場所 (ip、パス) を制御できません。MapReduce API には、開発者がこれに対処するための reduce プログラムを作成するための規定があります。ApacheBeam で DirectRunner またはその他のランナーを使用してこれを処理するにはどうすればよいですか?
WordCount の出力は、複数のファイルに格納されています。ただし、開発者は、ファイルがクラスターにとどまる場所 (ip、パス) を制御できません。MapReduce API には、開発者がこれに対処するための reduce プログラムを作成するための規定があります。ApacheBeam で DirectRunner またはその他のランナーを使用してこれを処理するにはどうすればよいですか?