AggregationFunction (Flink : Java 1.19.2-cp2 API)

java.lang.Object
- org.apache.flink.api.java.aggregation.AggregationFunction<T>

Type Parameters:

T - The type to be aggregated.

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

MaxAggregationFunction, MinAggregationFunction, SumAggregationFunction
```
@Internal
public abstract class AggregationFunction<T>
extends Object
implements Serializable
```
See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

AggregationFunction()

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`abstract void`	`aggregate(T value)`
`abstract T`	`getAggregate()`
`abstract void`	`initializeAggregate()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- AggregationFunction
```
public AggregationFunction()
```

Method Detail

initializeAggregate

public abstract void initializeAggregate()

aggregate

public abstract void aggregate(T value)

getAggregate
```
public abstract T getAggregate()
```