org.apache.giraph.examples

Class PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator

java.lang.Object

org.apache.giraph.aggregators.BasicAggregator<PageRankWithKryoSimpleWritable.VertexValue>

org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator

All Implemented Interfaces:

Aggregator<PageRankWithKryoSimpleWritable.VertexValue>

Enclosing class:

PageRankWithKryoSimpleWritable

public static class PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator
extends BasicAggregator<PageRankWithKryoSimpleWritable.VertexValue>

Aggregator for getting min double value.

Constructor Summary

Constructors

Constructor and Description
DoubleMinWrapperAggregator()

Method Summary

Modifier and Type	Method and Description
void	aggregate(PageRankWithKryoSimpleWritable.VertexValue value) Add a new value.
PageRankWithKryoSimpleWritable.VertexValue	createInitialValue() Return new aggregated value which is neutral to aggregate operation.

Methods inherited from class org.apache.giraph.aggregators.BasicAggregator

getAggregatedValue, reset, setAggregatedValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DoubleMinWrapperAggregator

public DoubleMinWrapperAggregator()

Method Detail

aggregate

public void aggregate(PageRankWithKryoSimpleWritable.VertexValue value)

Description copied from interface: Aggregator

Add a new value. Needs to be commutative and associative

Parameters:

value - Value to be aggregated.

createInitialValue

public PageRankWithKryoSimpleWritable.VertexValue createInitialValue()

Description copied from interface: Aggregator

Return new aggregated value which is neutral to aggregate operation. Must be changeable without affecting internals of Aggregator

Returns:

Neutral value