Package org.apache.hadoop.hbase.mapreduce

Class TestTableMapReduce

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestTableMapReduceBase

org.apache.hadoop.hbase.mapreduce.TestTableMapReduce

public class TestTableMapReduce
extends TestTableMapReduceBase

Test Map/Reduce job over HBase tables. The map/reduce process we're testing on our tables is simple - take every row in the table, reverse the value of a particular cell, and write it back to the table.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	TestTableMapReduce.ProcessContentsMapper	Pass the given key and processed record reduce

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.mapreduce.TestTableMapReduceBase

columns, INPUT_FAMILY, MULTI_REGION_TABLE_NAME, OUTPUT_FAMILY, TABLE_FOR_NEGATIVE_TESTS, UTIL

Constructor Summary

Constructors

Constructor	Description
TestTableMapReduce()

Method Summary

Modifier and Type	Method	Description
protected org.slf4j.Logger	getLog()	Retrieve my logger instance.
protected void	runTestOnTable(org.apache.hadoop.hbase.client.Table table)	Handles API-specifics for setting up and executing the job.
void	testWritingToDisabledTable()
void	testWritingToNonExistentTable()
private void	verifyJobCountersAreEmitted(org.apache.hadoop.mapreduce.Job job)	Verify scan counters are emitted from the job

Methods inherited from class org.apache.hadoop.hbase.mapreduce.TestTableMapReduceBase

afterClass, beforeClass, map, testCombiner, testMultiRegionTable, verify

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

Constructor Details

TestTableMapReduce

public TestTableMapReduce()

Method Details

getLog

protected org.slf4j.Logger getLog()

Description copied from class: TestTableMapReduceBase

Retrieve my logger instance.

Specified by:

getLog in class TestTableMapReduceBase

runTestOnTable

protected void runTestOnTable(org.apache.hadoop.hbase.client.Table table)
                       throws IOException

Description copied from class: TestTableMapReduceBase

Handles API-specifics for setting up and executing the job.

Specified by:

runTestOnTable in class TestTableMapReduceBase

Throws:

IOException

verifyJobCountersAreEmitted

private void verifyJobCountersAreEmitted(org.apache.hadoop.mapreduce.Job job)
                                  throws IOException

Verify scan counters are emitted from the job

Throws:

IOException

testWritingToDisabledTable

public void testWritingToDisabledTable()
                                throws IOException

Throws:

IOException

testWritingToNonExistentTable

public void testWritingToNonExistentTable()
                                   throws IOException

Throws:

IOException