org.apache.flink.api.java.aggregation

Class AggregationFunction<T>

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 and Description
AggregationFunction()

Method Summary

Modifier and Type	Method and 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()