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的方法编写逻辑即可