K
- type of the keyR0
- type of the aggregated result from stream-0R1
- type of the aggregated result from stream-1R2
- type of the aggregated result from stream-2OUT
- the type of the output item this function returns@FunctionalInterface public interface KeyedWindowResult3Function<K,R0,R1,R2,OUT> extends Serializable
stage.aggregate3()
.
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,
R0 result0,
R1 result1,
R2 result2) |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.