我试图在c++中实现一个reducer的清理方法。我试着跟着测试工作。

class WordCountReducer : public HadoopPipes::Reducer {
public:
  WordCountReducer(HadoopPipes::TaskContext& context) {}
  // Reduce function
  void reduce(HadoopPipes::ReduceContext& context) {
    //dont emit anything in reducer
  }

  void cleanup(HadoopPipes::ReduceContext& context) {
    //emit key and value as 1
    context.emit(context.getInputKey(), HadoopUtils::toString(1));
  }
};

尽管作业成功运行，但它不会打印输出文件中的任何内容。做完全相同的事情，但在减速机发射完美的工作。
使用这个链接来实现java，效果非常好！
我是c++和管道的业余爱好者。