com.hazelcast.jet.function

Interface KeyedWindowResult3Function<K,R0,R1,R2,OUT>

Type Parameters:

K - type of the key

R0 - type of the aggregated result from stream-0

R1 - type of the aggregated result from stream-1

R2 - type of the aggregated result from stream-2

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 KeyedWindowResult3Function<K,R0,R1,R2,OUT>
extends Serializable

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

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, R0 result0, R1 result1, R2 result2)

Method Detail

apply

@Nullable
OUT apply(long winStart,
                    long winEnd,
                    @Nonnull
                    K key,
                    @Nonnull
                    R0 result0,
                    @Nonnull
                    R1 result1,
                    @Nonnull
                    R2 result2)