This project has retired. For details please refer to its Attic page.

Uses of Class
org.apache.hadoop.mrunit.PipelineMapReduceDriver

Packages that use PipelineMapReduceDriver

org.apache.hadoop.mrunit

Uses of PipelineMapReduceDriver in org.apache.hadoop.mrunit

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

PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withCounters(org.apache.hadoop.mapred.Counters ctrs) Sets the counters to use and returns self for fluent style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withInput(K1 key, V1 val) 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
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withInputFromString(String input) Identical to addInputFromString, but with a fluent programming style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withMapReduce(org.apache.hadoop.mapred.Mapper m, org.apache.hadoop.mapred.Reducer r) Add a Mapper and Reducer instance to the pipeline to use with this test driver using fluent 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
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withOutput(K2 key, V2 val) Functions like addOutput() but returns self for fluent programming style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withOutput(Pair<K2,V2> outputRecord) Works like addOutput(), but returns self for fluent style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withOutputFromString(String output) Identical to addOutputFromString, but with a fluent programming style