org.apache.giraph.aggregators.matrix.sparse

Class DoubleSparseVectorSumAggregator

java.lang.Object

org.apache.giraph.aggregators.BasicAggregator<DoubleSparseVector>

org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVectorSumAggregator

All Implemented Interfaces:

Aggregator<DoubleSparseVector>

public class DoubleSparseVectorSumAggregator
extends BasicAggregator<DoubleSparseVector>

The double vector aggregator is used to aggregate double vectors.

Constructor Summary

Constructors

Constructor and Description
DoubleSparseVectorSumAggregator()

Method Summary

Modifier and Type	Method and Description
void	aggregate(DoubleSparseVector vector) Add a new value.
DoubleSparseVector	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

DoubleSparseVectorSumAggregator

public DoubleSparseVectorSumAggregator()

Method Detail

createInitialValue

public DoubleSparseVector 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

aggregate

public void aggregate(DoubleSparseVector vector)

Description copied from interface: Aggregator

Add a new value. Needs to be commutative and associative

Parameters:

vector - Value to be aggregated.