Package | Description |
---|---|
org.apache.flink.table.runtime.aggregate |
Modifier and Type | Class and Description |
---|---|
class |
GroupAggProcessFunction
Aggregate Function used for the groupby (without window) aggregate
|
class |
ProcTimeBoundedRangeOver
Process Function used for the aggregate in bounded proc-time OVER window
DataStream |
class |
ProcTimeBoundedRowsOver
Process Function for ROW clause processing-time bounded OVER window
|
class |
ProcTimeUnboundedOver
Process Function for processing-time unbounded OVER window
|
class |
RowTimeBoundedRangeOver
Process Function for RANGE clause event-time bounded OVER window
|
class |
RowTimeBoundedRowsOver
Process Function for ROWS clause event-time bounded OVER window
|
class |
RowTimeUnboundedOver
A ProcessFunction to support unbounded event-time over-window
|
class |
RowTimeUnboundedRangeOver
A ProcessFunction to support unbounded RANGE window.
|
class |
RowTimeUnboundedRowsOver
A ProcessFunction to support unbounded ROWS window.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.