org.approvaltests.hadoop.version2

Class MapperWrapper<KeyIn,ValueIn,KeyOut,ValueOut>

java.lang.Object

org.approvaltests.hadoop.version2.MapperWrapper<KeyIn,ValueIn,KeyOut,ValueOut>

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<KeyIn,ValueIn,KeyOut,ValueOut>, Transform<KeyIn,ValueIn,KeyOut,ValueOut>, SmartMapper<KeyIn,ValueIn,KeyOut,ValueOut>

public class MapperWrapper<KeyIn,ValueIn,KeyOut,ValueOut>
extends Object
implements SmartMapper<KeyIn,ValueIn,KeyOut,ValueOut>

Constructor Summary

Constructors

Constructor and Description
MapperWrapper(org.apache.hadoop.mapred.Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper, Class<KeyIn> keyIn, Class<ValueIn> valueIn, Class<KeyOut> keyOut, Class<ValueOut> valueOut)

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(org.apache.hadoop.mapred.JobConf arg0)
Class<KeyIn>	getKeyInType()
Class<KeyOut>	getKeyOutType()
Class<ValueIn>	getValueInType()
Class<ValueOut>	getValueOutType()
void	map(KeyIn arg0, ValueIn arg1, org.apache.hadoop.mapred.OutputCollector<KeyOut,ValueOut> arg2, org.apache.hadoop.mapred.Reporter arg3)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapperWrapper

public MapperWrapper(org.apache.hadoop.mapred.Mapper<KeyIn,ValueIn,KeyOut,ValueOut> mapper,
                     Class<KeyIn> keyIn,
                     Class<ValueIn> valueIn,
                     Class<KeyOut> keyOut,
                     Class<ValueOut> valueOut)

Method Detail

getKeyInType

public Class<KeyIn> getKeyInType()

Specified by:

getKeyInType in interface Transform<KeyIn,ValueIn,KeyOut,ValueOut>

getValueInType

public Class<ValueIn> getValueInType()

Specified by:

getValueInType in interface Transform<KeyIn,ValueIn,KeyOut,ValueOut>

getKeyOutType

public Class<KeyOut> getKeyOutType()

Specified by:

getKeyOutType in interface Transform<KeyIn,ValueIn,KeyOut,ValueOut>

getValueOutType

public Class<ValueOut> getValueOutType()

Specified by:

getValueOutType in interface Transform<KeyIn,ValueIn,KeyOut,ValueOut>

map

public void map(KeyIn arg0,
                ValueIn arg1,
                org.apache.hadoop.mapred.OutputCollector<KeyOut,ValueOut> arg2,
                org.apache.hadoop.mapred.Reporter arg3)
         throws IOException

Specified by:

map in interface org.apache.hadoop.mapred.Mapper<KeyIn,ValueIn,KeyOut,ValueOut>

Throws:

IOException

configure

public void configure(org.apache.hadoop.mapred.JobConf arg0)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException