Package | Description |
---|---|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.comm.requests |
Package for requests.
|
org.apache.giraph.graph |
Package of all the graph related objects, built on the
org.apache.bsp package.
|
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<Integer,ConcurrentMap<I,VertexMutations<I,V,E>>> |
ServerData.getPartitionMutations()
Get the vertex mutations (synchronize on the values)
|
Map<Integer,Map<I,VertexMutations<I,V,E>>> |
SendMutationsCache.removeAllPartitionMutations()
Gets all the mutations and removes them from the cache.
|
Map<I,VertexMutations<I,V,E>> |
SendMutationsCache.removePartitionMutations(int partitionId)
Gets the mutations for a partition and removes it from the cache.
|
Constructor and Description |
---|
SendPartitionMutationsRequest(int partitionId,
Map<I,VertexMutations<I,V,E>> vertexIdMutations)
Constructor used to send request.
|
Modifier and Type | Method and Description |
---|---|
VertexMutations<I,V,E> |
VertexMutations.copy()
Copy the vertex mutations.
|
Modifier and Type | Method and Description |
---|---|
void |
VertexMutations.addVertexMutations(VertexMutations<I,V,E> vertexMutations)
Add one vertex mutations to another
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.