public class AskForInputSplitRequest extends WritableRequest implements MasterRequest
conf, UNKNOWN_SIZE
Constructor and Description |
---|
AskForInputSplitRequest()
Constructor used for reflection only
|
AskForInputSplitRequest(InputType splitType,
int workerTaskId,
boolean isFirstSplit)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
doRequest(MasterGlobalCommHandler commHandler)
Execute the request
|
RequestType |
getType()
Get the type of the request
|
getClientId, getConf, getRequestId, getSerializedSize, readFields, setClientId, setConf, setRequestId, write
public AskForInputSplitRequest(InputType splitType, int workerTaskId, boolean isFirstSplit)
splitType
- Type of split we are requestingworkerTaskId
- Task id of worker which requested the splitisFirstSplit
- Whether this is the first split a thread is requesting,
or this request indicates that previously requested input split was donepublic AskForInputSplitRequest()
public void doRequest(MasterGlobalCommHandler commHandler)
MasterRequest
doRequest
in interface MasterRequest
commHandler
- Master communication handlerpublic RequestType getType()
WritableRequest
getType
in class WritableRequest
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.