public class SccPhaseMasterCompute extends DefaultMasterCompute
Modifier and Type | Class and Description |
---|---|
static class |
SccPhaseMasterCompute.Phases
Enumerates the possible phases of the algorithm.
|
Modifier and Type | Field and Description |
---|---|
static String |
CONVERGED
Flags whether a vertex converged in the Backward Traversal phase
|
static String |
NEW_MAXIMUM
Flags whether a new maximum was found in the Forward Traversal phase
|
static String |
PHASE
Aggregator that stores the current phase
|
Constructor and Description |
---|
SccPhaseMasterCompute() |
Modifier and Type | Method and Description |
---|---|
void |
compute()
Must be defined by user to specify what the master has to do.
|
static SccPhaseMasterCompute.Phases |
getPhase(org.apache.hadoop.io.IntWritable phaseInt)
Helper function to convert from internal aggregated value to a Phases
enumerator.
|
void |
initialize()
Initialize the MasterCompute class, this is the place to register
aggregators.
|
readFields, write
broadcast, getAggregatedValue, getComputation, getContext, getMessageCombiner, getReduced, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerInfoList, haltComputation, isHalted, logToCommandLine, registerAggregator, registerPersistentAggregator, registerReducer, registerReducer, setAggregatedValue, setComputation, setGraphState, setIncomingMessage, setMasterService, setMessageCombiner, setOutgoingMessage, setOutgoingMessageClasses, setSuperstepClasses
getConf, setConf
public static final String PHASE
public static final String NEW_MAXIMUM
public static final String CONVERGED
public void initialize() throws InstantiationException, IllegalAccessException
MasterCompute
initialize
in class DefaultMasterCompute
InstantiationException
IllegalAccessException
public void compute()
MasterCompute
compute
in class DefaultMasterCompute
public static SccPhaseMasterCompute.Phases getPhase(org.apache.hadoop.io.IntWritable phaseInt)
phaseInt
- An integer that matches a position in the Phases enumerator.Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.