public class SendWorkerToWorkerMessageRequest extends WritableRequest implements WorkerRequest<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
conf, UNKNOWN_SIZE
Constructor and Description |
---|
SendWorkerToWorkerMessageRequest()
Default constructor, for reflection
|
SendWorkerToWorkerMessageRequest(org.apache.hadoop.io.Writable message)
Constructor with message
|
Modifier and Type | Method and Description |
---|---|
void |
doRequest(ServerData<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> serverData)
Execute the request
|
RequestType |
getType()
Get the type of the request
|
getClientId, getConf, getRequestId, getSerializedSize, readFields, setClientId, setConf, setRequestId, write
public SendWorkerToWorkerMessageRequest()
public SendWorkerToWorkerMessageRequest(org.apache.hadoop.io.Writable message)
message
- Message sentpublic RequestType getType()
WritableRequest
getType
in class WritableRequest
public void doRequest(ServerData<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> serverData)
WorkerRequest
doRequest
in interface WorkerRequest<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
serverData
- Accessible data that can be mutated per the requestCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.