| Modifier and Type | Method and Description |
|---|---|
static <M extends MapReduce> |
MapReduce.createMapReduce(Graph graph,
org.apache.commons.configuration.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. |
| 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) |
Copyright © 2013–2020 Apache Software Foundation. All rights reserved.