| 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.