Uses of Class
org.apache.hadoop.mrunit.PipelineMapReduceDriver

Packages that use PipelineMapReduceDriver

org.apache.hadoop.mrunit

Uses of PipelineMapReduceDriver in org.apache.hadoop.mrunit

Methods in org.apache.hadoop.mrunit that return PipelineMapReduceDriver

static <K1,V1,K2,V2> PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.newPipelineMapReduceDriver() Returns a new PipelineMapReduceDriver without having to specify the generic types on the right hand side of the object create statement.
static <K1,V1,K2,V2> PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.newPipelineMapReduceDriver(List<Pair<org.apache.hadoop.mapred.Mapper,org.apache.hadoop.mapred.Reducer>> pipeline) Returns a new PipelineMapReduceDriver without having to specify the generic types on the right hand side of the object create statement.
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withConfiguration(org.apache.hadoop.conf.Configuration configuration)
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withCounter(Enum e, long expectedValue)
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withCounter(String g, String n, long e)
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withCounters(org.apache.hadoop.mapred.Counters ctrs) Sets the counters to use and returns self for fluent style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withInput(K1 key, V1 val) Identical to addInput() but returns self for fluent programming style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withInput(Pair<K1,V1> input) Identical to addInput() but returns self for fluent programming style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withInputFromString(String input) Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withMapReduce(org.apache.hadoop.mapred.Mapper m, org.apache.hadoop.mapred.Reducer r) Add a Mapper and Reducer instance to the pipeline to use with this test driver using fluent style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withMapReduce(Pair<org.apache.hadoop.mapred.Mapper,org.apache.hadoop.mapred.Reducer> p) Add a Mapper and Reducer instance to the pipeline to use with this test driver using fluent style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withOutput(K2 key, V2 val) Functions like addOutput() but returns self for fluent programming style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withOutput(Pair<K2,V2> outputRecord) Works like addOutput(), but returns self for fluent style
PipelineMapReduceDriver<K1,V1,K2,V2>	PipelineMapReduceDriver.withOutputFromString(String output) Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables