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 java.lang.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
static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
MultiTableInputFormatTestBase()

Method Summary

Modifier and Type	Method and Description
protected abstract void	initJob(java.util.List<Scan> scans, Job job)
protected void	runJob(java.lang.String jobName, Configuration c, java.util.List<Scan> scans)
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
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

TEST_UTIL

public static final HBaseTestingUtility TEST_UTIL

Constructor Detail

MultiTableInputFormatTestBase

public MultiTableInputFormatTestBase()

Method Detail

setUpBeforeClass

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

Throws:

java.lang.Exception

tearDownAfterClass

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

Throws:

java.lang.Exception

tearDown

public void tearDown()
              throws java.lang.Exception

Throws:

java.lang.Exception

testScanEmptyToEmpty

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

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException

testScanEmptyToAPP

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

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException

testScanOBBToOPP

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

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException

testScanYZYToEmpty

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

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException

runJob

protected void runJob(java.lang.String jobName,
                      Configuration c,
                      java.util.List<Scan> scans)
               throws java.io.IOException,
                      java.lang.InterruptedException,
                      java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException

initJob

protected abstract void initJob(java.util.List<Scan> scans,
                                Job job)
                         throws java.io.IOException

Throws:

java.io.IOException