public class RandomWalkWorkerContext extends WorkerContext
Constructor and Description |
---|
RandomWalkWorkerContext() |
Modifier and Type | Method and Description |
---|---|
int |
getMaxSupersteps() |
double |
getTeleportationProbability() |
boolean |
isSource(long id)
Checks if a vertex is a source.
|
int |
numSources() |
void |
postApplication() |
void |
postSuperstep() |
void |
preApplication() |
void |
preSuperstep() |
getAndClearMessagesFromOtherWorkers, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerCount, getWorkerForVertex, logToCommandLine, readFields, sendMessageToWorker, setGraphState, setupSuperstep, write
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public int getMaxSupersteps()
public double getTeleportationProbability()
public boolean isSource(long id)
id
- The vertex ID to check.public int numSources()
public void preApplication() throws InstantiationException, IllegalAccessException
preApplication
in class WorkerContext
InstantiationException
IllegalAccessException
public void preSuperstep()
preSuperstep
in class WorkerContext
public void postSuperstep()
postSuperstep
in class WorkerContext
public void postApplication()
postApplication
in class WorkerContext
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.