Class  Description 

AggregateAggFunction 
Aggregate Function used for the aggregate operator in
WindowedStream 
AggregateUtil  
AggregateUtil$  
CRowTimeWindowPropertyCollector  
DataSetAggFunction 
RichGroupReduceFunction to compute aggregates that do not support preaggregation for batch
(DataSet) queries. 
DataSetFinalAggFunction 
RichGroupReduceFunction to compute the final result of a preaggregated aggregation
for batch (DataSet) queries. 
DataSetPreAggFunction 
GroupCombineFunction and MapPartitionFunction to compute preaggregates for batch
(DataSet) queries. 
DataSetSessionWindowAggReduceGroupFunction 
It wraps the aggregate logic inside of
GroupReduceOperator . 
DataSetSessionWindowAggregatePreProcessor 
This wraps the aggregate logic inside of
GroupCombineOperator . 
DataSetSlideTimeWindowAggFlatMapFunction 
It is used for sliding windows on batch for timewindows.

DataSetSlideTimeWindowAggReduceGroupFunction 
It is used for sliding windows on batch for timewindows.

DataSetSlideWindowAggReduceCombineFunction 
Wraps the aggregate logic inside of
GroupReduceOperator and
GroupCombineOperator . 
DataSetSlideWindowAggReduceGroupFunction 
It wraps the aggregate logic inside of
GroupReduceOperator . 
DataSetTumbleCountWindowAggReduceGroupFunction 
It wraps the aggregate logic inside of
GroupReduceOperator . 
DataSetTumbleTimeWindowAggReduceCombineFunction 
It wraps the aggregate logic inside of
GroupReduceOperator and
GroupCombineOperator . 
DataSetTumbleTimeWindowAggReduceGroupFunction 
It wraps the aggregate logic inside of
GroupReduceOperator . 
DataSetWindowAggMapFunction 
This map function only works for windows on batch tables.

DistinctReduce  
GeneratedAggregations 
Base class for codegenerated aggregations.

GroupAggProcessFunction 
Aggregate Function used for the groupby (without window) aggregate

IncrementalAggregateAllTimeWindowFunction 
Computes the final aggregate value from incrementally computed aggregates.

IncrementalAggregateAllWindowFunction<W extends Window> 
Computes the final aggregate value from incrementally computed aggregates.

IncrementalAggregateTimeWindowFunction 
Computes the final aggregate value from incrementally computed aggreagtes.

IncrementalAggregateWindowFunction<W extends Window> 
Computes the final aggregate value from incrementally computed aggreagtes.

ProcessFunctionWithCleanupState<IN,OUT>  
ProcTimeBoundedRangeOver 
Process Function used for the aggregate in bounded proctime OVER window
DataStream 
ProcTimeBoundedRowsOver 
Process Function for ROW clause processingtime bounded OVER window

ProcTimeUnboundedOver 
Process Function for processingtime unbounded OVER window

RowTimeBoundedRangeOver 
Process Function for RANGE clause eventtime bounded OVER window

RowTimeBoundedRowsOver 
Process Function for ROWS clause eventtime bounded OVER window

RowTimeUnboundedOver 
A ProcessFunction to support unbounded eventtime overwindow

RowTimeUnboundedRangeOver 
A ProcessFunction to support unbounded RANGE window.

RowTimeUnboundedRowsOver 
A ProcessFunction to support unbounded ROWS window.

RowTimeWindowPropertyCollector  
SingleElementIterable<T>  
TimeWindowPropertyCollector<T> 
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.