com.hazelcast.jet.function

Interface KeyedWindowResultFunction<K,R,OUT>

Type Parameters:

K - type of the key

R - the type of aggregation result this function receives

OUT - the type of the output item this function returns

All Superinterfaces:

Serializable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface KeyedWindowResultFunction<K,R,OUT>
extends Serializable

Represents the function you pass to a windowed group-and-aggregate method in the Pipeline API, such as 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:

1. winStart and winEnd: the starting and ending timestamp of the window (the end timestamp is the exclusive upper bound)
2. key the grouping key
3. windowResult the result of the aggregate operation

Method Summary

Modifier and Type	Method and Description
OUT	apply(long winStart, long winEnd, K key, R windowResult)

Method Detail

apply

@Nonnull
OUT apply(long winStart,
                   long winEnd,
                   @Nonnull
                   K key,
                   @Nonnull
                   R windowResult)