I
- Vertex idT
- DataB
- Specialization of
VertexIdData
for Tpublic abstract class SendWorkerDataRequest<I extends org.apache.hadoop.io.WritableComparable,T,B extends VertexIdData<I,T>> extends WritableRequest implements WorkerRequest
Modifier and Type | Field and Description |
---|---|
protected PairList<Integer,B> |
partitionVertexData
All data for a group of vertices, organized by partition, which
are owned by a single (destination) worker.
|
conf, UNKNOWN_SIZE
Constructor and Description |
---|
SendWorkerDataRequest()
Constructor used for reflection only
|
SendWorkerDataRequest(PairList<Integer,B> partVertData)
Constructor used to send request.
|
Modifier and Type | Method and Description |
---|---|
abstract B |
createVertexIdData()
Create a new
VertexIdData
specialized for the use case. |
int |
getSerializedSize()
Get the size of the request in serialized form.
|
void |
readFieldsRequest(DataInput input)
Serialize the request
|
void |
writeRequest(DataOutput output)
Deserialize the request
|
getClientId, getConf, getRequestId, getType, readFields, setClientId, setConf, setRequestId, write
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
doRequest
public SendWorkerDataRequest()
public abstract B createVertexIdData()
VertexIdData
specialized for the use case.VertexIdData
public void readFieldsRequest(DataInput input) throws IOException
WritableRequest
input
- Input to read fields fromIOException
public void writeRequest(DataOutput output) throws IOException
WritableRequest
output
- Output to write the request toIOException
public int getSerializedSize()
WritableRequest
getSerializedSize
in class WritableRequest
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.