Uses of Class
org.apache.giraph.comm.requests.WritableRequest

Packages that use WritableRequest

Package	Description
org.apache.giraph.comm	Package of communication related objects, IPC service.
org.apache.giraph.comm.flow_control	Package for flow-control policies.
org.apache.giraph.comm.netty	Package for netty implementations.
org.apache.giraph.comm.netty.handler	Package for classes which handle requests and responses.
org.apache.giraph.comm.requests	Package for requests.
org.apache.giraph.utils	Package of all generic utility classes.

Uses of WritableRequest in org.apache.giraph.comm

Methods in org.apache.giraph.comm with parameters of type WritableRequest

Modifier and Type	Method and Description
void	MasterClient.sendWritableRequest(int destTaskId, WritableRequest request) Send a request to a remote server (should be already connected)
void	WorkerClient.sendWritableRequest(int destTaskId, WritableRequest request) Send a request to a remote server (should be already connected)

Uses of WritableRequest in org.apache.giraph.comm.flow_control

Methods in org.apache.giraph.comm.flow_control with parameters of type WritableRequest

Modifier and Type	Method and Description
void	StaticFlowControl.sendRequest(int destTaskId, WritableRequest request)
void	CreditBasedFlowControl.sendRequest(int destTaskId, WritableRequest request)
void	NoOpFlowControl.sendRequest(int destTaskId, WritableRequest request)
void	FlowControl.sendRequest(int destTaskId, WritableRequest request) This method is called by a network client for all requests that should be handled by a *remote* task.

Uses of WritableRequest in org.apache.giraph.comm.netty

Methods in org.apache.giraph.comm.netty with parameters of type WritableRequest

Modifier and Type	Method and Description
void	NettyWorkerClientRequestProcessor.doRequest(WorkerInfo workerInfo, WritableRequest writableRequest) When doing the request, short circuit if it is local
Long	NettyClient.doSend(int destTaskId, WritableRequest request) Actual send of a request.
void	NettyMasterClient.sendWritableRequest(int destTaskId, WritableRequest request)
void	NettyWorkerClient.sendWritableRequest(int destTaskId, WritableRequest request)
void	NettyClient.sendWritableRequest(int destTaskId, WritableRequest request) Send a request to a remote server honoring the flow control mechanism (should be already connected)

Uses of WritableRequest in org.apache.giraph.comm.netty.handler

Methods in org.apache.giraph.comm.netty.handler that return WritableRequest

Modifier and Type	Method and Description
protected WritableRequest	SaslClientHandler.decode(io.netty.channel.ChannelHandlerContext ctx, Object msg) Decode the message read by handler
WritableRequest	RequestInfo.getRequest()

Constructors in org.apache.giraph.comm.netty.handler with parameters of type WritableRequest

Constructor and Description
RequestInfo(InetSocketAddress destinationAddress, WritableRequest request) Constructor.

Uses of WritableRequest in org.apache.giraph.comm.requests

Subclasses of WritableRequest in org.apache.giraph.comm.requests

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

Methods in org.apache.giraph.comm.requests that return types with arguments of type WritableRequest

Modifier and Type	Method and Description
Class<? extends WritableRequest>	RequestType.getRequestClass() Get class of request which this type corresponds to

Uses of WritableRequest in org.apache.giraph.utils

Methods in org.apache.giraph.utils that return WritableRequest

Modifier and Type	Method and Description
static WritableRequest	RequestUtils.decodeWritableRequest(io.netty.buffer.ByteBuf buf, WritableRequest request) decodeWritableRequest based on predicate

Methods in org.apache.giraph.utils with parameters of type WritableRequest

Modifier and Type	Method and Description
static WritableRequest	RequestUtils.decodeWritableRequest(io.netty.buffer.ByteBuf buf, WritableRequest request) decodeWritableRequest based on predicate