| Class | Description |
|---|---|
| Aggregation<PAYLOAD,META> | |
| CombinedMetaPayloadFunction<AIN,AOUT,BIN,BOUT,AM,BM> |
Given a combined stream (i.e.
|
| ContextRealTimeWindowFunction<IN> |
Given a period of time to wait in milliseconds, this function consumes
a stream for that period of time and produces a new stream of lists representing windows of that time period
|
| MetaPayload<PAYLOAD,META> |
A payload with metadata
|
| MetaPayloadStreamCombiner<AP,AM,BP,BM> |
A stream combiner takes two streams and produces a new stream of syncrhonised
pairs of the stream values.
|
| RealTimeWindowFunction<IN> |
Given a period of time to wait in milliseconds, this function consumes
a stream for that period of time and produces a new stream of lists representing windows of that time period
|
| SequentialStreamAggregator<T> | |
| Window<PAYLOAD,META> | |
| WindowAverage |
Given a window of key,value map instances, this function gets the average of
the window
|
| WindowFilter<IN,META> | |
| WindowFunction<IN,OUT,META> |