| Modifier and Type | Method and Description |
|---|---|
default void |
MapReduce.addResultToMemory(Memory.Admin memory,
Iterator<KeyValue<RK,RV>> keyValues)
The final result can be generated and added to
Memory and accessible via DefaultComputerResult. |
R |
MapReduce.generateFinalResult(Iterator<KeyValue<RK,RV>> keyValues)
The key/value pairs emitted by reduce() (or map() in a map-only job) can be iterated to generate a local JVM Java object.
|
| Modifier and Type | Method and Description |
|---|---|
Integer |
ClusterCountMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Integer>> keyValues) |
Map<Serializable,Long> |
ClusterPopulationMapReduce.generateFinalResult(Iterator<KeyValue<Serializable,Long>> keyValues) |
| Modifier and Type | Method and Description |
|---|---|
Iterator<KeyValue<Object,Double>> |
PageRankMapReduce.generateFinalResult(Iterator<KeyValue<Object,Double>> keyValues) |
| Modifier and Type | Method and Description |
|---|---|
Iterator<KeyValue<Object,Double>> |
PageRankMapReduce.generateFinalResult(Iterator<KeyValue<Object,Double>> keyValues) |
| Modifier and Type | Method and Description |
|---|---|
default <K,V> Iterator<KeyValue<K,V>> |
Storage.head(String location,
String memoryKey,
Class readerClass)
Get the
KeyValue data at the specified memory location. |
<K,V> Iterator<KeyValue<K,V>> |
Storage.head(String location,
String memoryKey,
Class readerClass,
int totalLines)
Get the
KeyValue data at the specified memory location. |
Copyright © 2013–2020 Apache Software Foundation. All rights reserved.