A C E F G H I K L M N O P R S T V W

A

addAll(List<Pair<K1, V1>>) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Adds list of inputs to send to the mapper

addAll(List<Pair<K1, V1>>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Adds input to send to the mapper

addAll(List<Pair<K1, V1>>) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Adds list of inputs to send to the mapper

addAll(List<Pair<K1, List<V1>>>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Adds input to send to the Reducer

addAllOutput(List<Pair<K2, V2>>) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds output (k, v)* pairs we expect

addCacheArchive(String) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds an archive to be put on the distributed cache.

addCacheArchive(URI) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds an archive to be put on the distributed cache.

addCacheFile(String) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds a file to be put on the distributed cache.

addCacheFile(URI) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds a file to be put on the distributed cache.

addInput(K1, V1) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Adds an input to send to the mapper

addInput(Pair<K1, V1>) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Adds an input to send to the mapper

addInput(K1, V1) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Adds an input to send to the mapper

addInput(Pair<K1, V1>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Adds an input to send to the Mapper

addInput(K1, V1) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Adds an input to send to the mapper

addInput(Pair<K1, V1>) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Adds an input to send to the Mapper

addInput(K1, List<V1>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Add input (K, V*) to send to the Reducer

addInput(Pair<K1, List<V1>>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Add input (K, V*) to send to the Reducer

addInputFromString(String) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

addInputFromString(String) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

addInputValue(V1) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v*)*. Replaced by #setInput(), #addInput(), and #addAll()

addInputValues(List<V1>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v*)*. Replaced by #setInput(), #addInput(), and #addAll()

addMapReduce(Mapper, Reducer) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Add a Mapper and Reducer instance to the pipeline to use with this test driver

addMapReduce(Pair<Mapper, Reducer>) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Add a Mapper and Reducer instance to the pipeline to use with this test driver

addOutput(Pair<K2, V2>) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds an output (k, v) pair we expect

addOutput(K2, V2) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds a (k, v) pair we expect as output

addOutputFromString(String) - Method in class org.apache.hadoop.mrunit.TestDriver

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

assertGreater(int, int) - Static method in class org.apache.hadoop.mrunit.testutil.ExtendedAssert

Deprecated. No replacement since extension methods to JUnit assert methods dont fit well with MRUnit's goals

assertGreaterOrEqual(int, int) - Static method in class org.apache.hadoop.mrunit.testutil.ExtendedAssert

Deprecated. No replacement since extension methods to JUnit assert methods dont fit well with MRUnit's goals

assertLess(int, int) - Static method in class org.apache.hadoop.mrunit.testutil.ExtendedAssert

Deprecated. No replacement since extension methods to JUnit assert methods dont fit well with MRUnit's goals

assertLessOrEqual(int, int) - Static method in class org.apache.hadoop.mrunit.testutil.ExtendedAssert

Deprecated. No replacement since extension methods to JUnit assert methods dont fit well with MRUnit's goals

assertListEquals(List<?>, List<?>) - Static method in class org.apache.hadoop.mrunit.testutil.ExtendedAssert

Deprecated. No replacement due to automatic list comparison using runTest()

C

cleanupDistributedCache() - Method in class org.apache.hadoop.mrunit.TestDriver

Cleans up the distributed cache test by deleting the temporary directory and any extracted cache archives contained within

clearInput() - Method in class org.apache.hadoop.mrunit.MapDriverBase

Clears the list of inputs to send to the mapper

clearInput() - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Clears the input to be sent to the Reducer

compare(Pair<S, T>, Pair<S, T>) - Method in class org.apache.hadoop.mrunit.types.Pair.FirstElemComparator

compare(Pair<S, T>, Pair<S, T>) - Method in class org.apache.hadoop.mrunit.types.Pair.SecondElemComparator

compareTo(Pair<S, T>) - Method in class org.apache.hadoop.mrunit.types.Pair

copy(E) - Method in class org.apache.hadoop.mrunit.TestDriver

copyPair(S, E) - Method in class org.apache.hadoop.mrunit.TestDriver

counterWrapper - Variable in class org.apache.hadoop.mrunit.TestDriver

E

equals(Object) - Method in class org.apache.hadoop.mrunit.types.Pair

expectedEnumCounters - Variable in class org.apache.hadoop.mrunit.TestDriver

expectedOutputs - Variable in class org.apache.hadoop.mrunit.TestDriver

expectedStringCounters - Variable in class org.apache.hadoop.mrunit.TestDriver

ExtendedAssert - Class in org.apache.hadoop.mrunit.testutil

Deprecated. No replacement due to automatic comparisons using runTest()

F

formatValueList(List<?>, StringBuilder) - Static method in class org.apache.hadoop.mrunit.TestDriver

G

getCombiner() - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

getCombiner() - Method in class org.apache.hadoop.mrunit.MapReduceDriver

getConfiguration() - Method in class org.apache.hadoop.mrunit.TestDriver

getContext() - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

Obtain Context object for furthering mocking with Mockito.

getContext() - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

Obtain Context object for furthering mocking with Mockito.

getCounters() - Method in class org.apache.hadoop.mrunit.MapDriver

getCounters() - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

getCounters() - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

getCounters() - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

getCounters() - Method in class org.apache.hadoop.mrunit.MapReduceDriver

getCounters() - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

getCounters() - Method in class org.apache.hadoop.mrunit.ReduceDriver

getExpectedEnumCounters() - Method in class org.apache.hadoop.mrunit.TestDriver

getExpectedOutputs() - Method in class org.apache.hadoop.mrunit.TestDriver

getExpectedStringCounters() - Method in class org.apache.hadoop.mrunit.TestDriver

getFirst() - Method in class org.apache.hadoop.mrunit.types.Pair

getInputKey() - Method in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated.

getInputValue() - Method in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated.

getInputValues() - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v*)*. Replaced by ReduceDriverBase.getInputValues(Object)

getInputValues(K1) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Returns a list of values for the given key

getMapInputPath() - Method in class org.apache.hadoop.mrunit.MapDriverBase

getMapInputPath() - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

getMapInputPath() - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

getMapper() - Method in class org.apache.hadoop.mrunit.MapDriver

getMapper() - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

getMapper() - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

getMapper() - Method in class org.apache.hadoop.mrunit.MapReduceDriver

getMapReducePipeline() - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

getOutputSerializationConfiguration() - Method in class org.apache.hadoop.mrunit.TestDriver

Get the Configuration to use when copying output for use with run* methods or for the InputFormat when reading output back in when setting a real OutputFormat.

getReducer() - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

getReducer() - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

getReducer() - Method in class org.apache.hadoop.mrunit.MapReduceDriver

getReducer() - Method in class org.apache.hadoop.mrunit.ReduceDriver

getSecond() - Method in class org.apache.hadoop.mrunit.types.Pair

H

hashCode() - Method in class org.apache.hadoop.mrunit.types.Pair

I

initDistributedCache() - Method in class org.apache.hadoop.mrunit.TestDriver

Initialises the test distributed cache if required.

inputKey - Variable in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated.

inputKey - Variable in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated.

inputList - Variable in class org.apache.hadoop.mrunit.MapReduceDriverBase

inputs - Variable in class org.apache.hadoop.mrunit.MapDriverBase

inputs - Variable in class org.apache.hadoop.mrunit.ReduceDriverBase

inputVal - Variable in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated.

iterator() - Method in class org.apache.hadoop.mrunit.ReduceDriverBase.ValueClassInstanceReuseList

K

keyGroupComparator - Variable in class org.apache.hadoop.mrunit.MapReduceDriverBase

Key group comparator

keyValueOrderComparator - Variable in class org.apache.hadoop.mrunit.MapReduceDriverBase

Key value order comparator

L

LOG - Static variable in class org.apache.hadoop.mrunit.MapDriver

LOG - Static variable in class org.apache.hadoop.mrunit.MapDriverBase

LOG - Static variable in class org.apache.hadoop.mrunit.mapreduce.MapDriver

LOG - Static variable in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

LOG - Static variable in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

LOG - Static variable in class org.apache.hadoop.mrunit.MapReduceDriver

LOG - Static variable in class org.apache.hadoop.mrunit.MapReduceDriverBase

LOG - Static variable in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

LOG - Static variable in class org.apache.hadoop.mrunit.ReduceDriver

LOG - Static variable in class org.apache.hadoop.mrunit.TestDriver

M

MapDriver<K1,V1,K2,V2> - Class in org.apache.hadoop.mrunit

Harness that allows you to test a Mapper instance.

MapDriver(Mapper<K1, V1, K2, V2>) - Constructor for class org.apache.hadoop.mrunit.MapDriver

MapDriver() - Constructor for class org.apache.hadoop.mrunit.MapDriver

MapDriver<K1,V1,K2,V2> - Class in org.apache.hadoop.mrunit.mapreduce

Harness that allows you to test a Mapper instance.

MapDriver(Mapper<K1, V1, K2, V2>) - Constructor for class org.apache.hadoop.mrunit.mapreduce.MapDriver

MapDriver() - Constructor for class org.apache.hadoop.mrunit.mapreduce.MapDriver

MapDriverBase<K1,V1,K2,V2,T extends MapDriverBase<K1,V1,K2,V2,T>> - Class in org.apache.hadoop.mrunit

Harness that allows you to test a Mapper instance.

MapDriverBase() - Constructor for class org.apache.hadoop.mrunit.MapDriverBase

mapInputPath - Variable in class org.apache.hadoop.mrunit.MapDriverBase

mapInputPath - Variable in class org.apache.hadoop.mrunit.MapReduceDriverBase

mapInputPath - Variable in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

MapReduceDriver<K1,V1,K2,V2,K3,V3> - Class in org.apache.hadoop.mrunit.mapreduce

Harness that allows you to test a Mapper and a Reducer instance together You provide the input key and value that should be sent to the Mapper, and outputs you expect to be sent by the Reducer to the collector for those inputs.

MapReduceDriver(Mapper<K1, V1, K2, V2>, Reducer<K2, V2, K3, V3>) - Constructor for class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

MapReduceDriver(Mapper<K1, V1, K2, V2>, Reducer<K2, V2, K3, V3>, Reducer<K2, V2, K2, V2>) - Constructor for class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

MapReduceDriver() - Constructor for class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

MapReduceDriver<K1,V1,K2,V2,K3,V3> - Class in org.apache.hadoop.mrunit

Harness that allows you to test a Mapper and a Reducer instance together (along with an optional combiner).

MapReduceDriver(Mapper<K1, V1, K2, V2>, Reducer<K2, V2, K3, V3>) - Constructor for class org.apache.hadoop.mrunit.MapReduceDriver

MapReduceDriver(Mapper<K1, V1, K2, V2>, Reducer<K2, V2, K3, V3>, Reducer<K2, V2, K2, V2>) - Constructor for class org.apache.hadoop.mrunit.MapReduceDriver

MapReduceDriver() - Constructor for class org.apache.hadoop.mrunit.MapReduceDriver

MapReduceDriverBase<K1,V1,K2,V2,K3,V3,T extends MapReduceDriverBase<K1,V1,K2,V2,K3,V3,T>> - Class in org.apache.hadoop.mrunit

Harness that allows you to test a Mapper and a Reducer instance together You provide the input key and value that should be sent to the Mapper, and outputs you expect to be sent by the Reducer to the collector for those inputs.

MapReduceDriverBase() - Constructor for class org.apache.hadoop.mrunit.MapReduceDriverBase

mockOutputCreator - Variable in class org.apache.hadoop.mrunit.MapDriverBase

mockOutputCreator - Variable in class org.apache.hadoop.mrunit.ReduceDriverBase

N

newMapDriver() - Static method in class org.apache.hadoop.mrunit.MapDriver

Returns a new MapDriver without having to specify the generic types on the right hand side of the object create statement.

newMapDriver(Mapper<K1, V1, K2, V2>) - Static method in class org.apache.hadoop.mrunit.MapDriver

Returns a new MapDriver without having to specify the generic types on the right hand side of the object create statement.

newMapDriver() - Static method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

Returns a new MapDriver without having to specify the generic types on the right hand side of the object create statement.

newMapDriver(Mapper<K1, V1, K2, V2>) - Static method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

Returns a new MapDriver without having to specify the generic types on the right hand side of the object create statement.

newMapReduceDriver() - Static method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newMapReduceDriver(Mapper<K1, V1, K2, V2>, Reducer<K2, V2, K3, V3>) - Static method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newMapReduceDriver(Mapper<K1, V1, K2, V2>, Reducer<K2, V2, K3, V3>, Reducer<K2, V2, K2, V2>) - Static method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newMapReduceDriver() - Static method in class org.apache.hadoop.mrunit.MapReduceDriver

Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newMapReduceDriver(Mapper<K1, V1, K2, V2>, Reducer<K2, V2, K3, V3>) - Static method in class org.apache.hadoop.mrunit.MapReduceDriver

Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newMapReduceDriver(Mapper<K1, V1, K2, V2>, Reducer<K2, V2, K3, V3>, Reducer<K2, V2, K2, V2>) - Static method in class org.apache.hadoop.mrunit.MapReduceDriver

Returns a new MapReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newPipelineMapReduceDriver() - Static method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Returns a new PipelineMapReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newPipelineMapReduceDriver(List<Pair<Mapper, Reducer>>) - Static method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Returns a new PipelineMapReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newReduceDriver() - Static method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

Returns a new ReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newReduceDriver(Reducer<K1, V1, K2, V2>) - Static method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

Returns a new ReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newReduceDriver() - Static method in class org.apache.hadoop.mrunit.ReduceDriver

Returns a new ReduceDriver without having to specify the generic types on the right hand side of the object create statement.

newReduceDriver(Reducer<K1, V1, K2, V2>) - Static method in class org.apache.hadoop.mrunit.ReduceDriver

Returns a new ReduceDriver without having to specify the generic types on the right hand side of the object create statement.

O

org.apache.hadoop.mrunit - package org.apache.hadoop.mrunit

org.apache.hadoop.mrunit.mapreduce - package org.apache.hadoop.mrunit.mapreduce

org.apache.hadoop.mrunit.testutil - package org.apache.hadoop.mrunit.testutil

org.apache.hadoop.mrunit.types - package org.apache.hadoop.mrunit.types

P

Pair<S,T> - Class in org.apache.hadoop.mrunit.types

A very basic pair type that does not allow null values.

Pair(S, T) - Constructor for class org.apache.hadoop.mrunit.types.Pair

Pair.FirstElemComparator<S,T> - Class in org.apache.hadoop.mrunit.types

Pair.FirstElemComparator() - Constructor for class org.apache.hadoop.mrunit.types.Pair.FirstElemComparator

Pair.SecondElemComparator<S,T> - Class in org.apache.hadoop.mrunit.types

Pair.SecondElemComparator() - Constructor for class org.apache.hadoop.mrunit.types.Pair.SecondElemComparator

parseCommaDelimitedList(String) - Static method in class org.apache.hadoop.mrunit.TestDriver

Split "val,val,val,val..." into a List of Text(val) objects.

parseTabbedPair(String) - Static method in class org.apache.hadoop.mrunit.TestDriver

Split "key \t val" into Pair(Text(key), Text(val))

PipelineMapReduceDriver<K1,V1,K2,V2> - Class in org.apache.hadoop.mrunit

Harness that allows you to test a dataflow through a set of Mappers and Reducers.

PipelineMapReduceDriver(List<Pair<Mapper, Reducer>>) - Constructor for class org.apache.hadoop.mrunit.PipelineMapReduceDriver

PipelineMapReduceDriver() - Constructor for class org.apache.hadoop.mrunit.PipelineMapReduceDriver

preRunChecks(Object) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Handle inputKey and inputVal for backwards compatibility.

preRunChecks(Object, Object) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

preRunChecks(Object) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Handle inputKey and inputValues for backwards compatibility.

printPreTestDebugLog() - Method in class org.apache.hadoop.mrunit.MapDriverBase

printPreTestDebugLog() - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

printPreTestDebugLog() - Method in class org.apache.hadoop.mrunit.TestDriver

Overridable hook for printing pre-test debug information

R

ReduceDriver<K1,V1,K2,V2> - Class in org.apache.hadoop.mrunit.mapreduce

Harness that allows you to test a Reducer instance.

ReduceDriver(Reducer<K1, V1, K2, V2>) - Constructor for class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

ReduceDriver() - Constructor for class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

ReduceDriver<K1,V1,K2,V2> - Class in org.apache.hadoop.mrunit

Harness that allows you to test a Reducer instance.

ReduceDriver(Reducer<K1, V1, K2, V2>) - Constructor for class org.apache.hadoop.mrunit.ReduceDriver

ReduceDriver() - Constructor for class org.apache.hadoop.mrunit.ReduceDriver

ReduceDriverBase<K1,V1,K2,V2,T extends ReduceDriverBase<K1,V1,K2,V2,T>> - Class in org.apache.hadoop.mrunit

Harness that allows you to test a Reducer instance.

ReduceDriverBase() - Constructor for class org.apache.hadoop.mrunit.ReduceDriverBase

ReduceDriverBase.ValueClassInstanceReuseList<T> - Class in org.apache.hadoop.mrunit

ReduceDriverBase.ValueClassInstanceReuseList(List<T>, Configuration) - Constructor for class org.apache.hadoop.mrunit.ReduceDriverBase.ValueClassInstanceReuseList

resetExpectedCounters() - Method in class org.apache.hadoop.mrunit.TestDriver

Clears the list of expected counters from this driver

resetOutput() - Method in class org.apache.hadoop.mrunit.TestDriver

Clears the list of outputs expected from this driver

run() - Method in class org.apache.hadoop.mrunit.MapDriver

run() - Method in class org.apache.hadoop.mrunit.MapDriverBase

run() - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

run() - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

run() - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

run() - Method in class org.apache.hadoop.mrunit.MapReduceDriver

run() - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

run() - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

run() - Method in class org.apache.hadoop.mrunit.ReduceDriver

run() - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

run(boolean) - Method in class org.apache.hadoop.mrunit.TestDriver

Runs the test but returns the result set instead of validating it (ignores any addOutput(), etc calls made before this).

run() - Method in class org.apache.hadoop.mrunit.TestDriver

Runs the test but returns the result set instead of validating it (ignores any addOutput(), etc calls made before this)

runTest() - Method in class org.apache.hadoop.mrunit.TestDriver

Runs the test and validates the results

runTest(boolean) - Method in class org.apache.hadoop.mrunit.TestDriver

Runs the test and validates the results

S

setCacheArchives(URI[]) - Method in class org.apache.hadoop.mrunit.TestDriver

Set the list of archives to put on the distributed cache

setCacheFiles(URI[]) - Method in class org.apache.hadoop.mrunit.TestDriver

Set the list of files to put on the distributed cache

setCombiner(Reducer<K2, V2, K2, V2>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Sets the reducer object to use as a combiner for this test

setCombiner(Reducer<K2, V2, K2, V2>) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Sets the reducer object to use as a combiner for this test

setConfiguration(Configuration) - Method in class org.apache.hadoop.mrunit.TestDriver

Deprecated. Use getConfiguration() to set configuration items as opposed to overriding the entire configuration object as it's used internally.

setCounters(Counters) - Method in class org.apache.hadoop.mrunit.MapDriver

Sets the counters object to use for this test.

setCounters(Counters) - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

Sets the counters object to use for this test.

setCounters(Counters) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Sets the counters object to use for this test.

setCounters(Counters) - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

Sets the counters object to use for this test.

setCounters(Counters) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Sets the counters object to use for this test.

setCounters(Counters) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Sets the counters object to use for this test.

setCounters(Counters) - Method in class org.apache.hadoop.mrunit.ReduceDriver

Sets the counters object to use for this test.

setInput(K1, V1) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Sets the input to send to the mapper

setInput(Pair<K1, V1>) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Sets the input to send to the mapper

setInput(K1, List<V1>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Sets the input to send to the reducer

setInputFromString(String) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

setInputFromString(String) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

setInputKey(K1) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v)*. Replaced by #setInput(), #addInput(), and #addAll()

setInputKey(K1) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v*)*. Replaced by #setInput(), #addInput(), and #addAll()

setInputValue(V1) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v)*. Replaced by #setInput(), #addInput(), and #addAll()

setInputValues(List<V1>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v*)*. Replaced by #setInput(), #addInput(), and #addAll()

setKeyGroupingComparator(RawComparator<K2>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Set the key grouping comparator, similar to calling the following API calls but passing a real instance rather than just the class: pre 0.20.1 API: JobConf.setOutputValueGroupingComparator(Class) 0.20.1+ API: Job.setGroupingComparatorClass(Class)

setKeyOrderComparator(RawComparator<K2>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Set the key value order comparator, similar to calling the following API calls but passing a real instance rather than just the class: pre 0.20.1 API: JobConf.setOutputKeyComparatorClass(Class) 0.20.1+ API: Job.setSortComparatorClass(Class)

setMapInputPath(Path) - Method in class org.apache.hadoop.mrunit.MapDriverBase

setMapInputPath(Path) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

setMapInputPath(Path) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

setMapper(Mapper<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.MapDriver

Set the Mapper instance to use with this test driver

setMapper(Mapper<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

Set the Mapper instance to use with this test driver

setMapper(Mapper<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Set the Mapper instance to use with this test driver

setMapper(Mapper<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Set the Mapper instance to use with this test driver

setOutputSerializationConfiguration(Configuration) - Method in class org.apache.hadoop.mrunit.TestDriver

Set the Configuration to use when copying output for use with run* methods or for the InputFormat when reading output back in when setting a real OutputFormat.

setReducer(Reducer<K2, V2, K3, V3>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Sets the reducer object to use for this test

setReducer(Reducer<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

Sets the reducer object to use for this test

setReducer(Reducer<K2, V2, K3, V3>) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Sets the reducer object to use for this test

setReducer(Reducer<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.ReduceDriver

Sets the reducer object to use for this test

shuffle(List<Pair<K2, V2>>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Take the outputs from the Mapper, combine all values for the same key, and sort them by key.

T

TestDriver<K1,V1,K2,V2,T extends TestDriver<K1,V1,K2,V2,T>> - Class in org.apache.hadoop.mrunit

TestDriver() - Constructor for class org.apache.hadoop.mrunit.TestDriver

thisAsTestDriver() - Method in class org.apache.hadoop.mrunit.TestDriver

toString() - Method in class org.apache.hadoop.mrunit.MapDriver

toString() - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

toString() - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

toString() - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

toString() - Method in class org.apache.hadoop.mrunit.MapReduceDriver

toString() - Method in class org.apache.hadoop.mrunit.ReduceDriver

toString() - Method in class org.apache.hadoop.mrunit.types.Pair

V

validate(List<Pair<K2, V2>>, boolean) - Method in class org.apache.hadoop.mrunit.TestDriver

check the outputs against the expected inputs in record

validate(CounterWrapper) - Method in class org.apache.hadoop.mrunit.TestDriver

Check counters.

W

withAll(List<Pair<K1, V1>>) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Identical to addAll() but returns self for fluent programming style

withAll(List<Pair<K1, V1>>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Identical to addAll() but returns self for fluent programming style

withAll(List<Pair<K1, V1>>) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Identical to addAll() but returns self for fluent programming style

withAll(List<Pair<K1, List<V1>>>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Identical to addAll() but returns self for fluent programming style

withAllOutput(List<Pair<K2, V2>>) - Method in class org.apache.hadoop.mrunit.TestDriver

Functions like addAllOutput() but returns self for fluent programming style

withCacheArchive(String) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds an archive to be put on the distributed cache.

withCacheArchive(URI) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds an archive to be put on the distributed cache.

withCacheFile(String) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds a file to be put on the distributed cache.

withCacheFile(URI) - Method in class org.apache.hadoop.mrunit.TestDriver

Adds a file to be put on the distributed cache.

withCombiner(Reducer<K2, V2, K2, V2>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Identical to setCombiner(), but with fluent programming style

withCombiner(Reducer<K2, V2, K2, V2>) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Identical to setCombiner(), but with fluent programming style

withConfiguration(Configuration) - Method in class org.apache.hadoop.mrunit.TestDriver

Deprecated. Use getConfiguration() to set configuration items as opposed to overriding the entire configuration object as it's used internally.

withCounter(Enum<?>, long) - Method in class org.apache.hadoop.mrunit.TestDriver

Register expected enumeration based counter value

withCounter(String, String, long) - Method in class org.apache.hadoop.mrunit.TestDriver

Register expected name based counter value

withCounters(Counters) - Method in class org.apache.hadoop.mrunit.MapDriver

Sets the counters to use and returns self for fluent style

withCounters(Counters) - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

Sets the counters to use and returns self for fluent style

withCounters(Counters) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Sets the counters to use and returns self for fluent style

withCounters(Counters) - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

Sets the counters to use and returns self for fluent style

withCounters(Counters) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Sets the counters to use and returns self for fluent style

withCounters(Counters) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Sets the counters to use and returns self for fluent style

withCounters(Counters) - Method in class org.apache.hadoop.mrunit.ReduceDriver

Sets the counters to use and returns self for fluent style

withInput(K1, V1) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Identical to setInput() but returns self for fluent programming style

withInput(Pair<K1, V1>) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Identical to setInput() but returns self for fluent programming style

withInput(K1, V1) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Identical to addInput() but returns self for fluent programming style

withInput(Pair<K1, V1>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Identical to addInput() but returns self for fluent programming style

withInput(K1, V1) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Identical to addInput() but returns self for fluent programming style

withInput(Pair<K1, V1>) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Identical to addInput() but returns self for fluent programming style

withInput(K1, List<V1>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Identical to setInput() but returns self for fluent programming style

withInput(Pair<K1, List<V1>>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Identical to addInput() but returns self for fluent programming style

withInputFromString(String) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

withInputFromString(String) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

withInputFromString(String) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

withInputFromString(String) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

withInputKey(K1) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v)*. Replaced by #withInput() and #withAll()

withInputKey(K1) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v*)*. Replaced by ReduceDriverBase.withInput(Object, List), ReduceDriverBase.withAll(List), and ReduceDriverBase.withInput(Pair)

withInputValue(V1) - Method in class org.apache.hadoop.mrunit.MapDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v)*. Replaced by #withInput() and #withAll()

withInputValue(V1) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v*)*. Replaced by ReduceDriverBase.withInput(Object, List), ReduceDriverBase.withAll(List), and ReduceDriverBase.withInput(Pair)

withInputValues(List<V1>) - Method in class org.apache.hadoop.mrunit.ReduceDriverBase

Deprecated. MRUNIT-64. Moved to list implementation to support multiple input (k, v*)*. Replaced by ReduceDriverBase.withInput(Object, List), ReduceDriverBase.withAll(List), and ReduceDriverBase.withInput(Pair)

withKeyGroupingComparator(RawComparator<K2>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Identical to MapReduceDriverBase.setKeyGroupingComparator(RawComparator), but with a fluent programming style

withKeyOrderComparator(RawComparator<K2>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Identical to MapReduceDriverBase.setKeyOrderComparator(RawComparator), but with a fluent programming style

withMapInputPath(Path) - Method in class org.apache.hadoop.mrunit.MapDriverBase

withMapInputPath(Path) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

withMapInputPath(Path) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

withMapper(Mapper<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.MapDriver

Sets the Mapper instance to use and returns self for fluent style

withMapper(Mapper<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

Sets the Mapper instance to use and returns self for fluent style

withMapper(Mapper<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Sets the Mapper instance to use and returns self for fluent style

withMapper(Mapper<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Sets the Mapper instance to use and returns self for fluent style

withMapReduce(Mapper, Reducer) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Add a Mapper and Reducer instance to the pipeline to use with this test driver using fluent style

withMapReduce(Pair<Mapper, Reducer>) - Method in class org.apache.hadoop.mrunit.PipelineMapReduceDriver

Add a Mapper and Reducer instance to the pipeline to use with this test driver using fluent style

withOutput(Pair<K2, V2>) - Method in class org.apache.hadoop.mrunit.TestDriver

Works like addOutput(), but returns self for fluent style

withOutput(K2, V2) - Method in class org.apache.hadoop.mrunit.TestDriver

Works like addOutput() but returns self for fluent programming style

withOutputFormat(Class<? extends OutputFormat>, Class<? extends InputFormat>) - Method in class org.apache.hadoop.mrunit.MapDriver

Configure Mapper to output with a real OutputFormat.

withOutputFormat(Class<? extends OutputFormat>, Class<? extends InputFormat>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapDriver

Configure Mapper to output with a real OutputFormat.

withOutputFormat(Class<? extends OutputFormat>, Class<? extends InputFormat>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Configure Reducer to output with a real OutputFormat.

withOutputFormat(Class<? extends OutputFormat>, Class<? extends InputFormat>) - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

Configure Reducer to output with a real OutputFormat.

withOutputFormat(Class<? extends OutputFormat>, Class<? extends InputFormat>) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Configure Reducer to output with a real OutputFormat.

withOutputFormat(Class<? extends OutputFormat>, Class<? extends InputFormat>) - Method in class org.apache.hadoop.mrunit.ReduceDriver

Configure Reducer to output with a real OutputFormat.

withOutputFromString(String) - Method in class org.apache.hadoop.mrunit.TestDriver

Deprecated. No replacement due to lack of type safety and incompatibility with non Text Writables

withOutputSerializationConfiguration(Configuration) - Method in class org.apache.hadoop.mrunit.TestDriver

Set the Configuration to use when copying output for use with run* methods or for the InputFormat when reading output back in when setting a real OutputFormat.

withReducer(Reducer<K2, V2, K3, V3>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

Identical to setReducer(), but with fluent programming style

withReducer(Reducer<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.mapreduce.ReduceDriver

Identical to setReducer(), but with fluent programming style

withReducer(Reducer<K2, V2, K3, V3>) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

Identical to setReducer(), but with fluent programming style

withReducer(Reducer<K1, V1, K2, V2>) - Method in class org.apache.hadoop.mrunit.ReduceDriver

Identical to setReducer(), but with fluent programming style

withStrictCounterChecking() - Method in class org.apache.hadoop.mrunit.TestDriver

Change counter checking.

A C E F G H I K L M N O P R S T V W