org.apache.kafka.streams.kstream

Interface Merger<K,V>

Type Parameters:

K - key type

V - aggregate value type

@InterfaceStability.Unstable
public interface Merger<K,V>

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

Method Summary

Methods

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