org.apache.giraph.aggregators

Class BasicAggregator<A extends org.apache.hadoop.io.Writable>

java.lang.Object

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

Type Parameters:

A - Aggregated value

All Implemented Interfaces:

Aggregator<A>

Direct Known Subclasses:

BooleanAndAggregator, BooleanOrAggregator, BooleanOverwriteAggregator, DoubleDenseVectorSumAggregator, DoubleMaxAggregator, DoubleMinAggregator, DoubleOverwriteAggregator, DoubleProductAggregator, DoubleSparseVectorSumAggregator, DoubleSumAggregator, FloatDenseVectorSumAggregator, FloatMaxAggregator, FloatMinAggregator, FloatOverwriteAggregator, FloatProductAggregator, FloatSparseVectorSumAggregator, FloatSumAggregator, IntDenseVectorSumAggregator, IntMaxAggregator, IntMinAggregator, IntOverwriteAggregator, IntProductAggregator, IntSparseVectorSumAggregator, IntSumAggregator, LongDenseVectorSumAggregator, LongMaxAggregator, LongMinAggregator, LongOverwriteAggregator, LongProductAggregator, LongSparseVectorSumAggregator, LongSumAggregator, PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator, PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator, TextAppendAggregator

public abstract class BasicAggregator<A extends org.apache.hadoop.io.Writable>
extends Object
implements Aggregator<A>

Abstract class for Aggregator. Implements get value, set value and reset methods and has internal value object.

Constructor Summary

Constructors

Constructor and Description
BasicAggregator() Default constructor.
BasicAggregator(A initialValue) Constructor

Method Summary

Modifier and Type	Method and Description
A	getAggregatedValue() Return current aggregated value.
void	reset() Reset the value of aggregator to neutral value
void	setAggregatedValue(A value) Set aggregated value.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.giraph.aggregators.Aggregator

aggregate, createInitialValue

Constructor Detail

BasicAggregator

public BasicAggregator()

Default constructor. Creates new value object and resets the aggregator

BasicAggregator

public BasicAggregator(A initialValue)

Constructor

Parameters:

initialValue - initial value

Method Detail

getAggregatedValue

public A getAggregatedValue()

Description copied from interface: Aggregator

Return current aggregated value. Needs to be initialized if aggregate or setAggregatedValue have not been called before.

Specified by:

getAggregatedValue in interface Aggregator<A extends org.apache.hadoop.io.Writable>

Returns:

Aggregated

setAggregatedValue

public void setAggregatedValue(A value)

Description copied from interface: Aggregator

Set aggregated value. Can be used for initialization or reset.

Specified by:

setAggregatedValue in interface Aggregator<A extends org.apache.hadoop.io.Writable>

Parameters:

value - Value to be set.

reset

public void reset()

Description copied from interface: Aggregator

Reset the value of aggregator to neutral value

Specified by:

reset in interface Aggregator<A extends org.apache.hadoop.io.Writable>