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() |
void |
postSuperstep() |
void |
preApplication() |
void |
preSuperstep() |
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
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
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.