public class TestTableInputFormat extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TestTableInputFormat.ExampleDeprecatedTIF |
static class |
TestTableInputFormat.ExampleJobConfigurableTIF |
static class |
TestTableInputFormat.ExampleTIF |
static class |
TestTableInputFormat.ExampleVerifier |
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 void before() throws IOException
IOException
public static Table createTable(byte[] tableName) throws IOException
tableName
- IOException
public static Table createTable(byte[] tableName, byte[][] families) throws IOException
tableName
- IOException
public void testTableRecordReaderMapreduce() throws IOException, InterruptedException
IOException
InterruptedException
public void testTableRecordReaderScannerFailMapreduce() throws IOException, InterruptedException
IOException
InterruptedException
public void testTableRecordReaderScannerFailMapreduceTwice() throws IOException, InterruptedException
IOException
InterruptedException
public void testTableRecordReaderScannerTimeoutMapreduce() throws IOException, InterruptedException
public void testTableRecordReaderScannerTimeoutMapreduceTwice() throws IOException, InterruptedException
public void testExtensionOfTableInputFormatBase() throws IOException, InterruptedException, ClassNotFoundException
public void testJobConfigurableExtensionOfTableInputFormatBase() throws IOException, InterruptedException, ClassNotFoundException
public void testDeprecatedExtensionOfTableInputFormatBase() throws IOException, InterruptedException, ClassNotFoundException