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

static <K1,V1,K2,V2> PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.newPipelineMapReduceDriver() Returns a new PipelineMapReduceDriver without having to specify the generic types on the right hand side of the object create statement.
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.
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withAll(List<Pair<K1,V1>> inputRecords) Identical to addAll() but returns self for fluent programming style
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) Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withMapInputPath(org.apache.hadoop.fs.Path mapInputPath)
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