S
- Execution stage typepublic final class BlockMasterCompute<S> extends MasterCompute
Constructor and Description |
---|
BlockMasterCompute() |
Modifier and Type | Method and Description |
---|---|
void |
compute() |
void |
initialize() |
void |
readFields(DataInput in) |
void |
write(DataOutput out) |
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 void initialize() throws InstantiationException, IllegalAccessException
initialize
in class MasterCompute
InstantiationException
IllegalAccessException
public void compute()
compute
in class MasterCompute
public void write(DataOutput out) throws IOException
IOException
public void readFields(DataInput in) throws IOException
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.