1

私は Giraph でいくつかの基本的な例を実行していEdgeInputFormatます。古典的な MapReduce ジョブでは、カウンターを使用してそれを行うことができ、Giraph はこれにアグリゲーターを使用します。( https://giraph.apache.org/aggregators.html )

ウェブサイトには、アグリゲーターをマスターに登録する必要があると言われています。私が書いた唯一のコードはBasicComputation、compute() メソッドを拡張して実装するクラスです。誰かがそれらをどこに登録すればよいか、データの読み取り中にどのように使用するかを指摘できますか?

4

1 に答える 1

1

私はそれを行う方法を考え出しました。

拡張するクラスを実装MasterComputeし、initialize() メソッドで永続的なアグリゲーターを登録しました。使用しIntSumAggregatorました。

その後、でEdgeInputFormat使用できaggregate("myAggregator", new IntWritable(1));ました。

はline 引数MasterComputeを使用して設定されました。-mc

于 2014-06-12T14:33:47.443 に答える