Package org.apache.giraph.comm

Package of communication related objects, IPC service.

See: Description

Interface Summary

Interface	Description
MasterClient	Interface for master to send messages to workers
MasterServer	Interface for master to receive messages from workers
NetworkMetrics	Interface for providing network statistics, such as bytes received etc.
WorkerClient<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Public interface for workers to establish connections and send aggregated requests.
WorkerClientRequestProcessor<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Aggregates IPC requests and sends them off
WorkerServer<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Interface for message communication server.

Class Summary

Class	Description
SendDataCache<D>	An abstract structure for caching data by partitions to be sent to workers in bulk.
SendEdgeCache<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>	Aggregates the edges to be sent to workers so they can be sent in bulk.
SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Aggregates the messages to be sent to workers so they can be sent in bulk.
SendMessageCache.TargetVertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>	An iterator wrapper on edges to return target vertex ids.
SendMutationsCache<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Aggregates the mutations to be sent to partitions so they can be sent in bulk.
SendOneMessageToManyCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Aggregates the messages to be sent to workers so they can be sent in bulk.
SendPartitionCache<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Caches partition vertices prior to sending.
SendVertexIdDataCache<I extends org.apache.hadoop.io.WritableComparable,T,B extends VertexIdData<I,T>>	An abstract structure for caching data indexed by vertex id, to be sent to workers in bulk.
ServerData<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Anything that the server stores

Enum Summary

Enum	Description
GlobalCommType	Type tag distinguishing different global communication messages.

Package org.apache.giraph.comm Description

Package of communication related objects, IPC service.