これ本当に行き詰まる。Map/Reducer クラスが何も表示できないのはなぜですか? Reducer クラスに次のコードを追加します。
@Override
public void reduce(Text key, Iterable<LongWritable> values, Context context)
{
// Standard algorithm for finding the max value
long sum = 0;
for (LongWritable value : values) {
sum++;
}
try
{
context.write(key, new LongWritable(sum));
System.out.println("Reducer exits...");
}
catch (Exception e)
{
System.out.println(e);
}
}
「System.out.println("reducer exits...");」という行が表示される理由 Hadoop プログラムを実行すると、コンソールに表示できません: hadoop jar xxx.jar 入力 出力