I
- Vertex idE
- Edge datapublic class SendWorkerEdgesRequest<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> extends SendWorkerDataRequest<I,Edge<I,E>,VertexIdEdges<I,E>>
partitionVertexData
conf, UNKNOWN_SIZE
Constructor and Description |
---|
SendWorkerEdgesRequest()
Constructor used for reflection only
|
SendWorkerEdgesRequest(PairList<Integer,VertexIdEdges<I,E>> partVertEdges)
Constructor used to send request.
|
Modifier and Type | Method and Description |
---|---|
VertexIdEdges<I,E> |
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 SendWorkerEdgesRequest()
public SendWorkerEdgesRequest(PairList<Integer,VertexIdEdges<I,E>> partVertEdges)
partVertEdges
- Map of remote partitions =>
ByteArrayVertexIdEdgespublic VertexIdEdges<I,E> createVertexIdData()
SendWorkerDataRequest
VertexIdData
specialized for the use case.createVertexIdData
in class SendWorkerDataRequest<I extends org.apache.hadoop.io.WritableComparable,Edge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>,VertexIdEdges<I extends org.apache.hadoop.io.WritableComparable,E 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.