org.apache.giraph.benchmark

Class AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext

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.worker.DefaultWorkerContext

org.apache.giraph.benchmark.AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext

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:

AggregatorsBenchmark

public static class AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext
extends DefaultWorkerContext

WorkerContext class for AggregatorsBenchmark

Constructor Summary

Constructors

Constructor and Description
AggregatorsBenchmarkWorkerContext()

Method Summary

Modifier and Type	Method and Description
void	postSuperstep() Execute user code.
void	preSuperstep() Execute user code.

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

postApplication, preApplication

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

AggregatorsBenchmarkWorkerContext

public AggregatorsBenchmarkWorkerContext()

Method Detail

preSuperstep

public void preSuperstep()

Description copied from class: WorkerContext

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

Overrides:

preSuperstep in class DefaultWorkerContext

postSuperstep

public void postSuperstep()

Description copied from class: WorkerContext

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

Overrides:

postSuperstep in class DefaultWorkerContext