Package | Description |
---|---|
org.apache.hadoop.mrunit |
|
Modifier and Type | Method and Description |
---|---|
static <K1,V1,K2,V2> |
ReduceDriver.newReduceDriver()
Returns a new ReduceDriver without having to specify the generic types on
the right hand side of the object create statement.
|
static <K1,V1,K2,V2> |
ReduceDriver.newReduceDriver(org.apache.hadoop.mapred.Reducer<K1,V1,K2,V2> reducer)
Returns a new ReduceDriver without having to specify the generic types on
the right hand side of the object create statement.
|
ReduceDriver<K1,V1,K2,V2> |
ReduceDriver.withCounters(org.apache.hadoop.mapred.Counters ctrs)
Sets the counters to use and returns self for fluent style
|
ReduceDriver<K1,V1,K2,V2> |
ReduceDriver.withOutputFormat(Class<? extends org.apache.hadoop.mapred.OutputFormat> outputFormatClass,
Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass)
Configure
Reducer to output with a real OutputFormat . |
ReduceDriver<K1,V1,K2,V2> |
ReduceDriver.withReducer(org.apache.hadoop.mapred.Reducer<K1,V1,K2,V2> r)
Identical to setReducer(), but with fluent programming style
|
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.