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 |
testTableRecordReader()
Run test assuming no errors using mapred api.
|
void |
testTableRecordReaderScannerFail()
Run test assuming Scanner IOException failure using mapred api,
|
void |
testTableRecordReaderScannerFailTwice()
Run test assuming Scanner IOException failure using mapred api,
|
void |
testTableRecordReaderScannerTimeout()
Run test assuming NotServingRegionException using mapred api.
|
void |
testTableRecordReaderScannerTimeoutTwice()
Run test assuming NotServingRegionException using mapred 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 testTableRecordReader() throws java.io.IOException
java.io.IOException
public void testTableRecordReaderScannerFail() throws java.io.IOException
java.io.IOException
public void testTableRecordReaderScannerFailTwice() throws java.io.IOException
java.io.IOException
public void testTableRecordReaderScannerTimeout() throws java.io.IOException
org.apache.hadoop.hbase.DoNotRetryIOException
java.io.IOException
public void testTableRecordReaderScannerTimeoutTwice() throws java.io.IOException
org.apache.hadoop.hbase.DoNotRetryIOException
java.io.IOException
public void testExtensionOfTableInputFormatBase() throws java.io.IOException
java.io.IOException
public void testDeprecatedExtensionOfTableInputFormatBase() throws java.io.IOException
java.io.IOException
public void testJobConfigurableExtensionOfTableInputFormatBase() throws java.io.IOException
java.io.IOException