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 and Description
(package private) static class	TestTableMapReduce.ProcessContentsMapper Pass the given key and processed record reduce

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static 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 and Description
TestTableMapReduce()

Method Summary

Modifier and Type	Method and 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 nn

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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

TestTableMapReduce

public TestTableMapReduce()

Method Detail

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 nn

Throws:

IOException

testWritingToDisabledTable

public void testWritingToDisabledTable()
                                throws IOException

Throws:

IOException

testWritingToNonExistentTable

public void testWritingToNonExistentTable()
                                   throws IOException

Throws:

IOException