Class | Description |
---|---|
AggregateAggFunction |
Aggregate Function used for the aggregate operator in
WindowedStream |
AggregateUtil | |
AggregateUtil$ | |
CRowTimeWindowPropertyCollector | |
DataSetAggFunction |
RichGroupReduceFunction to compute aggregates that do not support pre-aggregation for batch
(DataSet) queries. |
DataSetFinalAggFunction |
RichGroupReduceFunction to compute the final result of a pre-aggregated aggregation
for batch (DataSet) queries. |
DataSetPreAggFunction |
GroupCombineFunction and MapPartitionFunction to compute pre-aggregates 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 time-windows.
|
DataSetSlideTimeWindowAggReduceGroupFunction |
It is used for sliding windows on batch for time-windows.
|
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 code-generated 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 proc-time OVER window
DataStream |
ProcTimeBoundedRowsOver |
Process Function for ROW clause processing-time bounded OVER window
|
ProcTimeUnboundedOver |
Process Function for processing-time unbounded OVER window
|
RowTimeBoundedRangeOver |
Process Function for RANGE clause event-time bounded OVER window
|
RowTimeBoundedRowsOver |
Process Function for ROWS clause event-time bounded OVER window
|
RowTimeUnboundedOver |
A ProcessFunction to support unbounded event-time over-window
|
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.