| Modifier and Type | Method and Description |
|---|---|
KeyValue |
ObjectWritableIterator.next() |
| Modifier and Type | Method and Description |
|---|---|
<K,V> Iterator<KeyValue<K,V>> |
FileSystemStorage.head(String location,
String memoryKey,
Class parserClass,
int totalLines) |
| 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. |
List<Integer> |
GraphComputerTest.MapReduceB.generateFinalResult(Iterator<KeyValue<Integer,Integer>> keyValues) |
List<Integer> |
GraphComputerTest.MapReduceBB.generateFinalResult(Iterator<KeyValue<Integer,Integer>> keyValues) |
MapReduce.NullObject |
GraphComputerTest.MapReduceC.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,MapReduce.NullObject>> keyValues) |
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 |
|---|---|
Iterator<Traverser<?>> |
TraverserMapReduce.generateFinalResult(Iterator<KeyValue<Comparable,Traverser<?>>> keyValues) |
| Modifier and Type | Method and Description |
|---|---|
Map<E,Long> |
GroupCountStep.GroupCountMapReduce.generateFinalResult(Iterator<KeyValue<E,Long>> keyValues) |
Map<K,R> |
GroupStepV3d0.GroupMapReduceV3d0.generateFinalResult(Iterator<KeyValue<K,R>> keyValues) |
Map<K,V> |
GroupStep.GroupMapReduce.generateFinalResult(Iterator<KeyValue<K,V>> keyValues) |
Tree |
TreeStep.TreeMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Tree>> keyValues) |
| Modifier and Type | Method and Description |
|---|---|
Map<E,Long> |
GroupCountSideEffectStep.GroupCountSideEffectMapReduce.generateFinalResult(Iterator<KeyValue<E,Long>> keyValues) |
Map<K,R> |
GroupSideEffectStepV3d0.GroupSideEffectMapReduceV3d0.generateFinalResult(Iterator<KeyValue<K,R>> keyValues) |
Map<K,V> |
GroupSideEffectStep.GroupSideEffectMapReduce.generateFinalResult(Iterator<KeyValue<K,V>> keyValues) |
Collection |
AggregateStep.AggregateMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Object>> keyValues) |
Collection |
StoreStep.StoreMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Object>> keyValues) |
StandardTraversalMetrics |
ProfileStep.ProfileMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,StandardTraversalMetrics>> keyValues) |
Tree |
TreeSideEffectStep.TreeSideEffectMapReduce.generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Tree>> keyValues) |
| Modifier and Type | Method and Description |
|---|---|
<K,V> Iterator<KeyValue<K,V>> |
SparkContextStorage.head(String location,
String memoryKey,
Class parserClass,
int totalLines) |
<K,V> Iterator<KeyValue<K,V>> |
PersistedOutputRDD.writeMemoryRDD(Configuration configuration,
String memoryKey,
<any> memoryRDD) |
default <K,V> Iterator<KeyValue<K,V>> |
OutputRDD.writeMemoryRDD(Configuration configuration,
String memoryKey,
<any> memoryRDD)
Write the sideEffect memoryRDD to an output location.
|
<K,V> Iterator<KeyValue<K,V>> |
OutputFormatRDD.writeMemoryRDD(Configuration configuration,
String memoryKey,
<any> memoryRDD) |
| Modifier and Type | Method and Description |
|---|---|
default <K,V> Iterator<KeyValue<K,V>> |
Storage.head(String location,
String memoryKey,
Class parserClass)
Get the
KeyValue data at the specified memory location. |
<K,V> Iterator<KeyValue<K,V>> |
Storage.head(String location,
String memoryKey,
Class parserClass,
int totalLines)
Get the
KeyValue data at the specified memory location. |
| Modifier and Type | Field and Description |
|---|---|
Queue<KeyValue<K,V>> |
TinkerMapEmitter.mapQueue |
protected Queue<KeyValue<OK,OV>> |
TinkerReduceEmitter.reduceQueue |
Copyright © 2013–2016 Apache Software Foundation. All rights reserved.