org.apache.hadoop.mrunit.mapreduce.mock
Class MockContextWrapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

java.lang.Object
  org.apache.hadoop.mrunit.mapreduce.mock.MockContextWrapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

Direct Known Subclasses:

MockMapContextWrapper, MockReduceContextWrapper

public abstract class MockContextWrapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
extends Object

Field Summary

protected org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.mapreduce.Counters	counters
protected List<Pair<KEYOUT,VALUEOUT>>	outputs

Constructor Summary

MockContextWrapper(org.apache.hadoop.mapreduce.Counters counters, org.apache.hadoop.conf.Configuration conf)

Method Summary

protected void

createCommon(org.apache.hadoop.mapreduce.TaskInputOutputContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT> context)

Methods inherited from class java.lang.Object

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

Field Detail

counters

protected final org.apache.hadoop.mapreduce.Counters counters

conf

protected final org.apache.hadoop.conf.Configuration conf

outputs

protected final List<Pair<KEYOUT,VALUEOUT>> outputs

Constructor Detail

MockContextWrapper

public MockContextWrapper(org.apache.hadoop.mapreduce.Counters counters,
                          org.apache.hadoop.conf.Configuration conf)

Method Detail

createCommon

protected void createCommon(org.apache.hadoop.mapreduce.TaskInputOutputContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT> context)
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException