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.
|
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)
|
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.
|
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)
|
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() |
Constructor and Description |
---|
RequestInfo(InetSocketAddress destinationAddress,
WritableRequest request)
Constructor.
|
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
|
Modifier and Type | Method and Description |
---|---|
Class<? extends WritableRequest> |
RequestType.getRequestClass()
Get class of request which this type corresponds to
|
Modifier and Type | Method and Description |
---|---|
static WritableRequest |
RequestUtils.decodeWritableRequest(io.netty.buffer.ByteBuf buf,
WritableRequest request)
decodeWritableRequest based on predicate
|
Modifier and Type | Method and Description |
---|---|
static WritableRequest |
RequestUtils.decodeWritableRequest(io.netty.buffer.ByteBuf buf,
WritableRequest request)
decodeWritableRequest based on predicate
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.