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.