org.apache.giraph.block_app.migration

Class MigrationFullBlockFactory

java.lang.Object

org.apache.giraph.block_app.framework.AbstractBlockFactory<MigrationSuperstepStage>

org.apache.giraph.block_app.migration.MigrationFullBlockFactory

All Implemented Interfaces:

BlockFactory<MigrationSuperstepStage>

Direct Known Subclasses:

SimpleMigrationMasterBlockFactory

public abstract class MigrationFullBlockFactory
extends AbstractBlockFactory<MigrationSuperstepStage>

BlockFactory to extend when using drop-in migration

Field Summary

Fields inherited from class org.apache.giraph.block_app.framework.AbstractBlockFactory

CONFIGURATORS

Constructor Summary

Constructors

Constructor and Description
MigrationFullBlockFactory()

Method Summary

Modifier and Type	Method and Description
MigrationSuperstepStage	createExecutionStage(GiraphConfiguration conf) Create an empty instance of execution stage object.
<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,MR extends org.apache.hadoop.io.Writable,MS extends org.apache.hadoop.io.Writable> Block	createMigrationAppBlock(Class<? extends MigrationAbstractComputation.MigrationFullAbstractComputation<I,V,E,MR,MS>> computationClass, MigrationMasterCompute.MigrationFullMasterCompute masterCompute, Class<MS> messageClass, Class<? extends MessageCombiner<? super I,MS>> messageCombinerClass, GiraphConfiguration conf)
protected Class<? extends MigrationWorkerContext>	getWorkerContextValueClass(GiraphConfiguration conf) Concrete worker context value class application will use, if overridden.

Methods inherited from class org.apache.giraph.block_app.framework.AbstractBlockFactory

additionalInitConfig, getConvenienceConfiguratorPackages, getEdgeValueClass, getGcJavaOpts, getVertexIDClass, getVertexValueClass, initConfig, registerOutputs, shouldCreateVertexOnMsgs, shouldSendOneMessageToAll

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.giraph.block_app.framework.BlockFactory

createBlock

Constructor Detail

MigrationFullBlockFactory

public MigrationFullBlockFactory()

Method Detail

createExecutionStage

public MigrationSuperstepStage createExecutionStage(GiraphConfiguration conf)

Description copied from interface: BlockFactory

Create an empty instance of execution stage object. Can be used by application to be aware of what was executed before. Most common example is counting iterations, or for having a boolean whether some important event happened. Execution stage should be immutable object, with creating a new object when different value is needed.

getWorkerContextValueClass

protected Class<? extends MigrationWorkerContext> getWorkerContextValueClass(GiraphConfiguration conf)

Description copied from class: AbstractBlockFactory

Concrete worker context value class application will use, if overridden.

Overrides:

getWorkerContextValueClass in class AbstractBlockFactory<MigrationSuperstepStage>

createMigrationAppBlock

public <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,MR extends org.apache.hadoop.io.Writable,MS extends org.apache.hadoop.io.Writable> Block createMigrationAppBlock(Class<? extends MigrationAbstractComputation.MigrationFullAbstractComputation<I,V,E,MR,MS>> computationClass,
                                                                                                                                                                                                                                                           MigrationMasterCompute.MigrationFullMasterCompute masterCompute,
                                                                                                                                                                                                                                                           Class<MS> messageClass,
                                                                                                                                                                                                                                                           Class<? extends MessageCombiner<? super I,MS>> messageCombinerClass,
                                                                                                                                                                                                                                                           GiraphConfiguration conf)