Package org.apache.hadoop.hbase.thrift2

Class TestThriftHBaseServiceHandler

java.lang.Object

org.apache.hadoop.hbase.thrift2.TestThriftHBaseServiceHandler

@Tag("org.apache.hadoop.hbase.testclassification.ClientTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestThriftHBaseServiceHandler
extends Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestThriftHBaseServiceHandler.DelayingRegionObserver

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.ColumnFamilyDescriptor[]	families
private static byte[]	familyAname
private static byte[]	familyBname
private static final org.slf4j.Logger	LOG
private static final MetricsAssertHelper	metricsHelper
private static byte[]	qualifierAname
private static byte[]	qualifierBname
private static byte[]	tableAname
private static final HBaseTestingUtil	UTIL
private static byte[]	valueAname
private static byte[]	valueBname

Constructor Summary

Constructors

Constructor	Description
TestThriftHBaseServiceHandler()

Method Summary

Modifier and Type	Method	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	testConsistency()
void	testDDLOpertions()
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	testExpiredScanner()
void	testFilterRegistration()
void	testGetScannerResults()
void	testGetTableDescriptor()
void	testGetThriftServerOneType()	Verify that thrift2 client calling thrift server can get the thrift server type correctly.
void	testGetThriftServerType()
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(org.junit.jupiter.api.TestInfo testInfo)
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	testPerformNamespacePermissions()
void	testPerformTablePermissions()
void	testPutGet()
void	testPutGetMultiple()
void	testPutTTL()
void	testReverseScan()
void	testScan()
void	testScanWithBatchSize()
void	testScanWithColumnFamilyTimeRange()
void	testScanWithFilter()
void	testSlowLogResponses()
void	testSmallScan()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtil 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.client.ColumnFamilyDescriptor[] families

metricsHelper

private static final MetricsAssertHelper metricsHelper

Constructor Details

TestThriftHBaseServiceHandler

public TestThriftHBaseServiceHandler()

Method Details

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

@BeforeAll
public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

@AfterAll
public static void afterClass()
                       throws Exception

Throws:

Exception

setup

@BeforeEach
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

@Test
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

@Test
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

@Test
public void testPutGet()
                throws Exception

Throws:

Exception

testPutGetMultiple

@Test
public void testPutGetMultiple()
                        throws Exception

Throws:

Exception

testDeleteMultiple

@Test
public void testDeleteMultiple()
                        throws Exception

Throws:

Exception

testDelete

@Test
public void testDelete()
                throws Exception

Throws:

Exception

testDeleteAllTimestamps

@Test
public void testDeleteAllTimestamps()
                             throws Exception

Throws:

Exception

testDeleteSingleTimestamp

@Test
public void testDeleteSingleTimestamp()
                               throws Exception

Throws:

Exception

testDeleteFamily

@Test
public void testDeleteFamily()
                      throws Exception

Throws:

Exception

testDeleteFamilyVersion

@Test
public void testDeleteFamilyVersion()
                             throws Exception

Throws:

Exception

testIncrement

@Test
public void testIncrement()
                   throws Exception

Throws:

Exception

testAppend

@Test
public void testAppend()
                throws Exception

Throws:

Exception

testCheckAndPut

@Test
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

@Test
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

@Test
public void testScan()
              throws Exception

Throws:

Exception

testLongLivedScan

@Test
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

@Test
public void testReverseScan()
                     throws Exception

Throws:

Exception

testScanWithFilter

@Test
public void testScanWithFilter()
                        throws Exception

Throws:

Exception

testScanWithColumnFamilyTimeRange

@Test
public void testScanWithColumnFamilyTimeRange()
                                       throws Exception

Throws:

Exception

testSmallScan

@Test
public void testSmallScan()
                   throws Exception

Throws:

Exception

testExpiredScanner

@Test
public void testExpiredScanner()
                        throws Exception

Throws:

Exception

testPutTTL

@Test
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

@Test
public void testScanWithBatchSize()
                           throws Exception

Throws:

Exception

testGetScannerResults

@Test
public void testGetScannerResults()
                           throws Exception

Throws:

Exception

testFilterRegistration

@Test
public void testFilterRegistration()
                            throws Exception

Throws:

Exception

testMetrics

@Test
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

@Test
public void testMetricsWithException(org.junit.jupiter.api.TestInfo testInfo)
                              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

@Test
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

@Test
public void testAttribute()
                   throws Exception

Throws:

Exception

testMutateRow

@Test
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

@Test
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

@Test
public void testCheckAndMutate()
                        throws Exception

Throws:

Exception

testConsistency

@Test
public void testConsistency()
                     throws Exception

Throws:

Exception

testDDLOpertions

@Test
public void testDDLOpertions()
                      throws Exception

Throws:

Exception

testGetTableDescriptor

@Test
public void testGetTableDescriptor()
                            throws Exception

Throws:

Exception

testGetThriftServerType

@Test
public void testGetThriftServerType()
                             throws Exception

Throws:

Exception

testGetThriftServerOneType

@Test
public void testGetThriftServerOneType()
                                throws Exception

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

Throws:

Exception

testSlowLogResponses

@Test
public void testSlowLogResponses()
                          throws Exception

Throws:

Exception

testPerformTablePermissions

@Test
public void testPerformTablePermissions()
                                 throws Throwable

Throws:

Throwable

testPerformNamespacePermissions

@Test
public void testPerformNamespacePermissions()
                                     throws Throwable

Throws:

Throwable