org.apache.hadoop.hbase.mapreduce

Class TestMultithreadedTableMapper

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestMultithreadedTableMapper

public class TestMultithreadedTableMapper
extends java.lang.Object

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
static class	TestMultithreadedTableMapper.ProcessContentsMapper Pass the given key and processed record reduce

Constructor Summary

Constructors

Constructor and Description
TestMultithreadedTableMapper()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
static void	beforeClass()
void	testMultithreadedTableMapper() Test multithreadedTableMappper map/reduce against a multi-region table

Methods inherited from class java.lang.Object

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

Constructor Detail

TestMultithreadedTableMapper

public TestMultithreadedTableMapper()

Method Detail

beforeClass

public static void beforeClass()
                        throws java.lang.Exception

Throws:

java.lang.Exception

afterClass

public static void afterClass()
                       throws java.lang.Exception

Throws:

java.lang.Exception

testMultithreadedTableMapper

public void testMultithreadedTableMapper()
                                  throws java.io.IOException,
                                         java.lang.InterruptedException,
                                         java.lang.ClassNotFoundException

Test multithreadedTableMappper map/reduce against a multi-region table

Throws:

java.io.IOException

java.lang.ClassNotFoundException

java.lang.InterruptedException