cgl.imr.message
Class ReducerRequest

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

public class ReducerRequest
extends PubSubMessage

Message requesting a reducer.


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 ReducerRequest()
           
  ReducerRequest(byte[] request)
           
  ReducerRequest(JobConf jobConf, ReducerConf reduceConf, String reduceTopic, String responseTopic, String combineTopic)
           
 
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 getCombineTopic()
           
 JobConf getJobConf()
           
 ReducerConf getReduceConf()
           
 String getReduceTopic()
           
 String getResponseTopic()
           
 void setCombineTopic(String combineTopic)
           
 void setJobConf(JobConf jobConf)
           
 void setReduceConf(ReducerConf reduceConf)
           
 void setReduceTopic(String reduceTopic)
           
 void setResponseTopic(String responseTopic)
           
 
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

ReducerRequest

protected ReducerRequest()

ReducerRequest

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

ReducerRequest

public ReducerRequest(JobConf jobConf,
                      ReducerConf reduceConf,
                      String reduceTopic,
                      String responseTopic,
                      String combineTopic)
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

getCombineTopic

public String getCombineTopic()

getJobConf

public JobConf getJobConf()

getReduceConf

public ReducerConf getReduceConf()

getReduceTopic

public String getReduceTopic()

getResponseTopic

public String getResponseTopic()

setCombineTopic

public void setCombineTopic(String combineTopic)

setJobConf

public void setJobConf(JobConf jobConf)

setReduceConf

public void setReduceConf(ReducerConf reduceConf)

setReduceTopic

public void setReduceTopic(String reduceTopic)

setResponseTopic

public void setResponseTopic(String responseTopic)


For comments and suggestions please send e-mail to