public static class AggregatorsTestComputation.AggregatorsTestMasterCompute extends DefaultMasterCompute
Constructor and Description |
---|
AggregatorsTestMasterCompute() |
Modifier and Type | Method and Description |
---|---|
void |
compute() |
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 void compute()
compute
in class DefaultMasterCompute
public void initialize() throws InstantiationException, IllegalAccessException
initialize
in class DefaultMasterCompute
InstantiationException
IllegalAccessException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.