hadoop - Hadoop 使用 C++ 管道：如何调用 Mapper.cleanup()

Question

使用 C++ 管道 api(1.2.0)，如何在映射器的 map() 阶段之后在 Mapper.cleanup() 中调用？基本上对于每个块，我想在映射阶段将我的记录存储在内存中，然后再应用一些处理。

欢迎任何提示，谢谢，

Answer 1

Mapper c++ 类扩展Closable：

class Mapper: public Closable {
public:
  virtual void map(MapContext& context) = 0;
};

并Closable具有以下签名：

class Closable {
public:
  virtual void close() {}
  virtual ~Closable() {}
};

所以（不是 C++ 程序员），我猜你只需要在一个名为的方法中编写你的逻辑close