Package org.apache.giraph.comm

Package of communication related objects, IPC service.

See:
Description

Interface Summary

MasterClient	Interface for master to send messages to workers
MasterServer	Interface for master to receive messages from workers
WorkerClient<I extends WritableComparable,V extends Writable,E extends Writable>	Public interface for workers to establish connections and send aggregated requests.
WorkerClientRequestProcessor<I extends WritableComparable,V extends Writable,E extends Writable>	Aggregates IPC requests and sends them off
WorkerServer<I extends WritableComparable,V extends Writable,E extends Writable>	Interface for message communication server.

Class Summary

SendCache<I extends WritableComparable,T,B extends ByteArrayVertexIdData<I,T>>	An abstract structure for caching data indexed by vertex id, to be sent to workers in bulk.
SendEdgeCache<I extends WritableComparable,E extends Writable>	Aggregates the edges to be sent to workers so they can be sent in bulk.
SendMessageCache<I extends WritableComparable,M extends Writable>	Aggregates the messages to be sent to workers so they can be sent in bulk.
SendMutationsCache<I extends WritableComparable,V extends Writable,E extends Writable>	Aggregates the mutations to be sent to partitions so they can be sent in bulk.
SendPartitionCache<I extends WritableComparable,V extends Writable,E extends Writable>	Caches partition vertices prior to sending.
ServerData<I extends WritableComparable,V extends Writable,E extends Writable>	Anything that the server stores

Package org.apache.giraph.comm Description

Package of communication related objects, IPC service.