public static class TestComputationStateComputation.TestComputationStateWorkerContext extends DefaultWorkerContext
Constructor and Description |
---|
TestComputationStateWorkerContext() |
Modifier and Type | Method and Description |
---|---|
void |
postSuperstep() |
void |
preSuperstep() |
postApplication, preApplication
getAndClearMessagesFromOtherWorkers, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerCount, getWorkerForVertex, logToCommandLine, readFields, sendMessageToWorker, setGraphState, setupSuperstep, write
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public void preSuperstep()
preSuperstep
in class DefaultWorkerContext
public void postSuperstep()
postSuperstep
in class DefaultWorkerContext
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.