private static class MapReduceManagerImpl.DefaultCollector<KOut,VOut> extends java.lang.Object implements MapReduceManagerImpl.CollectableCollector<KOut,VOut>
Modifier and Type | Field and Description |
---|---|
private java.util.Map<KOut,java.util.List<VOut>> |
store |
Modifier | Constructor and Description |
---|---|
private |
MapReduceManagerImpl.DefaultCollector() |
private MapReduceManagerImpl.DefaultCollector()
public void emit(KOut key, VOut value)
Collector
Mapper
implementorpublic java.util.Map<KOut,java.util.List<VOut>> collectedValues()
collectedValues
in interface MapReduceManagerImpl.CollectableCollector<KOut,VOut>