org.apache.hadoop.hbase.thrift

Class TestThriftServer

java.lang.Object

org.apache.hadoop.hbase.thrift.TestThriftServer

public class TestThriftServer
extends Object

Unit testing for ThriftServerRunner.HBaseServiceHandler, a part of the org.apache.hadoop.hbase.thrift package.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestThriftServer.MySlowHBaseHandler

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static ByteBuffer	columnAAname
private static ByteBuffer	columnAname
private static ByteBuffer	columnBname
private static org.slf4j.Logger	LOG
protected static int	MAXVERSIONS
private static MetricsAssertHelper	metricsHelper
org.junit.rules.TestName	name
private static ByteBuffer	rowAname
private static ByteBuffer	rowBname
private static ByteBuffer	tableAname
private static ByteBuffer	tableBname
private static HBaseTestingUtility	UTIL
private static ByteBuffer	valueAname
private static ByteBuffer	valueBname
private static ByteBuffer	valueCname
private static ByteBuffer	valueDname
private static ByteBuffer	valueEname

Constructor Summary

Constructors

Constructor and Description
TestThriftServer()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
private static ByteBuffer	asByteBuffer(long l)
private static ByteBuffer	asByteBuffer(String i)
static void	beforeClass()
static void	checkTableList(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
private void	closeScanner(int scannerId, org.apache.hadoop.hbase.thrift.ThriftHBaseServiceHandler handler) Asserts that the passed scanner is exhausted, and then closes the scanner.
private static int	countTablesByStatus(Boolean isEnabled, org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
static void	createTestTables(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
static void	doTestAppend() Appends the value to a cell and checks that the cell value is updated properly.
static void	doTestCheckAndPut() Check that checkAndPut fails if the cell does not exist, then put in the cell, then check that the checkAndPut succeeds.
void	doTestFilterRegistration()
void	doTestGetRegionInfo()
static void	doTestGetRegionInfo(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
void	doTestGetTableRegions() For HBASE-2556 Tests for GetTableRegions n
static void	doTestGetTableRegions(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
void	doTestIncrements()
static void	doTestIncrements(org.apache.hadoop.hbase.thrift.ThriftHBaseServiceHandler handler)
void	doTestTableCreateDrop() Tests for creating, enabling, disabling, and deleting tables.
static void	doTestTableCreateDrop(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
void	doTestTableMutations() Tests adding a series of Mutations and BatchMutations, including a delete mutation.
static void	doTestTableMutations(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
void	doTestTableScanners() Tests the four different scanner-opening methods (with and without a stoprow, with and without a timestamp).
void	doTestTableTimestampsAndColumns() Similar to testTableMutations(), except Mutations are applied with specific timestamps and data retrieval uses these timestamps to extract specific versions of data.
void	doTestThriftMetrics() Tests if the metrics for thrift handler work correctly
static void	dropTestTables(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
private static List<org.apache.hadoop.hbase.thrift.generated.BatchMutation>	getBatchMutations()
private static List<org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor>	getColumnDescriptors()
private List<ByteBuffer>	getColumnList(boolean includeA, boolean includeB)
private int	getCurrentCount(String name, int maybe, org.apache.hadoop.hbase.thrift.ThriftMetrics metrics) TODO: These counts are supposed to be zero but sometimes they are not, they are equal to the passed in maybe.
private static org.apache.hadoop.hbase.thrift.generated.Hbase.Iface	getHandlerForMetricsTest(org.apache.hadoop.hbase.thrift.ThriftMetrics metrics, org.apache.hadoop.conf.Configuration conf)
private static org.apache.hadoop.hbase.thrift.ThriftMetrics	getMetrics(org.apache.hadoop.conf.Configuration conf)
private static List<org.apache.hadoop.hbase.thrift.generated.Mutation>	getMutations() Returns a List of Mutations for a row, with columnA having valueA and columnB having valueB
void	testAll() Runs all of the tests under a single JUnit test method.
private void	testExceptionType(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler, org.apache.hadoop.hbase.thrift.ThriftMetrics metrics, ByteBuffer tTableName, String rowkey, ErrorThrowingGetObserver.ErrorType errorType)
void	testGetTableNamesWithStatus()
void	testGetThriftServerOneType() Verify that thrift client calling thrift2 server can get the thrift2 server type correctly.
void	testGetThriftServerType()
void	testMetricsWithException()

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

UTIL

private static final HBaseTestingUtility UTIL

LOG

private static final org.slf4j.Logger LOG

metricsHelper

private static final MetricsAssertHelper metricsHelper

MAXVERSIONS

protected static final int MAXVERSIONS

See Also:

Constant Field Values

tableAname

private static ByteBuffer tableAname

tableBname

private static ByteBuffer tableBname

columnAname

private static ByteBuffer columnAname

columnAAname

private static ByteBuffer columnAAname

columnBname

private static ByteBuffer columnBname

rowAname

private static ByteBuffer rowAname

rowBname

private static ByteBuffer rowBname

valueAname

private static ByteBuffer valueAname

valueBname

private static ByteBuffer valueBname

valueCname

private static ByteBuffer valueCname

valueDname

private static ByteBuffer valueDname

valueEname

private static ByteBuffer valueEname

name

public org.junit.rules.TestName name

Constructor Detail

TestThriftServer

public TestThriftServer()

Method Detail

asByteBuffer

private static ByteBuffer asByteBuffer(String i)

asByteBuffer

private static ByteBuffer asByteBuffer(long l)

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

testAll

public void testAll()
             throws Exception

Runs all of the tests under a single JUnit test method. We consolidate all testing to one method because HBaseClusterTestCase is prone to OutOfMemoryExceptions when there are three or more JUnit test methods. n

Throws:

Exception

doTestTableCreateDrop

public void doTestTableCreateDrop()
                           throws Exception

Tests for creating, enabling, disabling, and deleting tables. Also tests that creating a table with an invalid column name yields an IllegalArgument exception. n

Throws:

Exception

doTestTableCreateDrop

public static void doTestTableCreateDrop(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
                                  throws Exception

Throws:

Exception

getCurrentCount

private int getCurrentCount(String name,
                            int maybe,
                            org.apache.hadoop.hbase.thrift.ThriftMetrics metrics)

TODO: These counts are supposed to be zero but sometimes they are not, they are equal to the passed in maybe. Investigate why. My guess is they are set by the test that runs just previous to this one. Sometimes they are cleared. Sometimes not. nnnn

doTestThriftMetrics

public void doTestThriftMetrics()
                         throws Exception

Tests if the metrics for thrift handler work correctly

Throws:

Exception

getHandlerForMetricsTest

private static org.apache.hadoop.hbase.thrift.generated.Hbase.Iface getHandlerForMetricsTest(org.apache.hadoop.hbase.thrift.ThriftMetrics metrics,
                                                                                             org.apache.hadoop.conf.Configuration conf)
                                                                                      throws Exception

Throws:

Exception

getMetrics

private static org.apache.hadoop.hbase.thrift.ThriftMetrics getMetrics(org.apache.hadoop.conf.Configuration conf)
                                                                throws Exception

Throws:

Exception

createTestTables

public static void createTestTables(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
                             throws Exception

Throws:

Exception

checkTableList

public static void checkTableList(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
                           throws Exception

Throws:

Exception

dropTestTables

public static void dropTestTables(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
                           throws Exception

Throws:

Exception

doTestIncrements

public void doTestIncrements()
                      throws Exception

Throws:

Exception

doTestIncrements

public static void doTestIncrements(org.apache.hadoop.hbase.thrift.ThriftHBaseServiceHandler handler)
                             throws Exception

Throws:

Exception

doTestTableMutations

public void doTestTableMutations()
                          throws Exception

Tests adding a series of Mutations and BatchMutations, including a delete mutation. Also tests data retrieval, and getting back multiple versions. n

Throws:

Exception

doTestTableMutations

public static void doTestTableMutations(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
                                 throws Exception

Throws:

Exception

doTestTableTimestampsAndColumns

public void doTestTableTimestampsAndColumns()
                                     throws Exception

Similar to testTableMutations(), except Mutations are applied with specific timestamps and data retrieval uses these timestamps to extract specific versions of data. n

Throws:

Exception

doTestTableScanners

public void doTestTableScanners()
                         throws Exception

Tests the four different scanner-opening methods (with and without a stoprow, with and without a timestamp). n

Throws:

Exception

doTestGetTableRegions

public void doTestGetTableRegions()
                           throws Exception

For HBASE-2556 Tests for GetTableRegions n

Throws:

Exception

doTestGetTableRegions

public static void doTestGetTableRegions(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
                                  throws Exception

Throws:

Exception

doTestFilterRegistration

public void doTestFilterRegistration()
                              throws Exception

Throws:

Exception

doTestGetRegionInfo

public void doTestGetRegionInfo()
                         throws Exception

Throws:

Exception

doTestGetRegionInfo

public static void doTestGetRegionInfo(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
                                throws Exception

Throws:

Exception

doTestAppend

public static void doTestAppend()
                         throws Exception

Appends the value to a cell and checks that the cell value is updated properly. n

Throws:

Exception

doTestCheckAndPut

public static void doTestCheckAndPut()
                              throws Exception

Check that checkAndPut fails if the cell does not exist, then put in the cell, then check that the checkAndPut succeeds. n

Throws:

Exception

testGetTableNamesWithStatus

public void testGetTableNamesWithStatus()
                                 throws Exception

Throws:

Exception

countTablesByStatus

private static int countTablesByStatus(Boolean isEnabled,
                                       org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler)
                                throws Exception

Throws:

Exception

testMetricsWithException

public void testMetricsWithException()
                              throws Exception

Throws:

Exception

testExceptionType

private void testExceptionType(org.apache.hadoop.hbase.thrift.generated.Hbase.Iface handler,
                               org.apache.hadoop.hbase.thrift.ThriftMetrics metrics,
                               ByteBuffer tTableName,
                               String rowkey,
                               ErrorThrowingGetObserver.ErrorType errorType)
                        throws Exception

Throws:

Exception

getColumnDescriptors

private static List<org.apache.hadoop.hbase.thrift.generated.ColumnDescriptor> getColumnDescriptors()

Returns:

a List of ColumnDescriptors for use in creating a table. Has one default ColumnDescriptor and one ColumnDescriptor with fewer versions

getColumnList

private List<ByteBuffer> getColumnList(boolean includeA,
                                       boolean includeB)

Parameters:

includeA - whether or not to include columnA

includeB - whether or not to include columnB

Returns:

a List of column names for use in retrieving a scanner

getMutations

private static List<org.apache.hadoop.hbase.thrift.generated.Mutation> getMutations()

Returns a List of Mutations for a row, with columnA having valueA and columnB having valueB

getBatchMutations

private static List<org.apache.hadoop.hbase.thrift.generated.BatchMutation> getBatchMutations()

Returns:

a List of BatchMutations with the following effects: (rowA, columnA): delete (rowA, columnB): place valueC (rowB, columnA): place valueC (rowB, columnB): place valueD

closeScanner

private void closeScanner(int scannerId,
                          org.apache.hadoop.hbase.thrift.ThriftHBaseServiceHandler handler)
                   throws Exception

Asserts that the passed scanner is exhausted, and then closes the scanner.

Parameters:

scannerId - the scanner to close

handler - the HBaseServiceHandler interfacing to HBase n

Throws:

Exception

testGetThriftServerType

public void testGetThriftServerType()
                             throws Exception

Throws:

Exception

testGetThriftServerOneType

public void testGetThriftServerOneType()
                                throws Exception

Verify that thrift client calling thrift2 server can get the thrift2 server type correctly.

Throws:

Exception