K- type of the key
R- the type of aggregation result this function receives
OUT- the type of the output item this function returns
@FunctionalInterface public interface KeyedWindowResultFunction<K,R,OUT> extends Serializable
mapToOutputFn. 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.
@Nullable OUT apply(long winStart, long winEnd, @Nonnull K key, @Nonnull R windowResult, boolean isEarly)
winStart- the inclusive lower timestamp of the window
winEnd- the exclusive upper timestamp of the window
key- the grouping key
windowResult- the result of the aggregate operation
isEarly- whether the result is an early result as specified by
Copyright © 2022 Hazelcast, Inc.. All rights reserved.