org.apache.giraph.block_app.migration

Class MigrationMasterCompute.MigrationFullMasterCompute

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

org.apache.giraph.block_app.migration.MigrationMasterCompute

org.apache.giraph.block_app.migration.MigrationMasterCompute.MigrationFullMasterCompute

All Implemented Interfaces:

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

Direct Known Subclasses:

SimpleMigrationMasterBlockFactory.SimpleMigrationMasterCompute

Enclosing class:

MigrationMasterCompute

public static class MigrationMasterCompute.MigrationFullMasterCompute
extends MigrationMasterCompute

Drop-in replacement for MasterCompute when migrating to Blocks Framework.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.giraph.block_app.migration.MigrationMasterCompute

MigrationMasterCompute.MigrationFullMasterCompute

Constructor Summary

Constructors

Constructor and Description
MigrationFullMasterCompute()

Method Summary

Modifier and Type	Method and Description
Class<? extends MigrationAbstractComputation>	getComputation()
Class<? extends MessageCombiner>	getMessageCombiner()
long	getSuperstep()
long	getTotalNumEdges()
long	getTotalNumVertices()
void	haltComputation()
boolean	isHalted()
void	setComputation(Class<? extends MigrationAbstractComputation.MigrationFullAbstractComputation> computation)
void	setIncomingMessage(Class<? extends org.apache.hadoop.io.Writable> incomingMessageClass)
void	setMessageCombiner(Class<? extends MessageCombiner> combinerClass)
void	setOutgoingMessage(Class<? extends org.apache.hadoop.io.Writable> outgoingMessageClass)

Methods inherited from class org.apache.giraph.block_app.migration.MigrationMasterCompute

broadcast, compute, getAggregatedValue, getContext, getReduced, initialize, logToCommandLine, readFields, registerAggregator, registerPersistentAggregator, registerReducer, registerReducer, setAggregatedValue, write

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

MigrationFullMasterCompute

public MigrationFullMasterCompute()

Method Detail

getSuperstep

public final long getSuperstep()

getTotalNumVertices

public final long getTotalNumVertices()

Overrides:

getTotalNumVertices in class MigrationMasterCompute

getTotalNumEdges

public final long getTotalNumEdges()

Overrides:

getTotalNumEdges in class MigrationMasterCompute

haltComputation

public final void haltComputation()

isHalted

public final boolean isHalted()

setComputation

public final void setComputation(Class<? extends MigrationAbstractComputation.MigrationFullAbstractComputation> computation)

getComputation

public final Class<? extends MigrationAbstractComputation> getComputation()

setMessageCombiner

public final void setMessageCombiner(Class<? extends MessageCombiner> combinerClass)

getMessageCombiner

public final Class<? extends MessageCombiner> getMessageCombiner()

setIncomingMessage

public final void setIncomingMessage(Class<? extends org.apache.hadoop.io.Writable> incomingMessageClass)

setOutgoingMessage

public final void setOutgoingMessage(Class<? extends org.apache.hadoop.io.Writable> outgoingMessageClass)