Package | Description |
---|---|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.comm.requests |
Package for requests.
|
Modifier and Type | Method and Description |
---|---|
PairList<WorkerInfo,PairList<Integer,D>> |
SendDataCache.removeAllData()
Gets all the data and removes it from the cache.
|
PairList<WorkerInfo,PairList<Integer,VertexIdEdges<I,E>>> |
SendEdgeCache.removeAllEdges()
Gets all the edges and removes them from the cache.
|
PairList<Integer,D> |
SendDataCache.removeWorkerData(WorkerInfo workerInfo)
Gets the data for a worker and removes it from the cache.
|
PairList<Integer,VertexIdEdges<I,E>> |
SendEdgeCache.removeWorkerEdges(WorkerInfo workerInfo)
Gets the edges for a worker and removes it from the cache.
|
protected PairList<Integer,VertexIdMessages<I,M>> |
SendMessageCache.removeWorkerMessages(WorkerInfo workerInfo)
Gets the messages for a worker and removes it from the cache.
|
Modifier and Type | Method and Description |
---|---|
PairList<WorkerInfo,PairList<Integer,D>> |
SendDataCache.removeAllData()
Gets all the data and removes it from the cache.
|
PairList<WorkerInfo,PairList<Integer,VertexIdEdges<I,E>>> |
SendEdgeCache.removeAllEdges()
Gets all the edges and removes them from the cache.
|
Modifier and Type | Field and Description |
---|---|
protected PairList<Integer,B> |
SendWorkerDataRequest.partitionVertexData
All data for a group of vertices, organized by partition, which
are owned by a single (destination) worker.
|
Constructor and Description |
---|
SendWorkerDataRequest(PairList<Integer,B> partVertData)
Constructor used to send request.
|
SendWorkerEdgesRequest(PairList<Integer,VertexIdEdges<I,E>> partVertEdges)
Constructor used to send request.
|
SendWorkerMessagesRequest(PairList<Integer,VertexIdMessages<I,M>> partVertMsgs)
Constructor used to send request.
|
SendWorkerVerticesRequest(ImmutableClassesGiraphConfiguration<I,V,E> conf,
PairList<Integer,ExtendedDataOutput> workerPartitions)
Constructor for sending a request.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.