Package 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	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	Description
(package private) static final byte[]	INPUT_FAMILY
(package private) static final String	KEY_LASTROW
(package private) static final String	KEY_STARTROW
(package private) static final org.slf4j.Logger	LOG
(package private) static final String	TABLE_NAME
(package private) static List<String>	TABLES
static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
MultiTableInputFormatTestBase()

Method Summary

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

LOG

static final org.slf4j.Logger LOG

TEST_UTIL

public static final HBaseTestingUtil 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 Details

MultiTableInputFormatTestBase

public MultiTableInputFormatTestBase()

Method Details

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

InterruptedException

ClassNotFoundException

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