R
- the type of aggregation result this function receivesOUT
- the type of the output item this function returns@FunctionalInterface public interface WindowResultFunction<R,OUT> extends Serializable
stage.aggregate()
.
It creates the item to emit based on the results of a single aggregate
operation performed for a particular window.
The parameters are:
winStart
and winEnd
: the starting and ending timestamp
of the window (the end timestamp is the exclusive upper bound)
windowResult
the result of the aggregate operation
Modifier and Type | Method and Description |
---|---|
OUT |
apply(long start,
long end,
R result) |
default KeyedWindowResultFunction<Object,R,OUT> |
toKeyedWindowResultFn() |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.