org.apache.hadoop.hbase.mapreduce

Class MultiTableInputFormatTestBase

java.lang.Object

org.apache.hadoop.hbase.mapreduce.MultiTableInputFormatTestBase

Direct Known Subclasses:

TestMultiTableInputFormat, TestMultiTableSnapshotInputFormat

public abstract class MultiTableInputFormatTestBase
extends Object

Base set of tests and setup for input formats touching multiple tables.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MultiTableInputFormatTestBase.ScanMapper Pass the key and value to reducer.
static class	MultiTableInputFormatTestBase.ScanReducer Checks the last and first keys seen against the scanner boundaries.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static byte[]	INPUT_FAMILY
(package private) static String	KEY_LASTROW
(package private) static String	KEY_STARTROW
(package private) static org.slf4j.Logger	LOG
(package private) static String	TABLE_NAME
(package private) static List<String>	TABLES
static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
MultiTableInputFormatTestBase()

Method Summary

Modifier and Type	Method and Description
protected abstract void	initJob(List<org.apache.hadoop.hbase.client.Scan> scans, org.apache.hadoop.mapreduce.Job job)
protected void	runJob(String jobName, org.apache.hadoop.conf.Configuration c, List<org.apache.hadoop.hbase.client.Scan> scans)
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
private void	testScan(String start, String stop, String last) Tests a MR scan using specific start and stop rows.
void	testScanEmptyToAPP()
void	testScanEmptyToEmpty()
void	testScanOBBToOPP()
void	testScanYZYToEmpty()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

static final org.slf4j.Logger LOG

TEST_UTIL

public static final HBaseTestingUtility TEST_UTIL

TABLE_NAME

static final String TABLE_NAME

See Also:

Constant Field Values

INPUT_FAMILY

static final byte[] INPUT_FAMILY

KEY_STARTROW

static final String KEY_STARTROW

See Also:

Constant Field Values

KEY_LASTROW

static final String KEY_LASTROW

See Also:

Constant Field Values

TABLES

static List<String> TABLES

Constructor Detail

MultiTableInputFormatTestBase

public MultiTableInputFormatTestBase()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testScanEmptyToEmpty

public void testScanEmptyToEmpty()
                          throws IOException,
                                 InterruptedException,
                                 ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException

testScanEmptyToAPP

public void testScanEmptyToAPP()
                        throws IOException,
                               InterruptedException,
                               ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException

testScanOBBToOPP

public void testScanOBBToOPP()
                      throws IOException,
                             InterruptedException,
                             ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException

testScanYZYToEmpty

public void testScanYZYToEmpty()
                        throws IOException,
                               InterruptedException,
                               ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException

testScan

private void testScan(String start,
                      String stop,
                      String last)
               throws IOException,
                      InterruptedException,
                      ClassNotFoundException

Tests a MR scan using specific start and stop rows.

Throws:

IOException

ClassNotFoundException

InterruptedException

runJob

protected void runJob(String jobName,
                      org.apache.hadoop.conf.Configuration c,
                      List<org.apache.hadoop.hbase.client.Scan> scans)
               throws IOException,
                      InterruptedException,
                      ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException

initJob

protected abstract void initJob(List<org.apache.hadoop.hbase.client.Scan> scans,
                                org.apache.hadoop.mapreduce.Job job)
                         throws IOException

Throws:

IOException