Modifier and Type | Method and Description |
---|---|
static MapReduce.Stage |
MapReduce.Stage.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static MapReduce.Stage[] |
MapReduce.Stage.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MapReduce.doStage(MapReduce.Stage stage)
A MapReduce job can be map-only, map-reduce-only, or map-combine-reduce.
|
boolean |
GraphComputerTest.MapReduceB.doStage(MapReduce.Stage stage) |
boolean |
GraphComputerTest.MapReduceBB.doStage(MapReduce.Stage stage) |
boolean |
GraphComputerTest.MapReduceC.doStage(MapReduce.Stage stage) |
boolean |
GraphComputerTest.MapReduceK.doStage(MapReduce.Stage stage) |
default void |
MapReduce.workerEnd(MapReduce.Stage stage)
This method is called at the end of the respective
MapReduce.Stage for a particular "chunk of vertices."
The set of vertices in the graph are typically not processed with full parallelism. |
default void |
MapReduce.workerStart(MapReduce.Stage stage)
This method is called at the start of the respective
MapReduce.Stage for a particular "chunk of vertices."
The set of vertices in the graph are typically not processed with full parallelism. |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterCountMapReduce.doStage(MapReduce.Stage stage) |
boolean |
ClusterPopulationMapReduce.doStage(MapReduce.Stage stage) |
Modifier and Type | Method and Description |
---|---|
boolean |
PageRankMapReduce.doStage(MapReduce.Stage stage) |
Copyright © 2013–2022 Apache Software Foundation. All rights reserved.