cgl.imr.base.impl
Class ReducerConf

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

public class ReducerConf
extends Object
implements TwisterConstants, TwisterSerializable

Configuration for Reducer. Has a task no and a property bag.


Nested Class Summary
 
Nested classes/interfaces inherited from interface cgl.imr.base.TwisterConstants
TwisterConstants.JobState
 
Field Summary
 
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
ReducerConf(byte[] bytes, ClassLoader classLoader)
           
ReducerConf(int taskNo)
           
ReducerConf(int taskNo, Value value)
           
 
Method Summary
 void fromBytes(byte[] bytes)
          Construct the object from the Serialized bytes.
 byte[] getBytes()
          Serialize the object.
 int getReduceTaskNo()
           
 Value getValue()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ReducerConf

public ReducerConf(byte[] bytes,
                   ClassLoader classLoader)
            throws SerializationException
Throws:
SerializationException

ReducerConf

public ReducerConf(int taskNo)

ReducerConf

public ReducerConf(int taskNo,
                   Value value)
Method Detail

fromBytes

public void fromBytes(byte[] bytes)
               throws SerializationException
Construct the object from the Serialized bytes.

Specified by:
fromBytes in interface TwisterSerializable
Throws:
SerializationException

getBytes

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

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

getReduceTaskNo

public int getReduceTaskNo()

getValue

public Value getValue()


For comments and suggestions please send e-mail to