Combiner.Input<KI,VI>
Constructor and Description |
---|
SummingCombiner() |
Modifier and Type | Method and Description |
---|---|
Optional<Long> |
combine(Combiner.Input<K,Long> input)
This function is called to combine the current value of a key with updates that were queued for
the key.
|
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.