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() |
static SccPhaseMasterCompute.Phases |
getPhase(org.apache.hadoop.io.IntWritable phaseInt)
Helper function to convert from internal aggregated value to a Phases
enumerator.
|
void |
initialize() |
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
initialize
in class DefaultMasterCompute
InstantiationException
IllegalAccessException
public void compute()
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.