Package org.apache.flink.api.common.aggregators

Class LongSumAggregator

java.lang.Object

org.apache.flink.api.common.aggregators.LongSumAggregator

All Implemented Interfaces:

Serializable, Aggregator<LongValue>

@PublicEvolving
public class LongSumAggregator
extends Object
implements Aggregator<LongValue>

An Aggregator that sums up long values.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
LongSumAggregator()

Method Summary

Modifier and Type	Method	Description
void	aggregate(long value)	Adds the given value to the current aggregate.
void	aggregate(LongValue element)	Aggregates the given element.
LongValue	getAggregate()	Gets the aggregator's current aggregate.
void	reset()	Resets the internal state of the aggregator.

Methods inherited from class java.lang.Object

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

Constructor Detail

LongSumAggregator

public LongSumAggregator()

Method Detail

getAggregate

public LongValue getAggregate()

Description copied from interface: Aggregator

Gets the aggregator's current aggregate.

Specified by:

getAggregate in interface Aggregator<LongValue>

Returns:

The aggregator's current aggregate.

aggregate

public void aggregate(LongValue element)

Description copied from interface: Aggregator

Aggregates the given element. In the case of a sum aggregator, this method adds the given value to the sum.

Specified by:

aggregate in interface Aggregator<LongValue>

Parameters:

element - The element to aggregate.

aggregate

public void aggregate(long value)

Adds the given value to the current aggregate.

Parameters:

value - The value to add to the aggregate.

reset

public void reset()

Description copied from interface: Aggregator

Resets the internal state of the aggregator. This must bring the aggregator into the same state as if it was newly initialized.

Specified by:

reset in interface Aggregator<LongValue>