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) |
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) |
Modifier and Type | Method and Description |
---|---|
boolean |
TraverserMapReduce.doStage(MapReduce.Stage stage) |
Modifier and Type | Method and Description |
---|---|
boolean |
TreeStep.TreeMapReduce.doStage(MapReduce.Stage stage) |
boolean |
GroupCountStep.GroupCountMapReduce.doStage(MapReduce.Stage stage) |
boolean |
GroupStep.GroupMapReduce.doStage(MapReduce.Stage stage) |
boolean |
GroupStepV3d0.GroupMapReduceV3d0.doStage(MapReduce.Stage stage) |
Modifier and Type | Method and Description |
---|---|
boolean |
AggregateStep.AggregateMapReduce.doStage(MapReduce.Stage stage) |
boolean |
ProfileStep.ProfileMapReduce.doStage(MapReduce.Stage stage) |
boolean |
GroupSideEffectStep.GroupSideEffectMapReduce.doStage(MapReduce.Stage stage) |
boolean |
TreeSideEffectStep.TreeSideEffectMapReduce.doStage(MapReduce.Stage stage) |
boolean |
GroupSideEffectStepV3d0.GroupSideEffectMapReduceV3d0.doStage(MapReduce.Stage stage) |
boolean |
StoreStep.StoreMapReduce.doStage(MapReduce.Stage stage) |
boolean |
GroupCountSideEffectStep.GroupCountSideEffectMapReduce.doStage(MapReduce.Stage stage) |
Modifier and Type | Method and Description |
---|---|
boolean |
ReducingBarrierStep.DefaultMapReduce.doStage(MapReduce.Stage stage) |
Copyright © 2013–2017 Apache Software Foundation. All rights reserved.