Package | Description |
---|---|
org.apache.hadoop.mrunit.mapreduce |
Modifier and Type | Method and Description |
---|---|
static <K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.newMultipleInputMapReduceDriver()
Static factory-style method to construct a driver instance without
specifying a Combiner nor a Reducer.
|
static <K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.newMultipleInputMapReduceDriver(org.apache.hadoop.mapreduce.Reducer<K1,V1,K1,V1> combiner,
org.apache.hadoop.mapreduce.Reducer<K1,V1,K2,V2> reducer)
Static factory-style method to construct a driver instance with the
specified Combiner and Reducer
|
static <K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.newMultipleInputMapReduceDriver(org.apache.hadoop.mapreduce.Reducer<K1,V1,K2,V2> reducer)
Static factory-style method to construct a driver instance with the
specified Reducer
|
<K,V> MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withAll(org.apache.hadoop.mapreduce.Mapper<K,V,K1,V1> mapper,
List<Pair<K,V>> inputs)
Identical to addInput but supports fluent programming style
|
MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withCombiner(org.apache.hadoop.mapreduce.Reducer<K1,V1,K1,V1> combiner)
Identical to setCombiner but supports a fluent programming style
|
MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withCounter(org.apache.hadoop.mapreduce.Counters counters)
Identical to setCounters but supports a fluent programming style
|
<K,V> MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withInput(org.apache.hadoop.mapreduce.Mapper<K,V,K1,V1> mapper,
K key,
V val)
Identical to addInput but supports fluent programming style
|
<K,V> MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withInput(org.apache.hadoop.mapreduce.Mapper<K,V,K1,V1> mapper,
Pair<K,V> input)
Identical to addInput but supports fluent programming style
|
MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withInputFormat(Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)
Set the InputFormat
|
<K,V> MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withMapper(org.apache.hadoop.mapreduce.Mapper<K,V,K1,V1> mapper)
Identical to addMapper but supports a fluent programming style
|
MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withOutputFormat(Class<? extends org.apache.hadoop.mapreduce.OutputFormat> outputFormatClass)
Configure
Reducer to output with a real OutputFormat . |
MultipleInputsMapReduceDriver<K1,V1,K2,V2> |
MultipleInputsMapReduceDriver.withReducer(org.apache.hadoop.mapreduce.Reducer<K1,V1,K2,V2> reducer)
Identical to setReducer but supports a fluent programming style
|
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.