org.apache.giraph.block_app.migration

Class MigrationWorkerContext

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.block_app.migration.MigrationWorkerContext

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, org.apache.hadoop.io.Writable

Direct Known Subclasses:

MigrationWorkerContext.MigrationFullWorkerContext

public class MigrationWorkerContext
extends DefaultImmutableClassesGiraphConfigurable
implements org.apache.hadoop.io.Writable

Replacement for WorkerContext when migrating to Blocks Framework, disallowing functions that are tied to execution order.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MigrationWorkerContext.MigrationFullWorkerContext Drop-in replacement for WorkerContext when migrating to Blocks Framework.

Constructor Summary

Constructors

Constructor and Description
MigrationWorkerContext()

Method Summary

Modifier and Type	Method and Description
List<org.apache.hadoop.io.Writable>	getAndClearMessagesFromOtherWorkers()
int	getMyWorkerIndex()
long	getTotalNumEdges()
long	getTotalNumVertices()
int	getWorkerCount()
void	postSuperstep()
void	preSuperstep()
void	readFields(DataInput in)
void	sendMessageToWorker(org.apache.hadoop.io.Writable message, int workerIndex)
void	setApi(BlockWorkerContextApi api)
void	setReceivedMessages(List<org.apache.hadoop.io.Writable> receivedMessages)
void	write(DataOutput out)

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

MigrationWorkerContext

public MigrationWorkerContext()

Method Detail

setApi

public void setApi(BlockWorkerContextApi api)

setReceivedMessages

public void setReceivedMessages(List<org.apache.hadoop.io.Writable> receivedMessages)

preSuperstep

public void preSuperstep()

postSuperstep

public void postSuperstep()

getTotalNumVertices

public long getTotalNumVertices()

getTotalNumEdges

public long getTotalNumEdges()

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

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

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

Throws:

IOException

getWorkerCount

public final int getWorkerCount()

getMyWorkerIndex

public final int getMyWorkerIndex()

getAndClearMessagesFromOtherWorkers

public final List<org.apache.hadoop.io.Writable> getAndClearMessagesFromOtherWorkers()

sendMessageToWorker

public final void sendMessageToWorker(org.apache.hadoop.io.Writable message,
                                      int workerIndex)