org.approvaltests.hadoop.version2

Class ReducerWrapper<KeyIn,ValueIn,KeyOut,ValueOut>

java.lang.Object

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

All Implemented Interfaces:

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

public class ReducerWrapper<KeyIn,ValueIn,KeyOut,ValueOut>
extends Object
implements SmartReducer<KeyIn,ValueIn,KeyOut,ValueOut>

Constructor Summary

Constructors

Constructor and Description
ReducerWrapper(org.apache.hadoop.mapred.Reducer<KeyIn,ValueIn,KeyOut,ValueOut> reducer, 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	reduce(KeyIn arg0, Iterator<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

ReducerWrapper

public ReducerWrapper(org.apache.hadoop.mapred.Reducer<KeyIn,ValueIn,KeyOut,ValueOut> reducer,
                      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>

reduce

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

Specified by:

reduce in interface org.apache.hadoop.mapred.Reducer<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