org.apache.giraph.block_app.migration

Class 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>

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,M1,M2>

Type Parameters:

I - Vertex ID

V - Vertex Value

E - Edge Value

M1 - Incoming Message Value

M2 - Outgoing Message Value

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, TypesHolder<I,V,E,M1,M2>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage, org.apache.hadoop.io.Writable

Direct Known Subclasses:

MigrationAbstractComputation.MigrationFullBasicComputation

Enclosing class:

MigrationAbstractComputation<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>

public static class 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>
extends MigrationAbstractComputation<I,V,E,M1,M2>

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

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>

Constructor Summary

Constructors

Constructor and Description
MigrationFullAbstractComputation()

Method Summary

Modifier and Type	Method and Description
long	getSuperstep()

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

addEdgeRequest, addVertexRequest, addVertexRequest, compute, 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

Constructor Detail

MigrationFullAbstractComputation

public MigrationFullAbstractComputation()

Method Detail

getSuperstep

public long getSuperstep()