I
- Vertex idV
- Vertex valueE
- Edge valuepublic interface EdgeStore<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Modifier and Type | Method and Description |
---|---|
void |
addPartitionEdges(int partitionId,
VertexIdEdges<I,E> edges)
Add edges belonging to a given partition on this worker.
|
boolean |
hasEdgesForPartition(int partitionId)
Check if edge store has edge for a given partition
|
void |
moveEdgesToVertices()
Move all edges from temporary storage to their source vertices.
|
void |
readPartitionEdgeStore(int partitionId,
DataInput input)
Serialize the edges of a given partition, and adds it to the partition
store (assumes that the edge store does not have any edge from the
partition already).
|
void |
writePartitionEdgeStore(int partitionId,
DataOutput output)
Deserialize the edges of a given partition, and removes the associated data
from the store.
|
void addPartitionEdges(int partitionId, VertexIdEdges<I,E> edges)
partitionId
- Partition id for the incoming edges.edges
- Incoming edgesvoid moveEdgesToVertices()
void writePartitionEdgeStore(int partitionId, DataOutput output) throws IOException
partitionId
- Id of partition to deserializeoutput
- Output to write the edge store toIOException
void readPartitionEdgeStore(int partitionId, DataInput input) throws IOException
partitionId
- Id of partition to serializeinput
- Input to read the partition fromIOException
boolean hasEdgesForPartition(int partitionId)
partitionId
- Id of partitionCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.