| Modifier and Type | Field and Description | 
|---|---|
protected Set<MapReduce> | 
AbstractHadoopGraphComputer.mapReducers  | 
| Modifier and Type | Method and Description | 
|---|---|
GraphComputer | 
AbstractHadoopGraphComputer.mapReduce(MapReduce mapReduce)  | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
MapReduceHelper.executeMapReduceJob(MapReduce mapReduce,
                   Memory.Admin memory,
                   Configuration configuration)  | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
GraphComputerTest.MapReduceB  | 
static class  | 
GraphComputerTest.MapReduceBB  | 
static class  | 
GraphComputerTest.MapReduceC  | 
static class  | 
GraphComputerTest.MapReduceK  | 
| Modifier and Type | Method and Description | 
|---|---|
static <M extends MapReduce> | 
MapReduce.createMapReduce(Graph graph,
               Configuration configuration)
A helper method to construct a  
MapReduce given the content of the supplied configuration. | 
| Modifier and Type | Method and Description | 
|---|---|
MapReduce<MK,MV,RK,RV,R> | 
MapReduce.clone()
When multiple workers on a single machine need MapReduce instances, it is possible to use clone. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
default Set<MapReduce> | 
VertexProgram.getMapReducers()
The set of  
MapReduce jobs that are associated with the VertexProgram. | 
| Modifier and Type | Method and Description | 
|---|---|
GraphComputer | 
GraphComputer.mapReduce(MapReduce mapReduce)
Add a  
MapReduce job to the set of MapReduce jobs to be executed by the GraphComputer. | 
GraphComputer | 
GraphComputerTest.BadGraphComputer.mapReduce(MapReduce mapReduce)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ClusterCountMapReduce  | 
class  | 
ClusterPopulationMapReduce  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
PageRankMapReduce  | 
| Modifier and Type | Method and Description | 
|---|---|
Set<MapReduce> | 
TraversalVertexProgram.getMapReducers()  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
StaticMapReduce<MK,MV,RK,RV,R>  | 
| Modifier and Type | Method and Description | 
|---|---|
MapReduce<MK,MV,RK,RV,R> | 
StaticMapReduce.clone()  | 
MapReduce | 
MapReducePool.take()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MapMemory.addMapReduceMemoryKey(MapReduce mapReduce)  | 
static boolean | 
GraphComputerHelper.areEqual(MapReduce a,
        Object b)  | 
void | 
MapReducePool.offer(MapReduce<?,?,?,?,?> mapReduce)  | 
| Constructor and Description | 
|---|
MapReducePool(MapReduce mapReduce,
             int poolSize)  | 
| Modifier and Type | Method and Description | 
|---|---|
MapReduce<MK,MV,RK,RV,R> | 
MapReducer.getMapReduce()  | 
| Modifier and Type | Method and Description | 
|---|---|
static <K,V> <any> | 
SparkExecutor.executeMap(<any> graphRDD,
          MapReduce<K,V,?,?,?> mapReduce,
          Configuration graphComputerConfiguration)  | 
static <K,V,OK,OV> | 
SparkExecutor.executeReduce(<any> mapOrCombineRDD,
             MapReduce<K,V,OK,OV,?> mapReduce,
             Configuration graphComputerConfiguration)  | 
| Constructor and Description | 
|---|
CombineIterator(MapReduce<K,V,OK,OV,?> mapReduce,
               Iterator<<any>> inputIterator)  | 
MapIterator(MapReduce<K,V,?,?,?> mapReduce,
           Iterator<<any>> inputIterator)  | 
ReduceIterator(MapReduce<K,V,OK,OV,?> mapReduce,
              Iterator<<any>> inputIterator)  | 
| Constructor and Description | 
|---|
SparkMemory(VertexProgram<?> vertexProgram,
           Set<MapReduce> mapReducers,
           JavaSparkContext sparkContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
StringFactory.mapReduceString(MapReduce mapReduce)  | 
static String | 
StringFactory.mapReduceString(MapReduce mapReduce,
               String internalString)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
TinkerReduceEmitter.complete(MapReduce<?,?,OK,OV,?> mapReduce)  | 
protected void | 
TinkerMapEmitter.complete(MapReduce<K,V,?,?,?> mapReduce)  | 
GraphComputer | 
TinkerGraphComputer.mapReduce(MapReduce mapReduce)  | 
void | 
TinkerWorkerPool.setMapReduce(MapReduce mapReduce)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TinkerWorkerPool.executeMapReduce(Consumer<MapReduce> worker)  | 
| Constructor and Description | 
|---|
TinkerMemory(VertexProgram<?> vertexProgram,
            Set<MapReduce> mapReducers)  | 
Copyright © 2013–2021 Apache Software Foundation. All rights reserved.