I
- Vertex idV
- Vertex dataE
- Edge datapublic class SendPartitionMutationsRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends WritableRequest<I,V,E> implements WorkerRequest<I,V,E>
conf, UNKNOWN_SIZE
Constructor and Description |
---|
SendPartitionMutationsRequest()
Constructor used for reflection only
|
SendPartitionMutationsRequest(int partitionId,
Map<I,VertexMutations<I,V,E>> vertexIdMutations)
Constructor used to send request.
|
Modifier and Type | Method and Description |
---|---|
void |
doRequest(ServerData<I,V,E> serverData)
Execute the request
|
int |
getSerializedSize()
Get the size of the request in serialized form.
|
RequestType |
getType()
Get the type of the request
|
void |
readFieldsRequest(DataInput input)
Serialize the request
|
void |
writeRequest(DataOutput output)
Deserialize the request
|
getClientId, getConf, getRequestId, readFields, setClientId, setConf, setRequestId, write
public SendPartitionMutationsRequest()
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 RequestType getType()
WritableRequest
getType
in class WritableRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public void doRequest(ServerData<I,V,E> serverData)
WorkerRequest
doRequest
in interface WorkerRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
serverData
- Accessible data that can be mutated per the requestpublic int getSerializedSize()
WritableRequest
getSerializedSize
in class WritableRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.