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 |
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 |
TraverserMapReduce |
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 | Class and Description |
---|---|
static class |
GroupCountStep.GroupCountMapReduce<E> |
static class |
GroupStep.GroupMapReduce<S,K,V> |
static class |
GroupStepV3d0.GroupMapReduceV3d0<K,V,R>
Deprecated.
|
static class |
TreeStep.TreeMapReduce |
Modifier and Type | Method and Description |
---|---|
MapReduce<K,Collection<V>,K,R,Map<K,R>> |
GroupStepV3d0.getMapReduce()
Deprecated.
|
MapReduce<MapReduce.NullObject,Long,MapReduce.NullObject,Long,Long> |
CountGlobalStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Number,MapReduce.NullObject,Number,Number> |
MaxGlobalStep.getMapReduce() |
MapReduce<E,Long,E,Long,Map<E,Long>> |
GroupCountStep.getMapReduce() |
MapReduce<Number,Long,Number,Long,Number> |
MeanGlobalStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Number,MapReduce.NullObject,Number,Number> |
MinGlobalStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Tree,MapReduce.NullObject,Tree,Tree> |
TreeStep.getMapReduce() |
MapReduce<K,Collection<?>,K,V,Map<K,V>> |
GroupStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Number,MapReduce.NullObject,Number,Number> |
SumGlobalStep.getMapReduce() |
Modifier and Type | Class and Description |
---|---|
static class |
AggregateStep.AggregateMapReduce |
static class |
GroupCountSideEffectStep.GroupCountSideEffectMapReduce<E> |
static class |
GroupSideEffectStep.GroupSideEffectMapReduce<S,K,V> |
static class |
GroupSideEffectStepV3d0.GroupSideEffectMapReduceV3d0<K,V,R>
Deprecated.
|
static class |
ProfileStep.ProfileMapReduce |
static class |
StoreStep.StoreMapReduce |
static class |
TreeSideEffectStep.TreeSideEffectMapReduce |
Modifier and Type | Method and Description |
---|---|
MapReduce<K,Collection<V>,K,R,Map<K,R>> |
GroupSideEffectStepV3d0.getMapReduce()
Deprecated.
|
MapReduce<MapReduce.NullObject,Object,MapReduce.NullObject,Object,Collection> |
AggregateStep.getMapReduce() |
MapReduce<E,Long,E,Long,Map<E,Long>> |
GroupCountSideEffectStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Tree,MapReduce.NullObject,Tree,Tree> |
TreeSideEffectStep.getMapReduce() |
MapReduce<MapReduce.NullObject,Object,MapReduce.NullObject,Object,Collection> |
StoreStep.getMapReduce() |
MapReduce<K,Collection<?>,K,V,Map<K,V>> |
GroupSideEffectStep.getMapReduce() |
MapReduce<MapReduce.NullObject,StandardTraversalMetrics,MapReduce.NullObject,StandardTraversalMetrics,StandardTraversalMetrics> |
ProfileStep.getMapReduce() |
Modifier and Type | Class and Description |
---|---|
static class |
ReducingBarrierStep.DefaultMapReduce |
Modifier and Type | Method and Description |
---|---|
MapReduce |
ReducingBarrierStep.getMapReduce() |
Modifier and Type | Method and Description |
---|---|
static <K,V> <any> |
SparkExecutor.executeMap(<any> graphRDD,
MapReduce<K,V,?,?,?> mapReduce,
Configuration apacheConfiguration) |
static <K,V,OK,OV> |
SparkExecutor.executeReduce(<any> mapOrCombineRDD,
MapReduce<K,V,OK,OV,?> mapReduce,
Configuration apacheConfiguration) |
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–2016 Apache Software Foundation. All rights reserved.