Uses of Class
org.apache.hadoop.mrunit.types.Pair

Packages that use Pair

org.apache.hadoop.mrunit
org.apache.hadoop.mrunit.mapreduce
org.apache.hadoop.mrunit.types

Uses of Pair in org.apache.hadoop.mrunit

Fields in org.apache.hadoop.mrunit with type parameters of type Pair

protected List<Pair<Enum<?>,Long>>	TestDriver.expectedEnumCounters
protected List<Pair<K2,V2>>	TestDriver.expectedOutputs
protected List<Pair<Pair<String,String>,Long>>	TestDriver.expectedStringCounters
protected List<Pair<Pair<String,String>,Long>>	TestDriver.expectedStringCounters
protected List<Pair<K1,V1>>	MapReduceDriverBase.inputList
protected List<Pair<K1,V1>>	MapDriverBase.inputs
protected List<Pair<K1,List<V1>>>	ReduceDriverBase.inputs

Methods in org.apache.hadoop.mrunit that return Pair

protected <S,E> Pair<S,E>	TestDriver.copyPair(S first, E second)
static Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>	TestDriver.parseTabbedPair(String tabSeparatedPair) Split "key \t val" into Pair(Text(key), Text(val))

Methods in org.apache.hadoop.mrunit that return types with arguments of type Pair

List<Pair<Enum<?>,Long>>	TestDriver.getExpectedEnumCounters()
List<Pair<K2,V2>>	TestDriver.getExpectedOutputs()
List<Pair<Pair<String,String>,Long>>	TestDriver.getExpectedStringCounters()
List<Pair<Pair<String,String>,Long>>	TestDriver.getExpectedStringCounters()
List<Pair<org.apache.hadoop.mapred.Mapper,org.apache.hadoop.mapred.Reducer>>	PipelineMapReduceDriver.getMapReducePipeline()
List<Pair<K2,V2>>	PipelineMapReduceDriver.run()
abstract List<Pair<K2,V2>>	TestDriver.run() Runs the test but returns the result set instead of validating it (ignores any addOutput(), etc calls made before this)
List<Pair<K2,V2>>	MapDriver.run()
abstract List<Pair<K3,V3>>	MapReduceDriverBase.run()
List<Pair<K2,V2>>	ReduceDriver.run()
abstract List<Pair<K2,V2>>	MapDriverBase.run()
List<Pair<K3,V3>>	MapReduceDriver.run()
abstract List<Pair<K2,V2>>	ReduceDriverBase.run()
List<Pair<K2,V2>>	TestDriver.run(boolean validateCounters) Runs the test but returns the result set instead of validating it (ignores any addOutput(), etc calls made before this).
List<Pair<K2,List<V2>>>	MapReduceDriverBase.shuffle(List<Pair<K2,V2>> mapOutputs) Take the outputs from the Mapper, combine all values for the same key, and sort them by key.

Methods in org.apache.hadoop.mrunit with parameters of type Pair

void	ReduceDriverBase.addInput(Pair<K1,List<V1>> input) Add input (K, V*) to send to the Reducer
void	PipelineMapReduceDriver.addInput(Pair<K1,V1> input) Adds an input to send to the Mapper
void	MapReduceDriverBase.addInput(Pair<K1,V1> input) Adds an input to send to the Mapper
void	MapDriverBase.addInput(Pair<K1,V1> input) Adds an input to send to the mapper
void	PipelineMapReduceDriver.addMapReduce(Pair<org.apache.hadoop.mapred.Mapper,org.apache.hadoop.mapred.Reducer> p) Add a Mapper and Reducer instance to the pipeline to use with this test driver
void	TestDriver.addOutput(Pair<K2,V2> outputRecord) Adds an output (k, v) pair we expect
void	MapDriverBase.setInput(Pair<K1,V1> inputRecord) Sets the input to send to the mapper
T	ReduceDriverBase.withInput(Pair<K1,List<V1>> input) Identical to addInput() but returns self for fluent programming style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withInput(Pair<K1,V1> input) Identical to addInput() but returns self for fluent programming style
T	MapReduceDriverBase.withInput(Pair<K1,V1> input) Identical to addInput() but returns self for fluent programming style
T	MapDriverBase.withInput(Pair<K1,V1> inputRecord) Identical to setInput() but returns self for fluent programming style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withMapReduce(Pair<org.apache.hadoop.mapred.Mapper,org.apache.hadoop.mapred.Reducer> p) Add a Mapper and Reducer instance to the pipeline to use with this test driver using fluent style
T	TestDriver.withOutput(Pair<K2,V2> outputRecord) Works like addOutput(), but returns self for fluent style

Method parameters in org.apache.hadoop.mrunit with type arguments of type Pair

void	ReduceDriverBase.addAll(List<Pair<K1,List<V1>>> inputs) Adds input to send to the Reducer
void	PipelineMapReduceDriver.addAll(List<Pair<K1,V1>> inputs) Adds list of inputs to send to the mapper
void	MapReduceDriverBase.addAll(List<Pair<K1,V1>> inputs) Adds input to send to the mapper
void	MapDriverBase.addAll(List<Pair<K1,V1>> inputs) Adds list of inputs to send to the mapper
void	TestDriver.addAllOutput(List<Pair<K2,V2>> outputRecords) Adds output (k, v)* pairs we expect
static <K1,V1,K2,V2> PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.newPipelineMapReduceDriver(List<Pair<org.apache.hadoop.mapred.Mapper,org.apache.hadoop.mapred.Reducer>> pipeline) Returns a new PipelineMapReduceDriver without having to specify the generic types on the right hand side of the object create statement.
List<Pair<K2,List<V2>>>	MapReduceDriverBase.shuffle(List<Pair<K2,V2>> mapOutputs) Take the outputs from the Mapper, combine all values for the same key, and sort them by key.
protected void	TestDriver.validate(List<Pair<K2,V2>> outputs, boolean orderMatters) check the outputs against the expected inputs in record
T	ReduceDriverBase.withAll(List<Pair<K1,List<V1>>> inputs) Identical to addAll() but returns self for fluent programming style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withAll(List<Pair<K1,V1>> inputRecords) Identical to addAll() but returns self for fluent programming style
T	MapReduceDriverBase.withAll(List<Pair<K1,V1>> inputs) Identical to addAll() but returns self for fluent programming style
T	MapDriverBase.withAll(List<Pair<K1,V1>> inputRecords) Identical to addAll() but returns self for fluent programming style
T	TestDriver.withAllOutput(List<Pair<K2,V2>> outputRecords) Functions like addAllOutput() but returns self for fluent programming style

Constructor parameters in org.apache.hadoop.mrunit with type arguments of type Pair

PipelineMapReduceDriver(List<Pair<org.apache.hadoop.mapred.Mapper,org.apache.hadoop.mapred.Reducer>> pipeline)

Uses of Pair in org.apache.hadoop.mrunit.mapreduce

Methods in org.apache.hadoop.mrunit.mapreduce that return types with arguments of type Pair

List<Pair<K2,V2>>	MapDriver.run()
List<Pair<K2,V2>>	ReduceDriver.run()
List<Pair<K3,V3>>	MapReduceDriver.run()

Uses of Pair in org.apache.hadoop.mrunit.types

Methods in org.apache.hadoop.mrunit.types with parameters of type Pair

int	Pair.FirstElemComparator.compare(Pair<S,T> p1, Pair<S,T> p2)
int	Pair.FirstElemComparator.compare(Pair<S,T> p1, Pair<S,T> p2)
int	Pair.SecondElemComparator.compare(Pair<S,T> p1, Pair<S,T> p2)
int	Pair.SecondElemComparator.compare(Pair<S,T> p1, Pair<S,T> p2)
int	Pair.compareTo(Pair<S,T> p)