DoubleSumAggregator (Flink : Core 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.api.common.aggregators.DoubleSumAggregator

All Implemented Interfaces:

Serializable, Aggregator<DoubleValue>
```
@PublicEvolving
public class DoubleSumAggregator
extends Object
implements Aggregator<DoubleValue>
```
An Aggregator that sums up DoubleValue values.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

DoubleSumAggregator()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`aggregate(double value)`	Adds the given value to the current aggregate.
`void`	`aggregate(DoubleValue element)`	Aggregates the given element.
`DoubleValue`	`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
  - DoubleSumAggregator
```
public DoubleSumAggregator()
```
- Method Detail
  - getAggregate
```
public DoubleValue getAggregate()
```
    Description copied from interface: Aggregator
    
    Gets the aggregator's current aggregate.
    
    Specified by:
    
    getAggregate in interface Aggregator<DoubleValue>
    
    Returns:
    
    The aggregator's current aggregate.
  - aggregate
```
public void aggregate(DoubleValue 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<DoubleValue>
    
    Parameters:
    
    element - The element to aggregate.
  - aggregate
```
public void aggregate(double 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<DoubleValue>