|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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
|
MapReduceDriver.newMapReduceDriver()
Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement. |
|
static
|
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. |
|
MapReduceDriver<K1,V1,K2,V2,K3,V3> |
MapReduceDriver.withConfiguration(org.apache.hadoop.conf.Configuration configuration)
|
|
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)
Identical to addInputFromString, but with a fluent programming style |
|
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)
Identical to addOutputFromString, but with a fluent programming style |
|
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 |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |