Package org.apache.kafka.streams.kstream

Interface Merger<K,V>

Type Parameters:
K - key type
V - aggregate value type
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 Merger<K,V>
The interface for merging aggregate values for SessionWindows with the given key.

  • Method Summary

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

  • Method Details

    • 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