| 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  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  | 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<MapReduce.NullObject,Long,MapReduce.NullObject,Long,Long> | CountGlobalStep. getMapReduce() | 
| MapReduce<E,Long,E,Long,Map<E,Long>> | GroupCountStep. getMapReduce() | 
| MapReduce<K,Collection<?>,K,V,Map<K,V>> | GroupStep. getMapReduce() | 
| MapReduce<K,Collection<V>,K,R,Map<K,R>> | GroupStepV3d0. getMapReduce()Deprecated.  | 
| MapReduce<MapReduce.NullObject,Number,MapReduce.NullObject,Number,Number> | MaxGlobalStep. getMapReduce() | 
| MapReduce<Number,Long,Number,Long,Number> | MeanGlobalStep. getMapReduce() | 
| MapReduce<MapReduce.NullObject,Number,MapReduce.NullObject,Number,Number> | MinGlobalStep. getMapReduce() | 
| MapReduce<MapReduce.NullObject,Number,MapReduce.NullObject,Number,Number> | SumGlobalStep. getMapReduce() | 
| MapReduce<MapReduce.NullObject,Tree,MapReduce.NullObject,Tree,Tree> | TreeStep. 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<MapReduce.NullObject,Object,MapReduce.NullObject,Object,Collection> | AggregateStep. getMapReduce() | 
| MapReduce<E,Long,E,Long,Map<E,Long>> | GroupCountSideEffectStep. getMapReduce() | 
| MapReduce<K,Collection<?>,K,V,Map<K,V>> | GroupSideEffectStep. getMapReduce() | 
| MapReduce<K,Collection<V>,K,R,Map<K,R>> | GroupSideEffectStepV3d0. getMapReduce()Deprecated.  | 
| MapReduce<MapReduce.NullObject,StandardTraversalMetrics,MapReduce.NullObject,StandardTraversalMetrics,StandardTraversalMetrics> | ProfileStep. getMapReduce() | 
| MapReduce<MapReduce.NullObject,Object,MapReduce.NullObject,Object,Collection> | StoreStep. getMapReduce() | 
| MapReduce<MapReduce.NullObject,Tree,MapReduce.NullObject,Tree,Tree> | TreeSideEffectStep. 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 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–2015 Apache Software Foundation. All rights reserved.