org.apache.hadoop.hbase.mapred

Class TestTableInputFormat

java.lang.Object

org.apache.hadoop.hbase.mapred.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	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.

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

testTableRecordReader

public void testTableRecordReader()
                           throws IOException

Run test assuming no errors using mapred api.

Throws:

IOException

testTableRecordReaderScannerFail

public void testTableRecordReaderScannerFail()
                                      throws IOException

Run test assuming Scanner IOException failure using mapred api,

Throws:

IOException

testTableRecordReaderScannerFailTwice

public void testTableRecordReaderScannerFailTwice()
                                           throws IOException

Run test assuming Scanner IOException failure using mapred api,

Throws:

IOException

testTableRecordReaderScannerTimeout

public void testTableRecordReaderScannerTimeout()
                                         throws IOException

Run test assuming NotServingRegionException using mapred api.

Throws:

DoNotRetryIOException

IOException

testTableRecordReaderScannerTimeoutTwice

public void testTableRecordReaderScannerTimeoutTwice()
                                              throws IOException

Run test assuming NotServingRegionException using mapred api.

Throws:

DoNotRetryIOException

IOException

testExtensionOfTableInputFormatBase

public void testExtensionOfTableInputFormatBase()
                                         throws IOException

Verify the example we present in javadocs on TableInputFormatBase

Throws:

IOException

testDeprecatedExtensionOfTableInputFormatBase

public void testDeprecatedExtensionOfTableInputFormatBase()
                                                   throws IOException

Throws:

IOException

testJobConfigurableExtensionOfTableInputFormatBase

public void testJobConfigurableExtensionOfTableInputFormatBase()
                                                        throws IOException

Throws:

IOException