Class TestTableMapReduce
java.lang.Object
org.apache.hadoop.hbase.mapreduce.TestTableMapReduceBase
org.apache.hadoop.hbase.mapreduce.TestTableMapReduce
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
Modifier and TypeClassDescription(package private) static class
Pass the given key and processed record reduce -
Field Summary
Modifier and TypeFieldDescriptionstatic final HBaseClassTestRule
private static final org.slf4j.Logger
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
-
Method Summary
Modifier and TypeMethodDescriptionprotected 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
void
private void
verifyJobCountersAreEmitted
(org.apache.hadoop.mapreduce.Job job) Verify scan counters are emitted from the jobMethods inherited from class org.apache.hadoop.hbase.mapreduce.TestTableMapReduceBase
afterClass, beforeClass, map, testCombiner, testMultiRegionTable, verify
-
Field Details
-
CLASS_RULE
-
LOG
-
-
Constructor Details
-
TestTableMapReduce
public TestTableMapReduce()
-
-
Method Details
-
getLog
Description copied from class:TestTableMapReduceBase
Retrieve my logger instance.- Specified by:
getLog
in classTestTableMapReduceBase
-
runTestOnTable
Description copied from class:TestTableMapReduceBase
Handles API-specifics for setting up and executing the job.- Specified by:
runTestOnTable
in classTestTableMapReduceBase
- Throws:
IOException
-
verifyJobCountersAreEmitted
Verify scan counters are emitted from the job- Throws:
IOException
-
testWritingToDisabledTable
- Throws:
IOException
-
testWritingToNonExistentTable
- Throws:
IOException
-