org.apache.giraph.comm

Class SendMutationsCache<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.SendMutationsCache<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex data

E - Edge data

public class SendMutationsCache<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object

Aggregates the mutations to be sent to partitions so they can be sent in bulk. Not thread-safe.

Constructor Summary

Constructors

Constructor and Description
SendMutationsCache()

Method Summary

Modifier and Type	Method and Description
int	addEdgeMutation(Integer partitionId, I destVertexId, Edge<I,E> edge) Add an add edge mutation to the cache.
int	addVertexMutation(Integer partitionId, Vertex<I,V,E> vertex) Add a add vertex mutation to the cache.
Map<Integer,Map<I,VertexMutations<I,V,E>>>	removeAllPartitionMutations() Gets all the mutations and removes them from the cache.
int	removeEdgeMutation(Integer partitionId, I vertexIndex, I destinationVertexIndex) Add a remove edge mutation to the cache.
Map<I,VertexMutations<I,V,E>>	removePartitionMutations(int partitionId) Gets the mutations for a partition and removes it from the cache.
int	removeVertexMutation(Integer partitionId, I destVertexId) Add a remove vertex mutation to the cache.

Methods inherited from class java.lang.Object

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

Constructor Detail

SendMutationsCache

public SendMutationsCache()

Method Detail

addEdgeMutation

public int addEdgeMutation(Integer partitionId,
                           I destVertexId,
                           Edge<I,E> edge)

Add an add edge mutation to the cache.

Parameters:

partitionId - Partition id

destVertexId - Destination vertex id

edge - Edge to be added

Returns:

Number of mutations in the partition.

removeEdgeMutation

public int removeEdgeMutation(Integer partitionId,
                              I vertexIndex,
                              I destinationVertexIndex)

Add a remove edge mutation to the cache.

Parameters:

partitionId - Partition id

vertexIndex - Destination vertex id

destinationVertexIndex - Edge vertex index to be removed

Returns:

Number of mutations in the partition.

addVertexMutation

public int addVertexMutation(Integer partitionId,
                             Vertex<I,V,E> vertex)

Add a add vertex mutation to the cache.

Parameters:

partitionId - Partition id

vertex - Vertex to be added

Returns:

Number of mutations in the partition.

removeVertexMutation

public int removeVertexMutation(Integer partitionId,
                                I destVertexId)

Add a remove vertex mutation to the cache.

Parameters:

partitionId - Partition id

destVertexId - Vertex index to be removed

Returns:

Number of mutations in the partition.

removePartitionMutations

public Map<I,VertexMutations<I,V,E>> removePartitionMutations(int partitionId)

Gets the mutations for a partition and removes it from the cache.

Parameters:

partitionId - Partition id

Returns:

Removed partition mutations

removeAllPartitionMutations

public Map<Integer,Map<I,VertexMutations<I,V,E>>> removeAllPartitionMutations()

Gets all the mutations and removes them from the cache.

Returns:

All vertex mutations for all partitions