com.hazelcast.aggregation.impl

Class IntegerSumAggregator<I>

java.lang.Object

com.hazelcast.aggregation.Aggregator<I,R>

com.hazelcast.aggregation.impl.AbstractAggregator<I,Long>

com.hazelcast.aggregation.impl.IntegerSumAggregator<I>

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable, Serializable

public final class IntegerSumAggregator<I>
extends AbstractAggregator<I,Long>
implements IdentifiedDataSerializable

See Also:

Serialized Form

Field Summary

Fields inherited from class com.hazelcast.aggregation.impl.AbstractAggregator

attributePath

Constructor Summary

Constructors

Constructor and Description
IntegerSumAggregator()
IntegerSumAggregator(String attributePath)

Method Summary

Modifier and Type	Method and Description
void	accumulate(I entry) Accumulates the given entries.
Long	aggregate() Returns the result of the aggregation.
void	combine(Aggregator aggregator) Incorporates the intermediary result of the given aggregator to this instance of the aggregator.
int	getFactoryId() Returns DataSerializableFactory factory id for this class.
int	getId() Returns type identifier for this class.
void	readData(ObjectDataInput in) Reads fields from the input stream
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class com.hazelcast.aggregation.impl.AbstractAggregator

extract

Methods inherited from class com.hazelcast.aggregation.Aggregator

onAccumulationFinished, onCombinationFinished

Methods inherited from class java.lang.Object

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

Constructor Detail

IntegerSumAggregator

public IntegerSumAggregator()

IntegerSumAggregator

public IntegerSumAggregator(String attributePath)

Method Detail

accumulate

public void accumulate(I entry)

Description copied from class: Aggregator

Accumulates the given entries.

Specified by:

accumulate in class Aggregator<I,Long>

Parameters:

entry - input to accumulate.

combine

public void combine(Aggregator aggregator)

Description copied from class: Aggregator

Incorporates the intermediary result of the given aggregator to this instance of the aggregator. The given aggregator has to be of the same class as the one that the method is being called on. Enables merging the intermediary state from a given aggregator. It is used when the aggregation is split into a couple of aggregators.

Specified by:

combine in class Aggregator<I,Long>

Parameters:

aggregator - aggregator providing intermediary results to be combined into the results of this aggregator. The given aggregator has to be of the same class as the one that the method is being called on.

aggregate

public Long aggregate()

Description copied from class: Aggregator

Returns the result of the aggregation. The result may be calculated in this call or cached by the aggregator.

Specified by:

aggregate in class Aggregator<I,Long>

Returns:

returns the result of the aggregation.

getFactoryId

public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory id for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Returns:

factory id

getId

public int getId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. Id should be unique per DataSerializableFactory.

Specified by:

getId in interface IdentifiedDataSerializable

Returns:

type id

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException