org.apache.kafka.streams.kstream

Interface Merger<K,V>

Type Parameters:

K - key type

V - aggregate value type

public interface Merger<K,V>

The interface for merging aggregate values for SessionWindows with the given key.

Method Summary

Modifier and Type	Method and Description
V	apply(K aggKey, V aggOne, V aggTwo) Compute a new aggregate from the key and two aggregates.

Method Detail

apply

V apply(K aggKey,
        V aggOne,
        V aggTwo)

Compute a new aggregate from the key and two aggregates.

Parameters:

aggKey - the key of the record

aggOne - the first aggregate

aggTwo - the second aggregate

Returns:

the new aggregate value