BulkIterationBase.TerminationCriterionAggregator (Flink : Core 1.20.2-cp1 API)

java.lang.Object
- org.apache.flink.api.common.operators.base.BulkIterationBase.TerminationCriterionAggregator

All Implemented Interfaces:

Serializable, Aggregator<LongValue>

Enclosing class:

BulkIterationBase<T>
```
public static class BulkIterationBase.TerminationCriterionAggregator
extends Object
implements Aggregator<LongValue>
```
Aggregator that basically only adds 1 for every output tuple of the termination criterion branch

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

TerminationCriterionAggregator()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`aggregate(long count)`
`void`	`aggregate(LongValue count)`	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
  - TerminationCriterionAggregator
```
public TerminationCriterionAggregator()
```
- 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(long count)
```
  - aggregate
```
public void aggregate(LongValue count)
```
    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:
    
    count - The element to 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>