org.apache.giraph.examples.block_app

Class SimpleMigrationMasterBlockFactory

java.lang.Object

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

org.apache.giraph.block_app.migration.MigrationFullBlockFactory

org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory

All Implemented Interfaces:

BlockFactory<MigrationSuperstepStage>

public class SimpleMigrationMasterBlockFactory
extends MigrationFullBlockFactory

Demonstrates using migration library for Blocks Framework, as an drop-in replacement, without any changes.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation Demonstrates a computation with a centralized part implemented via a MasterCompute.
static class	SimpleMigrationMasterBlockFactory.SimpleMigrationMasterCompute MasterCompute used with SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation.
static class	SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext Worker context used with SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation.

Field Summary

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

CONFIGURATORS

Constructor Summary

Constructors

Constructor and Description
SimpleMigrationMasterBlockFactory()

Method Summary

Modifier and Type	Method and Description
Block	createBlock(GiraphConfiguration conf) Create a block (representing a full Giraph job), based on the given configuration.
protected Class<org.apache.hadoop.io.FloatWritable>	getEdgeValueClass(GiraphConfiguration conf) Concrete edge value class application will use.
protected Class<org.apache.hadoop.io.LongWritable>	getVertexIDClass(GiraphConfiguration conf) Concrete vertex id class application will use.
protected Class<org.apache.hadoop.io.DoubleWritable>	getVertexValueClass(GiraphConfiguration conf) Concrete vertex value class application will use.
protected Class<SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext>	getWorkerContextValueClass(GiraphConfiguration conf) Concrete worker context value class application will use, if overridden.

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

createExecutionStage, createMigrationAppBlock

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

additionalInitConfig, getConvenienceConfiguratorPackages, getGcJavaOpts, initConfig, registerOutputs, shouldCreateVertexOnMsgs, shouldSendOneMessageToAll

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleMigrationMasterBlockFactory

public SimpleMigrationMasterBlockFactory()

Method Detail

createBlock

public Block createBlock(GiraphConfiguration conf)

Description copied from interface: BlockFactory

Create a block (representing a full Giraph job), based on the given configuration. Configuration should be treated as immutable at this point. If there are issues in configuration, it is very cheap to throw from this method - as Giraph job will not even start. This function will be called two times - once before starting of the Giraph job, to fail early if anything is incorrectly configured. Second time will be on Master, which will return Block instance on which createIterator will be called once, which should return current application run. initConfig will be called only once, before starting Giraph job itself. Master will contain configuration already modified by initConfig.

getVertexIDClass

protected Class<org.apache.hadoop.io.LongWritable> getVertexIDClass(GiraphConfiguration conf)

Description copied from class: AbstractBlockFactory

Concrete vertex id class application will use.

Specified by:

getVertexIDClass in class AbstractBlockFactory<MigrationSuperstepStage>

getVertexValueClass

protected Class<org.apache.hadoop.io.DoubleWritable> getVertexValueClass(GiraphConfiguration conf)

Description copied from class: AbstractBlockFactory

Concrete vertex value class application will use.

Specified by:

getVertexValueClass in class AbstractBlockFactory<MigrationSuperstepStage>

getEdgeValueClass

protected Class<org.apache.hadoop.io.FloatWritable> getEdgeValueClass(GiraphConfiguration conf)

Description copied from class: AbstractBlockFactory

Concrete edge value class application will use.

Specified by:

getEdgeValueClass in class AbstractBlockFactory<MigrationSuperstepStage>

getWorkerContextValueClass

protected Class<SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext> getWorkerContextValueClass(GiraphConfiguration conf)

Description copied from class: AbstractBlockFactory

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

Overrides:

getWorkerContextValueClass in class MigrationFullBlockFactory