I
- Vertex idM
- Message datapublic class SendWorkerMessagesRequest<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> extends SendWorkerDataRequest<I,M,VertexIdMessages<I,M>>
partitionVertexData
conf, UNKNOWN_SIZE
Constructor and Description |
---|
SendWorkerMessagesRequest()
Default constructor
|
SendWorkerMessagesRequest(PairList<Integer,VertexIdMessages<I,M>> partVertMsgs)
Constructor used to send request.
|
Modifier and Type | Method and Description |
---|---|
VertexIdMessages<I,M> |
createVertexIdData()
Create a new
VertexIdData
specialized for the use case. |
void |
doRequest(ServerData serverData)
Execute the request
|
RequestType |
getType()
Get the type of the request
|
getSerializedSize, readFieldsRequest, writeRequest
getClientId, getConf, getRequestId, readFields, setClientId, setConf, setRequestId, write
public SendWorkerMessagesRequest()
public SendWorkerMessagesRequest(PairList<Integer,VertexIdMessages<I,M>> partVertMsgs)
partVertMsgs
- Map of remote partitions =>
VertexIdMessagespublic VertexIdMessages<I,M> createVertexIdData()
SendWorkerDataRequest
VertexIdData
specialized for the use case.createVertexIdData
in class SendWorkerDataRequest<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,VertexIdMessages<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>>
VertexIdData
public RequestType getType()
WritableRequest
getType
in class WritableRequest
public void doRequest(ServerData serverData)
WorkerRequest
serverData
- Accessible data that can be mutated per the requestCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.