Dear Mathew,
Pardon the late reply.
In my work, every vertex will have a score, I want to find the top-K scoring
vertexes.I planned to use an aggregator for this, here, I store my aggregated
value as Text, which stores the top-K vertex-id and their scores.
By the way, I have solved my problem in
HI Puneet,
What are you trying to do in getAggregatedValue()? Is there any reason you
don't just want to return the current value of the aggregator (which is
what the default implementation does)?
Best,
Matthew
On Sat, Sep 20, 2014 at 6:25 AM, Puneet Agarwal puagar...@yahoo.com wrote:
I have
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
