public class TestTableInputFormat
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
TestTableInputFormat.ExampleDeprecatedTIF |
static class |
TestTableInputFormat.ExampleJobConfigurableTIF |
static class |
TestTableInputFormat.ExampleTIF |
static class |
TestTableInputFormat.ExampleVerifier |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
Constructor and Description |
---|
TestTableInputFormat() |
Modifier and Type | Method and Description |
---|---|
static void |
afterClass() |
void |
before() |
static void |
beforeClass() |
static Table |
createTable(byte[] tableName)
Setup a table with two rows and values.
|
static Table |
createTable(byte[] tableName,
byte[][] families)
Setup a table with two rows and values per column family.
|
void |
testDeprecatedExtensionOfTableInputFormatBase() |
void |
testExtensionOfTableInputFormatBase()
Verify the example we present in javadocs on TableInputFormatBase
|
void |
testJobConfigurableExtensionOfTableInputFormatBase() |
void |
testTableRecordReaderMapreduce()
Run test assuming no errors using newer mapreduce api
|
void |
testTableRecordReaderScannerFailMapreduce()
Run test assuming Scanner IOException failure using newer mapreduce api
|
void |
testTableRecordReaderScannerFailMapreduceTwice()
Run test assuming Scanner IOException failure using newer mapreduce api
|
void |
testTableRecordReaderScannerTimeoutMapreduce()
Run test assuming NotServingRegionException using newer mapreduce api
|
void |
testTableRecordReaderScannerTimeoutMapreduceTwice()
Run test assuming NotServingRegionException using newer mapreduce api
|
public static void beforeClass() throws java.lang.Exception
java.lang.Exception
public static void afterClass() throws java.lang.Exception
java.lang.Exception
public void before() throws java.io.IOException
java.io.IOException
public static Table createTable(byte[] tableName) throws java.io.IOException
tableName
- java.io.IOException
public static Table createTable(byte[] tableName, byte[][] families) throws java.io.IOException
tableName
- java.io.IOException
public void testTableRecordReaderMapreduce() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testTableRecordReaderScannerFailMapreduce() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testTableRecordReaderScannerFailMapreduceTwice() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testTableRecordReaderScannerTimeoutMapreduce() throws java.io.IOException, java.lang.InterruptedException
java.lang.InterruptedException
org.apache.hadoop.hbase.DoNotRetryIOException
java.io.IOException
public void testTableRecordReaderScannerTimeoutMapreduceTwice() throws java.io.IOException, java.lang.InterruptedException
java.lang.InterruptedException
org.apache.hadoop.hbase.NotServingRegionException
java.io.IOException
public void testExtensionOfTableInputFormatBase() throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
public void testJobConfigurableExtensionOfTableInputFormatBase() throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
public void testDeprecatedExtensionOfTableInputFormatBase() throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException