hadoop - C++ パイプを使用する Hadoop: 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