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.