In
- Input value typeOut
- Output value typepublic interface Accumulator<In,Out>
extends java.io.Serializable
Modifier and Type | Method and Description |
---|---|
void |
accumulate(In value)
Accumulate another value.
|
void |
cleanup()
Resets the internal state so that all values accumulated so far are forgotten.
|
Out |
getFinal()
Get the output value corresponding to all input values accumulated so far.
|
void accumulate(In value)
value
- Value to accumulateOut getFinal()
This may return null to indicate no record should be written.
void cleanup()