org.apache.giraph.benchmark

Class RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

org.apache.giraph.worker.WorkerContext

org.apache.giraph.benchmark.RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerIndexUsage<org.apache.hadoop.io.WritableComparable>, WorkerReduceUsage, org.apache.hadoop.io.Writable

Enclosing class:

RandomMessageBenchmark

public static class RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext
extends WorkerContext

WorkerContext forRandomMessageBenchmark.

Constructor Summary

Constructors

Constructor and Description
RandomMessageBenchmarkWorkerContext()

Method Summary

Modifier and Type	Method and Description
byte[]	getMessageBytes() Get the message bytes to be used for sending.
int	getNumMessagePerEdge() Get the number of edges per message.
int	getNumSupersteps() Get the number of supersteps.
void	postApplication() Finalize the WorkerContext.
void	postSuperstep() Execute user code.
void	preApplication() Initialize the WorkerContext.
void	preSuperstep() Execute user code.
void	randomizeMessageBytes() Randomize the message bytes.

Methods inherited from class org.apache.giraph.worker.WorkerContext

getAndClearMessagesFromOtherWorkers, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerCount, getWorkerForVertex, logToCommandLine, readFields, sendMessageToWorker, setGraphState, setupSuperstep, write

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RandomMessageBenchmarkWorkerContext

public RandomMessageBenchmarkWorkerContext()

Method Detail

preApplication

public void preApplication()
                    throws InstantiationException,
                           IllegalAccessException

Description copied from class: WorkerContext

Initialize the WorkerContext. This method is executed once on each Worker before the first superstep starts.

Specified by:

preApplication in class WorkerContext

Throws:

InstantiationException - Expected instantiation in this method.

IllegalAccessException - Thrown for getting the class

preSuperstep

public void preSuperstep()

Description copied from class: WorkerContext

Execute user code. This method is executed once on each Worker before each superstep starts.

Specified by:

preSuperstep in class WorkerContext

postSuperstep

public void postSuperstep()

Description copied from class: WorkerContext

Execute user code. This method is executed once on each Worker after each superstep ends.

Specified by:

postSuperstep in class WorkerContext

postApplication

public void postApplication()

Description copied from class: WorkerContext

Finalize the WorkerContext. This method is executed once on each Worker after the last superstep ends.

Specified by:

postApplication in class WorkerContext

getMessageBytes

public byte[] getMessageBytes()

Get the message bytes to be used for sending.

Returns:

Byte array used for messages.

getNumMessagePerEdge

public int getNumMessagePerEdge()

Get the number of edges per message.

Returns:

Messages per edge.

getNumSupersteps

public int getNumSupersteps()

Get the number of supersteps.

Returns:

Number of supersteps.

randomizeMessageBytes

public void randomizeMessageBytes()

Randomize the message bytes.