org.apache.giraph.block_app.migration

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>

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>

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.MigrationBasicComputation, MigrationAbstractComputation.MigrationFullAbstractComputation

public 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>
extends WorkerAggregatorDelegator<I,V,E>
implements TypesHolder<I,V,E,M1,M2>, org.apache.hadoop.io.Writable

Replacement for AbstractComputation when migrating to Blocks Framework, disallowing functions that are tied to execution order.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	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> Drop-in replacement for BasicComputation when migrating to Blocks Framework, disallowing functions that are tied to execution order.
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> Drop-in replacement for AbstractComputation when migrating to Blocks Framework.
static class	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> Drop-in replacement for BasicComputation when migrating to Blocks Framework.

Constructor Summary

Constructors

Constructor and Description
MigrationAbstractComputation()

Method Summary

Modifier and Type	Method and Description
void	addEdgeRequest(I sourceVertexId, Edge<I,E> edge)
void	addVertexRequest(I id, V value)
void	addVertexRequest(I id, V value, OutEdges<I,E> edges)
void	compute(Vertex<I,V,E> vertex, Iterable<M1> messages)
long	getTotalNumEdges()
long	getTotalNumVertices()
<W extends MigrationWorkerContext> W	getWorkerContext()
void	postSuperstep()
void	preSuperstep()
void	readFields(DataInput in)
void	removeEdgesRequest(I sourceVertexId, I targetVertexId)
void	removeVertexRequest(I vertexId)
void	sendMessage(I id, M2 message)
void	sendMessageToAllEdges(Vertex<I,V,E> vertex, M2 message)
void	sendMessageToMultipleEdges(Iterator<I> vertexIdIterator, M2 message)
void	write(DataOutput out)

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

MigrationAbstractComputation

public MigrationAbstractComputation()

Method Detail

compute

public void compute(Vertex<I,V,E> vertex,
                    Iterable<M1> messages)
             throws IOException

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

preSuperstep

public void preSuperstep()

postSuperstep

public void postSuperstep()

getTotalNumVertices

public long getTotalNumVertices()

getTotalNumEdges

public long getTotalNumEdges()

sendMessage

public void sendMessage(I id,
                        M2 message)

sendMessageToAllEdges

public final void sendMessageToAllEdges(Vertex<I,V,E> vertex,
                                        M2 message)

sendMessageToMultipleEdges

public final void sendMessageToMultipleEdges(Iterator<I> vertexIdIterator,
                                             M2 message)

addVertexRequest

public final void addVertexRequest(I id,
                                   V value,
                                   OutEdges<I,E> edges)
                            throws IOException

Throws:

IOException

addVertexRequest

public final void addVertexRequest(I id,
                                   V value)
                            throws IOException

Throws:

IOException

removeVertexRequest

public final void removeVertexRequest(I vertexId)
                               throws IOException

Throws:

IOException

addEdgeRequest

public final void addEdgeRequest(I sourceVertexId,
                                 Edge<I,E> edge)
                          throws IOException

Throws:

IOException

removeEdgesRequest

public final void removeEdgesRequest(I sourceVertexId,
                                     I targetVertexId)
                              throws IOException

Throws:

IOException

getWorkerContext

public <W extends MigrationWorkerContext> W getWorkerContext()