public class SendAggregatorsToOwnerRequest extends ByteArrayWithSenderTaskIdRequest implements WorkerRequest
conf, UNKNOWN_SIZE
Constructor and Description |
---|
SendAggregatorsToOwnerRequest()
Constructor used for reflection only
|
SendAggregatorsToOwnerRequest(byte[] data,
int senderTaskId)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
doRequest(ServerData serverData)
Execute the request
|
RequestType |
getType()
Get the type of the request
|
getSenderTaskId, getSerializedSize
getData, getDataInput, getUnsafeByteArrayInput
getClientId, getConf, getRequestId, readFields, setClientId, setConf, setRequestId, write
public SendAggregatorsToOwnerRequest(byte[] data, int senderTaskId)
data
- Serialized aggregator datasenderTaskId
- Sender task idpublic SendAggregatorsToOwnerRequest()
public void doRequest(ServerData serverData)
WorkerRequest
doRequest
in interface WorkerRequest
serverData
- Accessible data that can be mutated per the requestpublic RequestType getType()
WritableRequest
getType
in class WritableRequest
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.