cgl.imr.base
Class TaskConf

java.lang.Object
  extended by cgl.imr.base.TaskConf
All Implemented Interfaces:
TwisterConstants, TwisterSerializable

public class TaskConf
extends Object
implements TwisterConstants, TwisterSerializable

Abstract class encapsulating the common functionality of the TaskConf. Mainly handles the functionality of serializing and deserializing a StringPropertyList object.


Nested Class Summary
 
Nested classes/interfaces inherited from interface cgl.imr.base.TwisterConstants
TwisterConstants.JobState
 
Field Summary
protected  StringPropertyList propertyList
           
 
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 TaskConf()
           
  TaskConf(byte[] bytes)
           
 
Method Summary
 void addProperty(String key, String val)
           
 void fromBytes(byte[] bytes)
          Construct the StringPropertyList from the serialized bytes.
 byte[] getBytes()
          Serialize the StringPropertyList object.
 String getProperty(String key)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

propertyList

protected StringPropertyList propertyList
Constructor Detail

TaskConf

protected TaskConf()

TaskConf

public TaskConf(byte[] bytes)
         throws SerializationException
Throws:
SerializationException
Method Detail

addProperty

public void addProperty(String key,
                        String val)

fromBytes

public void fromBytes(byte[] bytes)
               throws SerializationException
Construct the StringPropertyList from the serialized bytes.

Specified by:
fromBytes in interface TwisterSerializable
Throws:
SerializationException

getBytes

public byte[] getBytes()
                throws SerializationException
Serialize the StringPropertyList object.

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

getProperty

public String getProperty(String key)


For comments and suggestions please send e-mail to