public static class SimpleVertexWithWorkerContext.EmitterWorkerContext extends WorkerContext
Constructor and Description |
---|
EmitterWorkerContext() |
Modifier and Type | Method and Description |
---|---|
void |
emit(String s)
Write this string to the output stream.
|
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 void preApplication()
preApplication
in class WorkerContext
public void postApplication()
postApplication
in class WorkerContext
public void preSuperstep()
preSuperstep
in class WorkerContext
public void postSuperstep()
postSuperstep
in class WorkerContext
public void emit(String s)
s
- String to dump.Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.