public final class ReducerState<T,R>
extends java.lang.Object
Constructor and Description |
---|
ReducerState(java.util.stream.Collector<T,java.lang.Object,R> collector) |
Modifier and Type | Method and Description |
---|---|
java.util.stream.Collector<T,java.lang.Object,R> |
collector()
INTERNAL API
|
R |
finish() |
ReducerState<T,R> |
update(java.lang.Object batch) |