Package org.apache.hadoop.hbase.client

Class TestTableScanMetrics

java.lang.Object

org.apache.hadoop.hbase.client.TestTableScanMetrics

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	CF
private static org.apache.hadoop.hbase.client.Connection	CONN
private static final byte[]	CQ
private static int	NUM_REGIONS
private org.apache.hadoop.hbase.client.Scan	originalScan
private static final Random	RAND
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	TEST_UTIL
private static final byte[]	VALUE

Constructor Summary

Constructors

Constructor	Description
TestTableScanMetrics(String scannerName, org.apache.hadoop.hbase.client.Scan originalScan)

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.client.metrics.ScanMetrics	assertScannedRowsAndGetScanMetrics(org.apache.hadoop.hbase.client.Scan scan, int expectedCount)
private org.apache.hadoop.hbase.client.Scan	generateScan(byte[] smallerRow, byte[] largerRow)
private Runnable	getPeriodicScanMetricsCollector(org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics, Map<org.apache.hadoop.hbase.client.metrics.ScanMetricsRegionInfo,Map<String,Long>> scanMetricsByRegionCollection, CountDownLatch latch)
private List<byte[]>	mergeRegions(org.apache.hadoop.hbase.TableName tableName, byte[] topRegion, byte[] bottomRegion)	Merges two regions with the start row key as topRegion and bottomRegion.
private void	mergeScanMetricsByRegion(Map<org.apache.hadoop.hbase.client.metrics.ScanMetricsRegionInfo,Map<String,Long>> srcMap, Map<org.apache.hadoop.hbase.client.metrics.ScanMetricsRegionInfo,Map<String,Long>> dstMap)
private byte[]	moveRegion(org.apache.hadoop.hbase.TableName tableName, byte[] startRow)	Moves the region with start row key from its original region server to some other region server.
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
static void	setUp()
private List<byte[]>	splitRegion(org.apache.hadoop.hbase.TableName tableName, byte[] startRow, byte[] splitKey)	Splits the region with start row key at the split key provided.
static void	tearDown()
void	testConcurrentUpdatesAndResetOfScanMetricsByRegion()
void	testRPCCallProcessingAndQueueWaitTimeMetrics()
void	testScanMetricsByRegionForMultiRegionScan()
void	testScanMetricsByRegionForSingleRegionScan()
void	testScanMetricsByRegionReset()
void	testScanMetricsByRegionWithRegionMerge()
void	testScanMetricsByRegionWithRegionMove()
void	testScanMetricsByRegionWithRegionSplit()
void	testScanMetricsDisabled()
void	testScanMetricsResetWithScanMetricsByRegionDisabled()
void	testScanMetricsWithScanMetricByRegionDisabled()

Methods inherited from class java.lang.Object

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

Field Details

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

CF

private static final byte[] CF

CQ

private static final byte[] CQ

VALUE

private static final byte[] VALUE

RAND

private static final Random RAND

NUM_REGIONS

private static int NUM_REGIONS

CONN

private static org.apache.hadoop.hbase.client.Connection CONN

originalScan

private org.apache.hadoop.hbase.client.Scan originalScan

Constructor Details

TestTableScanMetrics

public TestTableScanMetrics(String scannerName,
 org.apache.hadoop.hbase.client.Scan originalScan)

Method Details

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

generateScan

private org.apache.hadoop.hbase.client.Scan generateScan(byte[] smallerRow,
 byte[] largerRow)
                                                  throws IOException

Throws:

IOException

assertScannedRowsAndGetScanMetrics

private org.apache.hadoop.hbase.client.metrics.ScanMetrics assertScannedRowsAndGetScanMetrics(org.apache.hadoop.hbase.client.Scan scan,
 int expectedCount)
                                                                                       throws IOException

Throws:

IOException

testScanMetricsDisabled

@TestTemplate
public void testScanMetricsDisabled()
                             throws Exception

Throws:

Exception

testScanMetricsWithScanMetricByRegionDisabled

@TestTemplate
public void testScanMetricsWithScanMetricByRegionDisabled()
                                                   throws Exception

Throws:

Exception

testScanMetricsResetWithScanMetricsByRegionDisabled

@TestTemplate
public void testScanMetricsResetWithScanMetricsByRegionDisabled()
                                                         throws Exception

Throws:

Exception

testScanMetricsByRegionForSingleRegionScan

@TestTemplate
public void testScanMetricsByRegionForSingleRegionScan()
                                                throws Exception

Throws:

Exception

testScanMetricsByRegionForMultiRegionScan

@TestTemplate
public void testScanMetricsByRegionForMultiRegionScan()
                                               throws Exception

Throws:

Exception

testScanMetricsByRegionReset

@TestTemplate
public void testScanMetricsByRegionReset()
                                  throws Exception

Throws:

Exception

testConcurrentUpdatesAndResetOfScanMetricsByRegion

@TestTemplate
public void testConcurrentUpdatesAndResetOfScanMetricsByRegion()
                                                        throws Exception

Throws:

Exception

testRPCCallProcessingAndQueueWaitTimeMetrics

@TestTemplate
public void testRPCCallProcessingAndQueueWaitTimeMetrics()
                                                  throws Exception

Throws:

Exception

testScanMetricsByRegionWithRegionMove

@TestTemplate
public void testScanMetricsByRegionWithRegionMove()
                                           throws Exception

Throws:

Exception

testScanMetricsByRegionWithRegionSplit

@TestTemplate
public void testScanMetricsByRegionWithRegionSplit()
                                            throws Exception

Throws:

Exception

testScanMetricsByRegionWithRegionMerge

@TestTemplate
public void testScanMetricsByRegionWithRegionMerge()
                                            throws Exception

Throws:

Exception

getPeriodicScanMetricsCollector

private Runnable getPeriodicScanMetricsCollector(org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics,
 Map<org.apache.hadoop.hbase.client.metrics.ScanMetricsRegionInfo,Map<String,Long>> scanMetricsByRegionCollection,
 CountDownLatch latch)

mergeScanMetricsByRegion

private void mergeScanMetricsByRegion(Map<org.apache.hadoop.hbase.client.metrics.ScanMetricsRegionInfo,Map<String,Long>> srcMap,
 Map<org.apache.hadoop.hbase.client.metrics.ScanMetricsRegionInfo,Map<String,Long>> dstMap)

moveRegion

private byte[] moveRegion(org.apache.hadoop.hbase.TableName tableName,
 byte[] startRow)
                   throws IOException

Moves the region with start row key from its original region server to some other region server. This is a synchronous method.

Parameters:

tableName - Table name of region to be moved belongs.

startRow - Start row key of the region to be moved.

Returns:

Encoded region name of the region which was moved.

Throws:

IOException

splitRegion

private List<byte[]> splitRegion(org.apache.hadoop.hbase.TableName tableName,
 byte[] startRow,
 byte[] splitKey)
                          throws IOException

Splits the region with start row key at the split key provided. This is a synchronous method.

Parameters:

tableName - Table name of region to be split.

startRow - Start row key of the region to be split.

splitKey - Split key for splitting the region.

Returns:

List of encoded region names with first element being parent region followed by two child regions.

Throws:

IOException

mergeRegions

private List<byte[]> mergeRegions(org.apache.hadoop.hbase.TableName tableName,
 byte[] topRegion,
 byte[] bottomRegion)
                           throws IOException

Merges two regions with the start row key as topRegion and bottomRegion. Ensures that the regions to be merged are adjacent regions. This is a synchronous method.

Parameters:

tableName - Table name of regions to be merged.

topRegion - Start row key of first region for merging.

bottomRegion - Start row key of second region for merging.

Returns:

List of encoded region names with first two elements being original regions followed by the merged region.

Throws:

IOException