public final class BlockWorkerContext extends WorkerContext implements KryoIgnoreWritable
Modifier and Type | Field and Description |
---|---|
static org.apache.log4j.Logger |
LOG |
Constructor and Description |
---|
BlockWorkerContext() |
Modifier and Type | Method and Description |
---|---|
BlockOutputHandle |
getOutputHandle() |
Object |
getWorkerValue() |
void |
postApplication()
Finalize the WorkerContext.
|
void |
postSuperstep()
Execute user code.
|
void |
preApplication()
Initialize the WorkerContext.
|
void |
preSuperstep()
Execute user code.
|
void |
readFields(DataInput in) |
void |
write(DataOutput out) |
getAndClearMessagesFromOtherWorkers, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerCount, getWorkerForVertex, logToCommandLine, sendMessageToWorker, setGraphState, setupSuperstep
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public void preApplication() throws InstantiationException, IllegalAccessException
WorkerContext
preApplication
in class WorkerContext
InstantiationException
- Expected instantiation in this method.IllegalAccessException
- Thrown for getting the classpublic void preSuperstep()
WorkerContext
preSuperstep
in class WorkerContext
public void postSuperstep()
WorkerContext
postSuperstep
in class WorkerContext
public void postApplication()
WorkerContext
postApplication
in class WorkerContext
public Object getWorkerValue()
public BlockOutputHandle getOutputHandle()
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
write
in class WorkerContext
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
readFields
in class WorkerContext
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.