public static final class TreeSideEffectStep.TreeSideEffectMapReduce extends StaticMapReduce<MapReduce.NullObject,Tree,MapReduce.NullObject,Tree,Tree>
MapReduce.MapEmitter<K,V>, MapReduce.NullObject, MapReduce.ReduceEmitter<OK,OV>, MapReduce.Stage| Modifier and Type | Field and Description | 
|---|---|
| static String | TREE_SIDE_EFFECT_STEP_SIDE_EFFECT_KEY | 
MAP_REDUCE| Constructor and Description | 
|---|
| TreeSideEffectMapReduce(TreeSideEffectStep step) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | combine(MapReduce.NullObject key,
       Iterator<Tree> values,
       MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter)The combine() method is logically executed at all "machines" in parallel. | 
| boolean | doStage(MapReduce.Stage stage)A MapReduce job can be map-only, map-reduce-only, or map-combine-reduce. | 
| Tree | generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Tree>> keyValues)The key/value pairs emitted by reduce() (or map() in a map-only job) can be iterated to generate a local JVM Java object. | 
| String | getMemoryKey()The results of the MapReduce job are associated with a memory-key to ultimately be stored in  Memory. | 
| void | loadState(Graph graph,
         Configuration configuration)When it is necessary to load the state of a MapReduce job, this method is called. | 
| void | map(Vertex vertex,
   MapReduce.MapEmitter<MapReduce.NullObject,Tree> emitter)The map() method is logically executed at all vertices in the graph in parallel. | 
| void | reduce(MapReduce.NullObject key,
      Iterator<Tree> values,
      MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter)The reduce() method is logically on the "machine" the respective key hashes to. | 
| void | storeState(Configuration configuration)When it is necessary to store the state of a MapReduce job, this method is called. | 
clone, equals, hashCode, toStringfinalize, getClass, notify, notifyAll, wait, wait, waitaddResultToMemory, createMapReduce, getMapKeySort, getReduceKeySort, workerEnd, workerStartpublic static final String TREE_SIDE_EFFECT_STEP_SIDE_EFFECT_KEY
public TreeSideEffectMapReduce(TreeSideEffectStep step)
public void storeState(Configuration configuration)
MapReducestoreState in interface MapReduce<MapReduce.NullObject,Tree,MapReduce.NullObject,Tree,Tree>storeState in class StaticMapReduce<MapReduce.NullObject,Tree,MapReduce.NullObject,Tree,Tree>configuration - the configuration to store the state of the MapReduce job in.public void loadState(Graph graph, Configuration configuration)
MapReducegraph - the graph the MapReduce job will run againstconfiguration - the configuration to load the state of the MapReduce job from.public boolean doStage(MapReduce.Stage stage)
MapReducestage - the stage to check for definition.public void map(Vertex vertex, MapReduce.MapEmitter<MapReduce.NullObject,Tree> emitter)
MapReducevertex - the current vertex being map() processed.emitter - the component that allows for key/value pairs to be emitted to the next stage.public void combine(MapReduce.NullObject key, Iterator<Tree> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter)
MapReducekey - the key that has aggregated valuesvalues - the aggregated values associated with the keyemitter - the component that allows for key/value pairs to be emitted to the reduce stage.public void reduce(MapReduce.NullObject key, Iterator<Tree> values, MapReduce.ReduceEmitter<MapReduce.NullObject,Tree> emitter)
MapReducekey - the key that has aggregated valuesvalues - the aggregated values associated with the keyemitter - the component that allows for key/value pairs to be emitted as the final result.public Tree generateFinalResult(Iterator<KeyValue<MapReduce.NullObject,Tree>> keyValues)
MapReducekeyValues - the key/value pairs that were emitted from reduce() (or map() in a map-only job)Copyright © 2013–2015 Apache Software Foundation. All rights reserved.