I
- Vertex idV
- Vertex dataE
- Edge datapublic 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
Constructor and Description |
---|
SendMutationsCache() |
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.
|
public int addEdgeMutation(Integer partitionId, I destVertexId, Edge<I,E> edge)
partitionId
- Partition iddestVertexId
- Destination vertex idedge
- Edge to be addedpublic int removeEdgeMutation(Integer partitionId, I vertexIndex, I destinationVertexIndex)
partitionId
- Partition idvertexIndex
- Destination vertex iddestinationVertexIndex
- Edge vertex index to be removedpublic int addVertexMutation(Integer partitionId, Vertex<I,V,E> vertex)
partitionId
- Partition idvertex
- Vertex to be addedpublic int removeVertexMutation(Integer partitionId, I destVertexId)
partitionId
- Partition iddestVertexId
- Vertex index to be removedpublic Map<I,VertexMutations<I,V,E>> removePartitionMutations(int partitionId)
partitionId
- Partition idCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.