org.apache.hadoop.hbase.thrift2

Class TestThriftHBaseServiceHandler

java.lang.Object

org.apache.hadoop.hbase.thrift2.TestThriftHBaseServiceHandler

public class TestThriftHBaseServiceHandler
extends Object

Unit testing for ThriftServer.HBaseHandler, a part of the org.apache.hadoop.hbase.thrift2 package.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestThriftHBaseServiceHandler.DelayingRegionObserver

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.HColumnDescriptor[]	families
private static byte[]	familyAname
private static byte[]	familyBname
private static org.slf4j.Logger	LOG
private static MetricsAssertHelper	metricsHelper
org.junit.rules.TestName	name
private static byte[]	qualifierAname
private static byte[]	qualifierBname
private static byte[]	tableAname
private static HBaseTestingUtility	UTIL
private static byte[]	valueAname
private static byte[]	valueBname

Constructor Summary

Constructors

Constructor and Description
TestThriftHBaseServiceHandler()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
void	assertTColumnValueEqual(org.apache.hadoop.hbase.thrift2.generated.TColumnValue a, org.apache.hadoop.hbase.thrift2.generated.TColumnValue b)
void	assertTColumnValuesEqual(List<org.apache.hadoop.hbase.thrift2.generated.TColumnValue> columnValuesA, List<org.apache.hadoop.hbase.thrift2.generated.TColumnValue> columnValuesB)
static void	beforeClass()
private org.apache.hadoop.hbase.thrift2.ThriftHBaseServiceHandler	createHandler()
private static org.apache.hadoop.hbase.thrift.ThriftMetrics	getMetrics(org.apache.hadoop.conf.Configuration conf)
private String	pad(int n, byte pad) Padding numbers to make comparison of sort order easier in a for loop
void	setup()
void	testAppend()
void	testAttribute()
void	testCheckAndDelete() check that checkAndDelete fails if the cell does not exist, then put in the cell, then check that the checkAndDelete succeeds.
void	testCheckAndMutate()
void	testCheckAndPut() check that checkAndPut fails if the cell does not exist, then put in the cell, then check that the checkAndPut succeeds.
void	testDelete()
void	testDeleteAllTimestamps()
void	testDeleteFamily()
void	testDeleteFamilyVersion()
void	testDeleteMultiple()
void	testDeleteSingleTimestamp()
void	testDurability() Create TPut, TDelete , TIncrement objects, set durability then call ThriftUtility functions to get Put , Delete and Increment respectively.
private void	testExceptionType(org.apache.hadoop.hbase.thrift2.generated.THBaseService.Iface handler, org.apache.hadoop.hbase.thrift.ThriftMetrics metrics, ByteBuffer tTableName, byte[] rowkey, ErrorThrowingGetObserver.ErrorType errorType)
void	testExists()
void	testExistsAll()
void	testFilterRegistration()
void	testGetScannerResults()
void	testIncrement()
void	testLongLivedScan() Tests keeping a HBase scanner alive for long periods of time.
void	testMetrics()
void	testMetricsPrecision() See HBASE-17611 Latency metrics were capped at ~ 2 seconds due to the use of an int variable to capture the duration.
void	testMetricsWithException()
void	testMutateRow() Put valueA to a row, make sure put has happened, then create a mutation object to put valueB and delete ValueA, then check that the row value is only valueB.
void	testPutGet()
void	testPutGetMultiple()
void	testPutTTL()
void	testReverseScan()
void	testScan()
void	testScanWithBatchSize()
void	testScanWithColumnFamilyTimeRange()
void	testScanWithFilter()
void	testSmallScan()

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

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtility UTIL

tableAname

private static byte[] tableAname

familyAname

private static byte[] familyAname

familyBname

private static byte[] familyBname

qualifierAname

private static byte[] qualifierAname

qualifierBname

private static byte[] qualifierBname

valueAname

private static byte[] valueAname

valueBname

private static byte[] valueBname

families

private static org.apache.hadoop.hbase.HColumnDescriptor[] families

metricsHelper

private static final MetricsAssertHelper metricsHelper

name

public org.junit.rules.TestName name

Constructor Detail

TestThriftHBaseServiceHandler

public TestThriftHBaseServiceHandler()

Method Detail

assertTColumnValuesEqual

public void assertTColumnValuesEqual(List<org.apache.hadoop.hbase.thrift2.generated.TColumnValue> columnValuesA,
                                     List<org.apache.hadoop.hbase.thrift2.generated.TColumnValue> columnValuesB)

assertTColumnValueEqual

public void assertTColumnValueEqual(org.apache.hadoop.hbase.thrift2.generated.TColumnValue a,
                                    org.apache.hadoop.hbase.thrift2.generated.TColumnValue b)

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

setup

public void setup()
           throws Exception

Throws:

Exception

createHandler

private org.apache.hadoop.hbase.thrift2.ThriftHBaseServiceHandler createHandler()
                                                                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

testExists

public void testExists()
                throws org.apache.hadoop.hbase.thrift2.generated.TIOError,
                       org.apache.thrift.TException

Throws:

org.apache.hadoop.hbase.thrift2.generated.TIOError

org.apache.thrift.TException

testExistsAll

public void testExistsAll()
                   throws org.apache.hadoop.hbase.thrift2.generated.TIOError,
                          org.apache.thrift.TException

Throws:

org.apache.hadoop.hbase.thrift2.generated.TIOError

org.apache.thrift.TException

testPutGet

public void testPutGet()
                throws Exception

Throws:

Exception

testPutGetMultiple

public void testPutGetMultiple()
                        throws Exception

Throws:

Exception

testDeleteMultiple

public void testDeleteMultiple()
                        throws Exception

Throws:

Exception

testDelete

public void testDelete()
                throws Exception

Throws:

Exception

testDeleteAllTimestamps

public void testDeleteAllTimestamps()
                             throws Exception

Throws:

Exception

testDeleteSingleTimestamp

public void testDeleteSingleTimestamp()
                               throws Exception

Throws:

Exception

testDeleteFamily

public void testDeleteFamily()
                      throws Exception

Throws:

Exception

testDeleteFamilyVersion

public void testDeleteFamilyVersion()
                             throws Exception

Throws:

Exception

testIncrement

public void testIncrement()
                   throws Exception

Throws:

Exception

testAppend

public void testAppend()
                throws Exception

Throws:

Exception

testCheckAndPut

public void testCheckAndPut()
                     throws Exception

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

Throws:

Exception

testCheckAndDelete

public void testCheckAndDelete()
                        throws Exception

check that checkAndDelete fails if the cell does not exist, then put in the cell, then check that the checkAndDelete succeeds.

Throws:

Exception

testScan

public void testScan()
              throws Exception

Throws:

Exception

testLongLivedScan

public void testLongLivedScan()
                       throws Exception

Tests keeping a HBase scanner alive for long periods of time. Each call to getScannerRow() should reset the ConnectionCache timeout for the scanner's connection

Throws:

Exception

testReverseScan

public void testReverseScan()
                     throws Exception

Throws:

Exception

testScanWithFilter

public void testScanWithFilter()
                        throws Exception

Throws:

Exception

testScanWithColumnFamilyTimeRange

public void testScanWithColumnFamilyTimeRange()
                                       throws Exception

Throws:

Exception

testSmallScan

public void testSmallScan()
                   throws Exception

Throws:

Exception

testPutTTL

public void testPutTTL()
                throws Exception

Throws:

Exception

pad

private String pad(int n,
                   byte pad)

Padding numbers to make comparison of sort order easier in a for loop

Parameters:

n - The number to pad.

pad - The length to pad up to.

Returns:

The padded number as a string.

testScanWithBatchSize

public void testScanWithBatchSize()
                           throws Exception

Throws:

Exception

testGetScannerResults

public void testGetScannerResults()
                           throws Exception

Throws:

Exception

testFilterRegistration

public void testFilterRegistration()
                            throws Exception

Throws:

Exception

testMetrics

public void testMetrics()
                 throws Exception

Throws:

Exception

getMetrics

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

Throws:

Exception

testMetricsWithException

public void testMetricsWithException()
                              throws Exception

Throws:

Exception

testExceptionType

private void testExceptionType(org.apache.hadoop.hbase.thrift2.generated.THBaseService.Iface handler,
                               org.apache.hadoop.hbase.thrift.ThriftMetrics metrics,
                               ByteBuffer tTableName,
                               byte[] rowkey,
                               ErrorThrowingGetObserver.ErrorType errorType)

testMetricsPrecision

public void testMetricsPrecision()
                          throws Exception

See HBASE-17611 Latency metrics were capped at ~ 2 seconds due to the use of an int variable to capture the duration.

Throws:

Exception

testAttribute

public void testAttribute()
                   throws Exception

Throws:

Exception

testMutateRow

public void testMutateRow()
                   throws Exception

Put valueA to a row, make sure put has happened, then create a mutation object to put valueB and delete ValueA, then check that the row value is only valueB.

Throws:

Exception

testDurability

public void testDurability()
                    throws Exception

Create TPut, TDelete , TIncrement objects, set durability then call ThriftUtility functions to get Put , Delete and Increment respectively. Use getDurability to make sure the returned objects have the appropriate durability setting.

Throws:

Exception

testCheckAndMutate

public void testCheckAndMutate()
                        throws Exception

Throws:

Exception