org.apache.giraph

Class TestCheckpointing.CheckpointVertexWorkerContext

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.TestCheckpointing.CheckpointVertexWorkerContext

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:

TestCheckpointing

public static class TestCheckpointing.CheckpointVertexWorkerContext
extends DefaultWorkerContext

Worker context associated.

Constructor Summary

Constructors

Constructor and Description
CheckpointVertexWorkerContext()

Method Summary

Modifier and Type	Method and Description
static long	getFinalSum()
void	postApplication()
void	postSuperstep()
void	preSuperstep()
void	readFields(DataInput dataInput)
void	write(DataOutput dataOutput)

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

preApplication

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

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

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

CheckpointVertexWorkerContext

public CheckpointVertexWorkerContext()

Method Detail

getFinalSum

public static long getFinalSum()

postSuperstep

public void postSuperstep()

Overrides:

postSuperstep in class DefaultWorkerContext

postApplication

public void postApplication()

Overrides:

postApplication in class DefaultWorkerContext

preSuperstep

public void preSuperstep()

Overrides:

preSuperstep in class DefaultWorkerContext

readFields

public void readFields(DataInput dataInput)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Overrides:

readFields in class WorkerContext

Throws:

IOException

write

public void write(DataOutput dataOutput)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Overrides:

write in class WorkerContext

Throws:

IOException