cgl.imr.base
Interface MapTask


public interface MapTask

This interface encapsulates the methods that need to be supported by a user defined Map task.


Method Summary
 void close()
          Any cleanup goes here.
 void configure(JobConf jobConf, MapperConf mapConf)
          Use to configure a Map task for static data/or other configurations.
 void map(MapOutputCollector collector, Key key, Value val)
          Should perform the user defined Map operation for the passed pairs.
 

Method Detail

close

void close()
           throws TwisterException
Any cleanup goes here.

Throws:
TwisterException

configure

void configure(JobConf jobConf,
               MapperConf mapConf)
               throws TwisterException
Use to configure a Map task for static data/or other configurations.

Parameters:
jobConf - Job configuration object.
mapConf - Configurations specific to this Map task.
Throws:
TwisterException

map

void map(MapOutputCollector collector,
         Key key,
         Value val)
         throws TwisterException
Should perform the user defined Map operation for the passed pairs.

Parameters:
collector - Collector to accumilate the output of the Map task.
key - Input Key for the map task (Not much used for a meaning full work.)
val - Input Value for the map task. This can be used to pass any variable data to the Map task. The map reduce client can pass this data directly via streaming using the TwisterDriver.
Throws:
TwisterException


For comments and suggestions please send e-mail to