org.apache.giraph.comm

Class SendPartitionCache<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.SendDataCache<ExtendedDataOutput>

org.apache.giraph.comm.SendPartitionCache<I,V,E>

Type Parameters:

I - Vertex index value

V - Vertex value

E - Edge value

public class SendPartitionCache<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends SendDataCache<ExtendedDataOutput>

Caches partition vertices prior to sending. Aggregating these requests will make larger, more efficient requests. Not thread-safe.

Constructor Summary

Constructors

Constructor and Description
SendPartitionCache(ImmutableClassesGiraphConfiguration<I,V,E> conf, CentralizedServiceWorker<?,?,?> serviceWorker) Constructor.

Method Summary

Modifier and Type	Method and Description
int	addVertex(PartitionOwner partitionOwner, Vertex<I,V,E> vertex) Add a vertex to the cache.

Methods inherited from class org.apache.giraph.comm.SendDataCache

getConf, getData, getInitialBufferSize, getNumWorkers, getSendWorkerInitialBufferSize, getServiceWorker, getWorkerPartitions, incrDataSize, removeAllData, removeWorkerData, setData

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SendPartitionCache

public SendPartitionCache(ImmutableClassesGiraphConfiguration<I,V,E> conf,
                          CentralizedServiceWorker<?,?,?> serviceWorker)

Constructor.

Parameters:

conf - Giraph configuration

serviceWorker - Service worker

Method Detail

addVertex

public int addVertex(PartitionOwner partitionOwner,
                     Vertex<I,V,E> vertex)

Add a vertex to the cache.

Parameters:

partitionOwner - Partition owner of the vertex

vertex - Vertex to add

Returns:

Size of partitions for this worker