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

Uses of Class
org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Packages that use MapReduceDriver
org.apache.hadoop.mrunit.mapreduce   
 

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

Methods in org.apache.hadoop.mrunit.mapreduce that return MapReduceDriver
static
<K1,V1,K2,V2,K3,V3>
MapReduceDriver<K1,V1,K2,V2,K3,V3>
MapReduceDriver.newMapReduceDriver()
          Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.
static
<K1,V1,K2,V2,K3,V3>
MapReduceDriver<K1,V1,K2,V2,K3,V3>
MapReduceDriver.newMapReduceDriver(org.apache.hadoop.mapreduce.Mapper<K1,V1,K2,V2> mapper, org.apache.hadoop.mapreduce.Reducer<K2,V2,K3,V3> reducer)
          Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.
static
<K1,V1,K2,V2,K3,V3>
MapReduceDriver<K1,V1,K2,V2,K3,V3>
MapReduceDriver.newMapReduceDriver(org.apache.hadoop.mapreduce.Mapper<K1,V1,K2,V2> mapper, org.apache.hadoop.mapreduce.Reducer<K2,V2,K3,V3> reducer, org.apache.hadoop.mapreduce.Reducer<K2,V2,K2,V2> combiner)
          Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withCombiner(org.apache.hadoop.mapreduce.Reducer<K2,V2,K2,V2> c)
          Identical to setCombiner(), but with fluent programming style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withConfiguration(org.apache.hadoop.conf.Configuration configuration)
           
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withCounter(Enum e, long expectedValue)
           
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withCounter(String g, String n, long e)
           
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withCounters(org.apache.hadoop.mapreduce.Counters ctrs)
          Sets the counters to use and returns self for fluent style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withInput(K1 key, V1 val)
          Identical to addInput() but returns self for fluent programming style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withInput(Pair<K1,V1> input)
          Identical to addInput() but returns self for fluent programming style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withInputFromString(String input)
          Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withKeyGroupingComparator(org.apache.hadoop.io.RawComparator<K2> groupingComparator)
          Identical to MapReduceDriverBase.setKeyGroupingComparator(RawComparator), but with a fluent programming style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withKeyOrderComparator(org.apache.hadoop.io.RawComparator<K2> orderComparator)
          Identical to MapReduceDriverBase.setKeyOrderComparator(RawComparator), but with a fluent programming style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withMapper(org.apache.hadoop.mapreduce.Mapper<K1,V1,K2,V2> m)
          Sets the Mapper instance to use and returns self for fluent style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withOutput(K3 key, V3 val)
          Functions like addOutput() but returns self for fluent programming style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withOutput(Pair<K3,V3> outputRecord)
          Works like addOutput(), but returns self for fluent style
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withOutputFromString(String output)
          Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables
 MapReduceDriver<K1,V1,K2,V2,K3,V3> MapReduceDriver.withReducer(org.apache.hadoop.mapreduce.Reducer<K2,V2,K3,V3> r)
          Identical to setReducer(), but with fluent programming style
 



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