com.hazelcast.jet.function

Interface WindowResult2Function<R0,R1,OUT>

Type Parameters:

R0 - type of the aggregated result from stream-0

R1 - type of the aggregated result from stream-1

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 WindowResult2Function<R0,R1,OUT>
extends Serializable

Represents the function you pass to a windowed aggregation method in the Pipeline API, such as stage.aggregate2(), that aggregates two input streams. It creates the item to emit based on the two results of the aggregate operation performed for a particular window.

The parameters are:

1. winStart and winEnd: the starting and ending timestamp of the window (the end timestamp is the exclusive upper bound)
2. result0 aggregated result of input stream-0
3. result1 aggregated result of input stream-1

Method Summary

Modifier and Type	Method and Description
OUT	apply(long start, long end, R0 result0, R1 result1)
default KeyedWindowResult2Function<Object,R0,R1,OUT>	toKeyedWindowResult2Fn()

Method Detail

apply

@Nullable
OUT apply(long start,
                    long end,
                    @Nonnull
                    R0 result0,
                    @Nonnull
                    R1 result1)

toKeyedWindowResult2Fn

default KeyedWindowResult2Function<Object,R0,R1,OUT> toKeyedWindowResult2Fn()