cgl.imr.message
Class TaskStatus

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

public class TaskStatus
extends PubSubMessage


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
TaskStatus(byte[] data)
           
TaskStatus(byte taskType, byte status, int taskNo, long execuationTime)
           
 
Method Summary
 void fromBytes(byte[] bytes)
          Construct the object back from a previously serialized bytes.
 byte[] getBytes()
          Serialize the object and returns the bytes.
 String getExceptionString()
           
 long getExecuationTime()
           
 int getStatus()
           
 int getTaskNo()
           
 int getTaskType()
           
 boolean isHasException()
           
 void setExceptionString(String exceptionString)
           
 void setExecuationTime(long execuationTime)
           
 void setStatus(byte status)
           
 void setTaskNo(int taskNo)
           
 void setTaskType(byte taskType)
           
 
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

TaskStatus

public TaskStatus(byte taskType,
                  byte status,
                  int taskNo,
                  long execuationTime)

TaskStatus

public TaskStatus(byte[] data)
           throws SerializationException
Throws:
SerializationException
Method Detail

fromBytes

public void fromBytes(byte[] bytes)
               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

getExceptionString

public String getExceptionString()

getExecuationTime

public long getExecuationTime()

getStatus

public int getStatus()

getTaskNo

public int getTaskNo()

getTaskType

public int getTaskType()

isHasException

public boolean isHasException()

setExceptionString

public void setExceptionString(String exceptionString)

setExecuationTime

public void setExecuationTime(long execuationTime)

setStatus

public void setStatus(byte status)

setTaskNo

public void setTaskNo(int taskNo)

setTaskType

public void setTaskType(byte taskType)


For comments and suggestions please send e-mail to