com.hazelcast.aggregation.impl

Class FixedSumAggregator<I>

java.lang.Object

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

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

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

All Implemented Interfaces:

Serializable

public class FixedSumAggregator<I>
extends AbstractAggregator<I,Long>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FixedSumAggregator()
FixedSumAggregator(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.

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

FixedSumAggregator

public FixedSumAggregator()

FixedSumAggregator

public FixedSumAggregator(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.