| 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,
               org.apache.commons.configuration2.Configuration configuration)A helper method to construct a  MapReducegiven 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  MapReducejobs that are associated with theVertexProgram. | 
| Modifier and Type | Method and Description | 
|---|---|
| GraphComputer | GraphComputer. mapReduce(MapReduce mapReduce)Add a  MapReducejob to the set of MapReduce jobs to be executed by theGraphComputer. | 
| 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 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–2022 Apache Software Foundation. All rights reserved.