Package | Description |
---|---|
org.apache.flink.table.runtime.aggregate |
Class and Description |
---|
Aggregate
The interface for all Flink aggregate functions, which expressed in terms of initiate(),
prepare(), merge() and evaluate().
|
AggregateAllWindowFunction |
AggregateReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
AggregateUtil$ |
AggregateWindowFunction |
AvgAggregate |
FloatingAvgAggregate |
IncrementalAggregateAllWindowFunction
Computes the final aggregate value from incrementally computed aggreagtes.
|
IncrementalAggregateReduceFunction
Incrementally computes group window aggregates.
|
IncrementalAggregateWindowFunction
Computes the final aggregate value from incrementally computed aggreagtes.
|
IntegralAvgAggregate |
MaxAggregate |
MinAggregate |
SumAggregate |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.