Package | Description |
---|---|
org.apache.flink.table.runtime.aggregate |
Class and Description |
---|
AggregateUtil$ |
DataSetPreAggFunction
GroupCombineFunction and MapPartitionFunction to compute pre-aggregates for batch
(DataSet) queries. |
DataSetSlideWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
DataSetTumbleTimeWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
GeneratedAggregations
Base class for code-generated aggregations.
|
IncrementalAggregateAllWindowFunction
Computes the final aggregate value from incrementally computed aggregates.
|
IncrementalAggregateWindowFunction
Computes the final aggregate value from incrementally computed aggreagtes.
|
ProcessFunctionWithCleanupState |
RowTimeUnboundedOver
A ProcessFunction to support unbounded event-time over-window
|
SingleElementIterable.SingleElementIterator |
TimeWindowPropertyCollector
Adds TimeWindow properties to specified fields of a row before it emits the row to a wrapped
collector.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.