org.apache.hadoop.hbase.mapred

Class TestTableInputFormat

java.lang.Object

org.apache.hadoop.hbase.mapred.TestTableInputFormat

public class TestTableInputFormat
extends java.lang.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 java.lang.Exception

Throws:

java.lang.Exception

afterClass

public static void afterClass()
                       throws java.lang.Exception

Throws:

java.lang.Exception

before

public void before()
            throws java.io.IOException

Throws:

java.io.IOException

createTable

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

Setup a table with two rows and values.

Parameters:

tableName -

Returns:

Throws:

java.io.IOException

createTable

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

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

Parameters:

tableName -

Returns:

Throws:

java.io.IOException

testTableRecordReader

public void testTableRecordReader()
                           throws java.io.IOException

Run test assuming no errors using mapred api.

Throws:

java.io.IOException

testTableRecordReaderScannerFail

public void testTableRecordReaderScannerFail()
                                      throws java.io.IOException

Run test assuming Scanner IOException failure using mapred api,

Throws:

java.io.IOException

testTableRecordReaderScannerFailTwice

public void testTableRecordReaderScannerFailTwice()
                                           throws java.io.IOException

Run test assuming Scanner IOException failure using mapred api,

Throws:

java.io.IOException

testTableRecordReaderScannerTimeout

public void testTableRecordReaderScannerTimeout()
                                         throws java.io.IOException

Run test assuming NotServingRegionException using mapred api.

Throws:

DoNotRetryIOException

java.io.IOException

testTableRecordReaderScannerTimeoutTwice

public void testTableRecordReaderScannerTimeoutTwice()
                                              throws java.io.IOException

Run test assuming NotServingRegionException using mapred api.

Throws:

DoNotRetryIOException

java.io.IOException

testExtensionOfTableInputFormatBase

public void testExtensionOfTableInputFormatBase()
                                         throws java.io.IOException

Verify the example we present in javadocs on TableInputFormatBase

Throws:

java.io.IOException

testDeprecatedExtensionOfTableInputFormatBase

public void testDeprecatedExtensionOfTableInputFormatBase()
                                                   throws java.io.IOException

Throws:

java.io.IOException

testJobConfigurableExtensionOfTableInputFormatBase

public void testJobConfigurableExtensionOfTableInputFormatBase()
                                                        throws java.io.IOException

Throws:

java.io.IOException