Package | Description |
---|---|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.comm.requests |
Package for requests.
|
org.apache.giraph.edge |
Package of Vertex implementations.
|
org.apache.giraph.ooc.data |
Package of classes related to data structures used for an out-of-core
mechanism
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
Modifier and Type | Method and Description |
---|---|
VertexIdEdges<I,E> |
SendEdgeCache.createVertexIdData() |
Modifier and Type | Method and Description |
---|---|
PairList<WorkerInfo,PairList<Integer,VertexIdEdges<I,E>>> |
SendEdgeCache.removeAllEdges()
Gets all the edges and removes them from the cache.
|
PairList<Integer,VertexIdEdges<I,E>> |
SendEdgeCache.removeWorkerEdges(WorkerInfo workerInfo)
Gets the edges for a worker and removes it from the cache.
|
Modifier and Type | Method and Description |
---|---|
VertexIdEdges<I,E> |
SendWorkerEdgesRequest.createVertexIdData() |
Constructor and Description |
---|
SendWorkerEdgesRequest(PairList<Integer,VertexIdEdges<I,E>> partVertEdges)
Constructor used to send request.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractEdgeStore.addPartitionEdges(int partitionId,
VertexIdEdges<I,E> edges) |
void |
EdgeStore.addPartitionEdges(int partitionId,
VertexIdEdges<I,E> edges)
Add edges belonging to a given partition on this worker.
|
Modifier and Type | Method and Description |
---|---|
protected VertexIdEdges<I,E> |
DiskBackedEdgeStore.readNextEntry(DataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
DiskBackedEdgeStore.addEntryToInMemoryPartitionData(int partitionId,
VertexIdEdges<I,E> edges) |
void |
DiskBackedEdgeStore.addPartitionEdges(int partitionId,
VertexIdEdges<I,E> edges) |
protected int |
DiskBackedEdgeStore.entrySerializedSize(VertexIdEdges<I,E> edges) |
protected void |
DiskBackedEdgeStore.writeEntry(VertexIdEdges<I,E> edges,
DataOutput out) |
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayVertexIdEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Stores vertex id and edge pairs in a single byte array.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.