hadoop使用c++管道：如何调用mapper.cleanup()

nle07wnf 于 2021-06-04 发布在 Hadoop

关注(0)|答案(1)|浏览(379)

使用c++pipes api（1.2.0），如何在Map器的map（）阶段之后在mapper.cleanup（）中获得调用？基本上，对于每个块，我希望在Map阶段将记录存储在内存中，然后应用一些处理。
欢迎任何提示，谢谢，

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