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–2019 Apache Software Foundation. All rights reserved.