org.apache.hadoop.hbase.mapreduce

Class TestTableInputFormat

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestTableInputFormat

public class TestTableInputFormat
extends Object

This tests the TableInputFormat and its recovery semantics

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestTableInputFormat.ExampleDeprecatedTIF
static class	TestTableInputFormat.ExampleJobConfigurableTIF
static class	TestTableInputFormat.ExampleTIF
static class	TestTableInputFormat.ExampleVerifier

Constructor Summary

Constructors

Constructor and Description
TestTableInputFormat()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestTableInputFormat

public TestTableInputFormat()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

before

public void before()
            throws IOException

Throws:

IOException

createTable

public static Table createTable(byte[] tableName)
                         throws IOException

Setup a table with two rows and values.

Parameters:

tableName -

Returns:

Throws:

IOException

createTable

public static Table createTable(byte[] tableName,
                                byte[][] families)
                         throws IOException

Setup a table with two rows and values per column family.

Parameters:

tableName -

Returns:

Throws:

IOException

testTableRecordReaderMapreduce

public void testTableRecordReaderMapreduce()
                                    throws IOException,
                                           InterruptedException

Run test assuming no errors using newer mapreduce api

Throws:

IOException

InterruptedException

testTableRecordReaderScannerFailMapreduce

public void testTableRecordReaderScannerFailMapreduce()
                                               throws IOException,
                                                      InterruptedException

Run test assuming Scanner IOException failure using newer mapreduce api

Throws:

IOException

InterruptedException

testTableRecordReaderScannerFailMapreduceTwice

public void testTableRecordReaderScannerFailMapreduceTwice()
                                                    throws IOException,
                                                           InterruptedException

Run test assuming Scanner IOException failure using newer mapreduce api

Throws:

IOException

InterruptedException

testTableRecordReaderScannerTimeoutMapreduce

public void testTableRecordReaderScannerTimeoutMapreduce()
                                                  throws IOException,
                                                         InterruptedException

Run test assuming NotServingRegionException using newer mapreduce api

Throws:

InterruptedException

DoNotRetryIOException

IOException

testTableRecordReaderScannerTimeoutMapreduceTwice

public void testTableRecordReaderScannerTimeoutMapreduceTwice()
                                                       throws IOException,
                                                              InterruptedException

Run test assuming NotServingRegionException using newer mapreduce api

Throws:

InterruptedException

NotServingRegionException

IOException

testExtensionOfTableInputFormatBase

public void testExtensionOfTableInputFormatBase()
                                         throws IOException,
                                                InterruptedException,
                                                ClassNotFoundException

Verify the example we present in javadocs on TableInputFormatBase

Throws:

IOException

InterruptedException

ClassNotFoundException

testJobConfigurableExtensionOfTableInputFormatBase

public void testJobConfigurableExtensionOfTableInputFormatBase()
                                                        throws IOException,
                                                               InterruptedException,
                                                               ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException

testDeprecatedExtensionOfTableInputFormatBase

public void testDeprecatedExtensionOfTableInputFormatBase()
                                                   throws IOException,
                                                          InterruptedException,
                                                          ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException