public abstract class MultiTableInputFormatTestBase
extends java.lang.Object
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.
|
Modifier and Type | Field and Description |
---|---|
static HBaseTestingUtility |
TEST_UTIL |
Constructor and Description |
---|
MultiTableInputFormatTestBase() |
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() |
public static void setUpBeforeClass() throws java.lang.Exception
java.lang.Exception
public static void tearDownAfterClass() throws java.lang.Exception
java.lang.Exception
public void tearDown() throws java.lang.Exception
java.lang.Exception
public void testScanEmptyToEmpty() throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
public void testScanEmptyToAPP() throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
public void testScanOBBToOPP() throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
public void testScanYZYToEmpty() throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
protected void runJob(java.lang.String jobName, Configuration c, java.util.List<Scan> scans) throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
protected abstract void initJob(java.util.List<Scan> scans, Job job) throws java.io.IOException
java.io.IOException