This project has retired. For details please refer to its Attic page.

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

A

abortTask(TaskAttemptContext) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockOutputCommitter

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

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

Expects an input of the form "key \t val" Forces the Mapper input types to Text.

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

Expects an input of the form "key \t val" Forces the Mapper input types to Text.

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

adds an input value to send to the reducer

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

Adds a set of input values to send to the reducer

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.MapDriverBase

Adds an output (k, v) pair we expect from the Mapper

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

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

addOutput(Pair<K3, V3>) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

Adds an output (k, v) pair we expect from the Reducer

addOutput(K3, V3) - Method in class org.apache.hadoop.mrunit.MapReduceDriverBase

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

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

Adds an output (k, v) pair we expect from the Reducer

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

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

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

Adds an output (k, v) pair we expect from the Reducer

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

Adds an output (k, v) pair we expect from the Reducer

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

Expects an input of the form "key \t val" Forces the Mapper output types to Text.

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

Expects an input of the form "key \t val" Forces the Reducer output types to Text.

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

Expects an input of the form "key \t val" Forces the Reducer output types to Text.

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

Expects an input of the form "key \t val" Forces the Reducer output types to Text.

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

asserts x > y

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

asserts x >= y)

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

asserts x < y

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

asserts x >= y)

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

Asserts that all the elements of the list are equivalent under equals()

C

cleanupJob(JobContext) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockOutputCommitter

close() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockRawKeyValueIterator

collect(K, V) - Method in class org.apache.hadoop.mrunit.mock.MockOutputCollector

Accepts another (key, value) pair as an output of this mapper/reducer.

commitTask(TaskAttemptContext) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockOutputCommitter

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

conf - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockContextWrapper

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

context - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockMapContextWrapper

context - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContextWrapper

copy(Object, Object, Configuration) - Static method in class org.apache.hadoop.mrunit.Serialization

copy(Object, Configuration) - Static method in class org.apache.hadoop.mrunit.Serialization

counters - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockContextWrapper

createCommon(TaskInputOutputContext<KEYIN, VALUEIN, KEYOUT, VALUEOUT>) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockContextWrapper

currentKeyValue - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockMapContextWrapper

currentKeyValue - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContextWrapper

E

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

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

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

F

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

G

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

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

getCounter(String, String) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockReporter

getCounter(Enum<?>) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockReporter

getCounter(String, String) - Method in class org.apache.hadoop.mrunit.mock.MockReporter

getCounter(Enum<?>) - Method in class org.apache.hadoop.mrunit.mock.MockReporter

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

getExpectedOutputs() - 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

getInputSplit() - Method in class org.apache.hadoop.mrunit.mock.MockReporter

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

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

Returns a list which when iterated over, returns the same instance of the value each time with different contents similar to how Hadoop currently works with Writables.

getKey() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockRawKeyValueIterator

getLength() - Method in class org.apache.hadoop.mrunit.mock.MockInputSplit

getLocations() - Method in class org.apache.hadoop.mrunit.mock.MockInputSplit

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

getMockContext() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockMapContextWrapper

getMockContext() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContextWrapper

getMockPath() - Static method in class org.apache.hadoop.mrunit.mapreduce.mock.MockInputSplit

Return the path object represented by this as a FileSplit.

getMockPath() - Static method in class org.apache.hadoop.mrunit.mock.MockInputSplit

Return the path object represented by this as a FileSplit.

getOutputs() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockMapContextWrapper

getOutputs() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContextWrapper

getOutputs() - Method in class org.apache.hadoop.mrunit.mock.MockOutputCollector

getProgress() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockRawKeyValueIterator

getProgress() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockReporter

getProgress() - Method in class org.apache.hadoop.mrunit.mock.MockReporter

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

getValue() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockRawKeyValueIterator

H

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

I

incrCounter(Enum<?>, long) - Method in class org.apache.hadoop.mrunit.mock.MockReporter

incrCounter(String, String, long) - Method in class org.apache.hadoop.mrunit.mock.MockReporter

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

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

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

inputs - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockMapContextWrapper

inputs - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContextWrapper

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

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.mock.MockMapContextWrapper

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

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

makeOneUseIterator(Iterator<V>) - Static method in class org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContextWrapper

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> - Class in org.apache.hadoop.mrunit

Harness that allows you to test a Mapper instance.

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

MapReduceDriver<K1,V1,K2 extends Comparable,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() - Constructor for class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

MapReduceDriver<K1,V1,K2 extends Comparable,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 extends Comparable,V2,K3,V3> - 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

MockContextWrapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT> - Class in org.apache.hadoop.mrunit.mapreduce.mock

MockContextWrapper(Counters, Configuration) - Constructor for class org.apache.hadoop.mrunit.mapreduce.mock.MockContextWrapper

MockInputSplit - Class in org.apache.hadoop.mrunit.mapreduce.mock

Mock implementation of InputSplit that does nothing.

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

MockInputSplit - Class in org.apache.hadoop.mrunit.mock

A fake InputSplit object to be returned by our MockReporter to the user class.

MockInputSplit() - Constructor for class org.apache.hadoop.mrunit.mock.MockInputSplit

MockMapContextWrapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT> - Class in org.apache.hadoop.mrunit.mapreduce.mock

o.a.h.mapreduce.Mapper.map() expects to use a Mapper.Context object as a parameter.

MockMapContextWrapper(List<Pair<KEYIN, VALUEIN>>, Counters, Configuration) - Constructor for class org.apache.hadoop.mrunit.mapreduce.mock.MockMapContextWrapper

MockOutputCollector<K,V> - Class in org.apache.hadoop.mrunit.mock

OutputCollector to use in the test framework for Mapper and Reducer classes.

MockOutputCollector(Configuration) - Constructor for class org.apache.hadoop.mrunit.mock.MockOutputCollector

MockOutputCommitter - Class in org.apache.hadoop.mrunit.mapreduce.mock

Mock implementation of OutputCommitter that does nothing.

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

MockRawKeyValueIterator - Class in org.apache.hadoop.mrunit.mapreduce.mock

Mock implementation of RawKeyValueIterator that does nothing.

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

MockReduceContextWrapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT> - Class in org.apache.hadoop.mrunit.mapreduce.mock

o.a.h.mapreduce.Reducer.reduce() expects to use a Reducer.Context object as a parameter.

MockReduceContextWrapper(List<Pair<KEYIN, List<VALUEIN>>>, Counters, Configuration) - Constructor for class org.apache.hadoop.mrunit.mapreduce.mock.MockReduceContextWrapper

MockReporter - Class in org.apache.hadoop.mrunit.mapreduce.mock

MockReporter(Counters) - Constructor for class org.apache.hadoop.mrunit.mapreduce.mock.MockReporter

MockReporter - Class in org.apache.hadoop.mrunit.mock

MockReporter(MockReporter.ReporterType, Counters) - Constructor for class org.apache.hadoop.mrunit.mock.MockReporter

MockReporter.ReporterType - Enum in org.apache.hadoop.mrunit.mock

N

needsTaskCommit(TaskAttemptContext) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockOutputCommitter

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() - 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.

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.

next() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockRawKeyValueIterator

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.mapreduce.mock - package org.apache.hadoop.mrunit.mapreduce.mock

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

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

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

outputs - Variable in class org.apache.hadoop.mrunit.mapreduce.mock.MockContextWrapper

P

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

A very basic pair type.

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

Pair.FirstElemComparator - Class in org.apache.hadoop.mrunit.types

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

Pair.SecondElemComparator - 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

progress() - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockReporter

progress() - Method in class org.apache.hadoop.mrunit.mock.MockReporter

R

readFields(DataInput) - Method in class org.apache.hadoop.mrunit.mock.MockInputSplit

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> - 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>) - Constructor for class org.apache.hadoop.mrunit.ReduceDriverBase.ValueClassInstanceReuseList

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() - 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.MapDriverBase

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

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

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

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

Runs the test and validates the results

S

Serialization - Class in org.apache.hadoop.mrunit

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

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

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

Expects an input of the form "key \t val" Forces the Mapper input types to Text.

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

Expects an input of the form "key \t val, val, val..." Forces the Reducer input types to Text.

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

Sets the input key to send to the mapper

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

Sets the input key to send to the Reducer

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

Sets the input value to send to the mapper

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

Sets the input values to send to the reducer; overwrites existing ones

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)

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

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

setStatus(String) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockReporter

setStatus(String) - Method in class org.apache.hadoop.mrunit.mock.MockReporter

setupJob(JobContext) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockOutputCommitter

setupTask(TaskAttemptContext) - Method in class org.apache.hadoop.mrunit.mapreduce.mock.MockOutputCommitter

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> - Class in org.apache.hadoop.mrunit

TestDriver() - Constructor for 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.mock.MockInputSplit

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.mock.MockInputSplit

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>>) - Method in class org.apache.hadoop.mrunit.TestDriver

check the outputs against the expected inputs in record

valueOf(String) - Static method in enum org.apache.hadoop.mrunit.mock.MockReporter.ReporterType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.hadoop.mrunit.mock.MockReporter.ReporterType

Returns an array containing the constants of this enum type, in the order they are declared.

W

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.mapreduce.MapDriver

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

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

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.MapDriver

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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.ReduceDriver

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

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

Identical to setInputFromString, but with a fluent programming style

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

Identical to setInputFromString, but with a fluent programming style

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

Identical to addInputFromString, but with a fluent programming style

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

Identical to setInput, but with a fluent programming style

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

Identical to addInputFromString, but with a fluent programming style

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

Identical to addInputFromString, but with a fluent programming style

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

Identical to setInput, but with a fluent programming style

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

Identical to setInputKey() but with fluent programming style

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

Identical to setInputKey() but with fluent programming style

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

Identical to setInputKey() but with fluent programming style

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

Identical to setInputKey() but with fluent programming style

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

Identical to setInputValue() but with fluent programming style

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

Identical to setInputValue() but with fluent programming style

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

Identical to addInputValue() but with fluent programming style

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

Identical to addInputValue() but with fluent programming style

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

Identical to addInputValues() but with fluent programming style

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

Identical to addInputValues() but with fluent programming style

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

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

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

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

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

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

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

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

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.MapDriver

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

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

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

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

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

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

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

withOutput(Pair<K3, V3>) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

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

withOutput(K3, V3) - Method in class org.apache.hadoop.mrunit.mapreduce.MapReduceDriver

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

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

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

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

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

withOutput(Pair<K3, V3>) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

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

withOutput(K3, V3) - Method in class org.apache.hadoop.mrunit.MapReduceDriver

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

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

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

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

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

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

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

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

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

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

Identical to addOutputFromString, but with a fluent programming style

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

Identical to addOutputFromString, but with a fluent programming style

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

Identical to addOutputFromString, but with a fluent programming style

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

Identical to addOutput, but with a fluent programming style

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

Identical to addOutputFromString, but with a fluent programming style

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

Identical to addOutputFromString, but with a fluent programming style

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

Identical to addOutput, but with a fluent programming style

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

write(DataOutput) - Method in class org.apache.hadoop.mrunit.mock.MockInputSplit

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