org.apache.giraph.comm.requests

Class AskForInputSplitRequest

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest

org.apache.giraph.comm.requests.AskForInputSplitRequest

All Implemented Interfaces:

MasterRequest, GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, org.apache.hadoop.io.Writable

public class AskForInputSplitRequest
extends WritableRequest
implements MasterRequest

A request which workers will send to master to ask it to give them splits

Field Summary

Fields inherited from class org.apache.giraph.comm.requests.WritableRequest

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
AskForInputSplitRequest() Constructor used for reflection only
AskForInputSplitRequest(InputType splitType, int workerTaskId, boolean isFirstSplit) Constructor

Method Summary

Modifier and Type	Method and Description
void	doRequest(MasterGlobalCommHandler commHandler) Execute the request
RequestType	getType() Get the type of the request

Methods inherited from class org.apache.giraph.comm.requests.WritableRequest

getClientId, getConf, getRequestId, getSerializedSize, readFields, setClientId, setConf, setRequestId, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AskForInputSplitRequest

public AskForInputSplitRequest(InputType splitType,
                               int workerTaskId,
                               boolean isFirstSplit)

Constructor

Parameters:

splitType - Type of split we are requesting

workerTaskId - Task id of worker which requested the split

isFirstSplit - Whether this is the first split a thread is requesting, or this request indicates that previously requested input split was done

AskForInputSplitRequest

public AskForInputSplitRequest()

Constructor used for reflection only

Method Detail

doRequest

public void doRequest(MasterGlobalCommHandler commHandler)

Description copied from interface: MasterRequest

Execute the request

Specified by:

doRequest in interface MasterRequest

Parameters:

commHandler - Master communication handler

getType

public RequestType getType()

Description copied from class: WritableRequest

Get the type of the request

Specified by:

getType in class WritableRequest

Returns:

Request type