Package org.apache.kafka.streams.kstream
Interface Reducer<V>
-
- Type Parameters:
V- value type
public interface Reducer<V>TheReducerinterface for combining two values of the same type into a new value. In contrast toAggregatorthe result type must be the same as the input type.The provided values can be either original values from input
KeyValuepair records or be a previously computed result fromapply(Object, Object).Reducercan be used to implement aggregation functions like sum, min, or max.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Vapply(V value1, V value2)Aggregate the two given values into a single one.
-