org.apache.hadoop.hbase.mapreduce

Class TestTableInputFormat

java.lang.Object

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

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

testTableRecordReaderMapreduce

public void testTableRecordReaderMapreduce()
                                    throws java.io.IOException,
                                           java.lang.InterruptedException

Run test assuming no errors using newer mapreduce api

Throws:

java.io.IOException

java.lang.InterruptedException

testTableRecordReaderScannerFailMapreduce

public void testTableRecordReaderScannerFailMapreduce()
                                               throws java.io.IOException,
                                                      java.lang.InterruptedException

Run test assuming Scanner IOException failure using newer mapreduce api

Throws:

java.io.IOException

java.lang.InterruptedException

testTableRecordReaderScannerFailMapreduceTwice

public void testTableRecordReaderScannerFailMapreduceTwice()
                                                    throws java.io.IOException,
                                                           java.lang.InterruptedException

Run test assuming Scanner IOException failure using newer mapreduce api

Throws:

java.io.IOException

java.lang.InterruptedException

testTableRecordReaderScannerTimeoutMapreduce

public void testTableRecordReaderScannerTimeoutMapreduce()
                                                  throws java.io.IOException,
                                                         java.lang.InterruptedException

Run test assuming NotServingRegionException using newer mapreduce api

Throws:

java.lang.InterruptedException

org.apache.hadoop.hbase.DoNotRetryIOException

java.io.IOException

testTableRecordReaderScannerTimeoutMapreduceTwice

public void testTableRecordReaderScannerTimeoutMapreduceTwice()
                                                       throws java.io.IOException,
                                                              java.lang.InterruptedException

Run test assuming NotServingRegionException using newer mapreduce api

Throws:

java.lang.InterruptedException

org.apache.hadoop.hbase.NotServingRegionException

java.io.IOException

testExtensionOfTableInputFormatBase

public void testExtensionOfTableInputFormatBase()
                                         throws java.io.IOException,
                                                java.lang.InterruptedException,
                                                java.lang.ClassNotFoundException

Verify the example we present in javadocs on TableInputFormatBase

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException

testJobConfigurableExtensionOfTableInputFormatBase

public void testJobConfigurableExtensionOfTableInputFormatBase()
                                                        throws java.io.IOException,
                                                               java.lang.InterruptedException,
                                                               java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException

testDeprecatedExtensionOfTableInputFormatBase

public void testDeprecatedExtensionOfTableInputFormatBase()
                                                   throws java.io.IOException,
                                                          java.lang.InterruptedException,
                                                          java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException