org.apache.flink.streaming.api.functions.aggregation

Class AggregationFunction<T>

java.lang.Object

org.apache.flink.streaming.api.functions.aggregation.AggregationFunction<T>

All Implemented Interfaces:

Serializable, Function, ReduceFunction<T>

Direct Known Subclasses:

ComparableAggregator, SumAggregator

@Internal
public abstract class AggregationFunction<T>
extends Object
implements ReduceFunction<T>

Holder class for aggregation types that can be used on a windowed stream or keyed stream.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AggregationFunction.AggregationType Aggregation types that can be used on a windowed stream or keyed stream.

Constructor Summary

Constructors

Constructor and Description
AggregationFunction()

Method Summary

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.functions.ReduceFunction

reduce

Constructor Detail

AggregationFunction

public AggregationFunction()