Package | Description |
---|---|
org.apache.giraph.comm.netty.handler |
Package for classes which handle requests and responses.
|
org.apache.giraph.comm.requests |
Package for requests.
|
Modifier and Type | Method and Description |
---|---|
void |
WorkerRequestServerHandler.processRequest(WorkerRequest<I,V,E> request) |
Modifier and Type | Class and Description |
---|---|
class |
AddressesAndPartitionsRequest
Request for master sending addresses and partitions to workers
|
class |
ReplyWithInputSplitRequest
A request which master will send to workers to give them splits
|
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 |
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
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.