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 Detail

      • apply

        V apply​(K aggKey,
                V aggOne,
                V aggTwo)
        Compute a new aggregate from the key and two aggregates.
        aggKey - the key of the record
        aggOne - the first aggregate
        aggTwo - the second aggregate
        the new aggregate value