K
- type of the keyR
- the type of aggregation result this function receivesOUT
- the type of the output item this function returns@FunctionalInterface public interface KeyedWindowResultFunction<K,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 and a particular grouping
key.
The parameters are:
winStart
and winEnd
: the starting and ending timestamp
of the window (the end timestamp is the exclusive upper bound)
key
the grouping key
windowResult
the result of the aggregate operation
Modifier and Type | Method and Description |
---|---|
OUT |
apply(long winStart,
long winEnd,
K key,
R windowResult) |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.