Package org.apache.giraph.comm.requests

Package for requests.

See: Description

Interface Summary

Interface	Description
MasterRequest	Interface for requests sent to master to extend
WorkerRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Interface for requests sent to worker to extend

Class Summary

Class	Description
AddressesAndPartitionsRequest	Request for master sending addresses and partitions to workers
AskForInputSplitRequest	A request which workers will send to master to ask it to give them splits
ByteArrayRequest	Abstract request which has a byte array as its data
ByteArrayWithSenderTaskIdRequest	Abstract request which has a byte array and task id of the sender as its data
PartitionStatsRequest	Request for sending partition stats from workers to master
ReplyWithInputSplitRequest	A request which master will send to workers to give them splits
SaslCompleteRequest	Reply from server to client after SASL authentication completes.
SaslTokenMessageRequest	Send and receive SASL tokens.
SendAggregatorsToOwnerRequest	Request to send final aggregatd values from master to worker which owns the aggregators
SendAggregatorsToWorkerRequest	Request to send final aggregated values from worker which owns them to other workers
SendPartitionCurrentMessagesRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>	Send a collection of vertex messages for a partition.
SendPartitionMutationsRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Send a collection of vertex mutations for a partition.
SendReducedToMasterRequest	Request to send final aggregated values from worker which owns aggregators to the master
SendResumeRequest	Send to a worker a signal to resume sending messages to sender worker.
SendVertexRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Send a collection of vertices for a partition.
SendWorkerAggregatorsRequest	Request to send partial aggregated values for current superstep (values which were computed by one worker's vertices)
SendWorkerDataRequest<I extends org.apache.hadoop.io.WritableComparable,T,B extends VertexIdData<I,T>>	Abstract request to send a collection of data, indexed by vertex id, for a partition.
SendWorkerEdgesRequest<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>	Send a collection of edges for a partition.
SendWorkerMessagesRequest<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Send a collection of vertex messages for a partition.
SendWorkerOneMessageToManyRequest<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Send a collection of ByteArrayOneMessageToManyIds messages to a worker.
SendWorkerToWorkerMessageRequest	Request which sends any Writable message from one worker to another
SendWorkerVerticesRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Send to a worker one or more partitions of vertices
WritableRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Interface for requests to implement

Enum Summary

Enum	Description
RequestType	Type of the request

Package org.apache.giraph.comm.requests Description

Package for requests.