I have created my own aggregator, by extending the BasicAggregator.
In this aggregator I have overridden following methods
aggregate()
createInitialValue()
getAggregatedValue()
(The documentation says that we need to implement aggregate and
createInitialValue methods only, if so, how and what w
It got solved.
I was using the following api
arrayListVar.add(i, new Float(newVal))
while there existed another value at i position in the ArrayList.
I then changed the logic to add the value after ith position, it stopped giving
the out of memory error.
There seems to be some error message
http://www.manning.com/martella/I am not sure if there is any example in
documentation Claudio might know more.
From: khaled.am...@gmail.com
Date: Fri, 19 Sep 2014 02:11:45 -0400
Subject: looking for a User guide
To: user@giraph.apache.org
Hi all,
I was looking for a user guide for Giraph 1.0.0
Hi,
I wrote a code on Giraph 1.0.0 and using it with Hadoop 1.0.0
My program, uses an Aggregator to find the top-K vertices in some manner.
I am running this program only on 11 vertices.
I have written my own Aggregator class, which extends BasicAggregator
I have declared two instance variables