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
 



Copyright © 2013 The Apache Software Foundation. All Rights Reserved.