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