org.apache.giraph.examples.block_app

Class SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<I,V,E>

org.apache.giraph.block_app.migration.MigrationAbstractComputation<I,V,E,M1,M2>

org.apache.giraph.block_app.migration.MigrationAbstractComputation.MigrationFullAbstractComputation<I,V,E,M,M>

org.apache.giraph.block_app.migration.MigrationAbstractComputation.MigrationFullBasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>

org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>, TypesHolder<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage, org.apache.hadoop.io.Writable

Enclosing class:

SimpleMigrationMasterBlockFactory

public static class SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation
extends MigrationAbstractComputation.MigrationFullBasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>

Demonstrates a computation with a centralized part implemented via a MasterCompute.

Nested Class Summary

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

MigrationAbstractComputation.MigrationBasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>, MigrationAbstractComputation.MigrationFullAbstractComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable>, MigrationAbstractComputation.MigrationFullBasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>

Field Summary

Fields

Modifier and Type	Field and Description
static String	SMC_AGG Aggregator to get values from the master to the workers

Constructor Summary

Constructors

Constructor and Description
SimpleMigrationMasterComputation()

Method Summary

Modifier and Type	Method and Description
void	compute(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex, Iterable<org.apache.hadoop.io.DoubleWritable> messages)

Methods inherited from class org.apache.giraph.block_app.migration.MigrationAbstractComputation.MigrationFullAbstractComputation

getSuperstep

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

addEdgeRequest, addVertexRequest, addVertexRequest, getTotalNumEdges, getTotalNumVertices, getWorkerContext, postSuperstep, preSuperstep, readFields, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges, write

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

Field Detail

SMC_AGG

public static final String SMC_AGG

Aggregator to get values from the master to the workers

See Also:

Constant Field Values

Constructor Detail

SimpleMigrationMasterComputation

public SimpleMigrationMasterComputation()

Method Detail

compute

public void compute(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex,
                    Iterable<org.apache.hadoop.io.DoubleWritable> messages)
             throws IOException

Overrides:

compute in class MigrationAbstractComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Throws:

IOException