hadoop - hadoop中未产生的输出

Question

我正在尝试使用mapreduce查找每个小部件的平均值。使用hadoop fs -cat user / vagrant / example-1 / part-r-00000时，作业成功完成，但没有产生任何输出

    public static class MaxWidgetReducer
  extends Reducer<Text, FloatWritable, FloatWritable, NullWritable> {

public void reduce(Text k, Iterable<FloatWritable> vals, Context context)
    throws IOException, InterruptedException {
  Float totalPrice = 0.0f;
  Float avgPrice = 0.0f;
  Integer count = null;

  for (FloatWritable w : vals) {

      totalPrice = (totalPrice + w.get());
        count++;

}

  avgPrice = (totalPrice)/(count);

  context.write(new FloatWritable(avgPrice), NullWritable.get());

}

Answer 1

我强烈建议您在mapper和reducer中都使用try / catch块，因此您可以知道是否是由于处理数据时引发了异常，请尝试将w.get()强制转换为float能够将该值(value)添加到总价中。

干杯。