cgl.imr.message
Class MapTaskRequest

java.lang.Object
  extended by cgl.imr.message.PubSubMessage
      extended by cgl.imr.message.MapTaskRequest
All Implemented Interfaces:
TwisterConstants, TwisterSerializable

public class MapTaskRequest
extends PubSubMessage

Request for map tasks.


Nested Class Summary
 
Nested classes/interfaces inherited from interface cgl.imr.base.TwisterConstants
TwisterConstants.JobState
 
Field Summary
 
Fields inherited from class cgl.imr.message.PubSubMessage
hasRefMsgId, refMsgId
 
Fields inherited from interface cgl.imr.base.TwisterConstants
COMBINE_INPUT, COMBINE_TOPIC_BASE, DIR_LIST_REQ, DIR_LIST_RES, FAILED, FIXED_DATA_FILE, FIXED_DATA_MODEL, HEP_DATA_STRING, MAP_ITERATIONS_OVER, MAP_REDUCE_TOPIC_BASE, MAP_TASK, MAP_TASK_REQUEST, MAP_WORKER_STARTED, MAPPER_REQUEST, MONITOR_REQUEST, MONITOR_RESPONSE, MONITOR_SLEEP_TIME, NEW_JOB_REQUEST, NEW_JOB_RESPONSE, NUM_MAP_TASKS, NUM_REDUCE_TASKS, PARTITION_FILE_RESPONSE_TOPIC_BASE, PARTITION_FILE_SPLIT_PATTERN, PROPERTIES_FILE, REDUCE_INPUT, REDUCE_RESPONSE, REDUCE_TASK, REDUCE_TASK_REQUEST, REDUCE_TOPIC_BASE, REDUCE_WORKER_REQUEST, RESPONSE_TOPIC_BASE, SEND_RECV_MAX_SLEEP_TIME, SEND_RECV_SLEEP_TIME, SUCCESS, TASK_STATUS, WORKER_RESPONSE
 
Constructor Summary
protected MapTaskRequest()
           
  MapTaskRequest(byte[] request)
           
  MapTaskRequest(int mapTaskNo)
           
 
Method Summary
 void addKeyValue(Key key, Value val)
           
 void fromBytes(byte[] messageBytes)
          Construct the object back from a previously serialized bytes.
 byte[] getBytes()
          Serialize the object and returns the bytes.
 String getJobId()
           
 Map<Key,Value> getKeyValues()
           
 int getMapTaskNo()
           
 String getResponseTopic()
           
 String getSinkBase()
           
 void setJobId(String jobId)
           
 void setKeyValues(Map<Key,Value> keyValues)
           
 void setResponseTopic(String responseTopic)
           
 void setSinkBase(String sinkBase)
           
 
Methods inherited from class cgl.imr.message.PubSubMessage
getRefMessageId, readRefIdIfAny, serializeRefId, setRefMessageId
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MapTaskRequest

protected MapTaskRequest()

MapTaskRequest

public MapTaskRequest(byte[] request)
               throws SerializationException
Throws:
SerializationException

MapTaskRequest

public MapTaskRequest(int mapTaskNo)
Method Detail

addKeyValue

public void addKeyValue(Key key,
                        Value val)

fromBytes

public void fromBytes(byte[] messageBytes)
               throws SerializationException
Description copied from interface: TwisterSerializable
Construct the object back from a previously serialized bytes.

Specified by:
fromBytes in interface TwisterSerializable
Specified by:
fromBytes in class PubSubMessage
Throws:
SerializationException

getBytes

public byte[] getBytes()
                throws SerializationException
Description copied from interface: TwisterSerializable
Serialize the object and returns the bytes.

Specified by:
getBytes in interface TwisterSerializable
Specified by:
getBytes in class PubSubMessage
Returns:
byte[] of serialized object.
Throws:
SerializationException

getJobId

public String getJobId()

getKeyValues

public Map<Key,Value> getKeyValues()

getMapTaskNo

public int getMapTaskNo()

getResponseTopic

public String getResponseTopic()

getSinkBase

public String getSinkBase()

setJobId

public void setJobId(String jobId)

setKeyValues

public void setKeyValues(Map<Key,Value> keyValues)

setResponseTopic

public void setResponseTopic(String responseTopic)

setSinkBase

public void setSinkBase(String sinkBase)


For comments and suggestions please send e-mail to