Interface KeyedWindowResultFunction<K,R,OUT>

Type Parameters:
K - type of the key
R - the type of aggregation result this function receives
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 KeyedWindowResultFunction<K,R,OUT> extends Serializable
Represents the function you pass to windowing processors such as aggregateToSlidingWindowP() and aggregateToSessionWindowP() as mapToOutputFn. It creates the item to emit based on the results of a single aggregate operation performed for a particular window and a particular grouping key.
Since:
Jet 3.0
  • Method Summary

    Modifier and Type
    Method
    Description
    apply(long winStart, long winEnd, K key, R windowResult, boolean isEarly)
    Applies the function to the given arguments
  • Method Details

    • apply

      @Nullable OUT apply(long winStart, long winEnd, @Nonnull K key, @Nonnull R windowResult, boolean isEarly)
      Applies the function to the given arguments
      Parameters:
      winStart - the inclusive lower timestamp of the window
      winEnd - the exclusive upper timestamp of the window
      key - the grouping key
      windowResult - the result of the aggregate operation
      isEarly - whether the result is an early result as specified by WindowDefinition.setEarlyResultsPeriod(long)
      Returns:
      the function result