Package org.apache.hadoop.hbase.client

Class TestTableScanMetrics

java.lang.Object

org.apache.hadoop.hbase.client.FromClientSideBase

org.apache.hadoop.hbase.client.TestTableScanMetrics

public class TestTableScanMetrics
extends FromClientSideBase

Field Summary

Fields

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

Fields inherited from class org.apache.hadoop.hbase.client.FromClientSideBase

FAMILY, INVALID_FAMILY, QUALIFIER, ROW, SLAVES

Constructor Summary

Constructors

Constructor	Description
TestTableScanMetrics()

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 List<Object[]>	params()
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	testScanMetricsByRegionForMultiRegionScan()
void	testScanMetricsByRegionForSingleRegionScan()
void	testScanMetricsByRegionReset()
void	testScanMetricsByRegionWithRegionMerge()
void	testScanMetricsByRegionWithRegionMove()
void	testScanMetricsByRegionWithRegionSplit()
void	testScanMetricsDisabled()
void	testScanMetricsResetWithScanMetricsByRegionDisabled()
void	testScanMetricsWithScanMetricByRegionDisabled()

Methods inherited from class org.apache.hadoop.hbase.client.FromClientSideBase

afterClass, assertDoubleResult, assertEmptyResult, assertIncrementKey, assertKey, assertNResult, assertNResult, assertNullResult, assertNumKeys, assertRowCount, assertSingleResult, assertSingleResult, assertSingleResult, buildScanner, createScanWithRowFilter, createScanWithRowFilter, deleteColumns, equals, getAllVersionsAndVerify, getNumberOfRows, getSingleScanResult, getTestNull, getTestNull, getVerifySingleColumn, getVerifySingleEmpty, getVersionAndVerify, getVersionAndVerifyMissing, getVersionRangeAndVerify, getVersionRangeAndVerifyGreaterThan, initialize, isSameParameterizedCluster, makeN, makeNAscii, makeNBig, makeStamps, putRows, scanAllVersionsAndVerify, scanTestNull, scanTestNull, scanVerifySingleColumn, scanVerifySingleEmpty, scanVersionAndVerify, scanVersionAndVerifyMissing, scanVersionRangeAndVerify, scanVersionRangeAndVerifyGreaterThan, singleRowGetTest, singleRowScanTest, splitTable

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

scannerName

public String scannerName

originalScan

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

Constructor Details

TestTableScanMetrics

public TestTableScanMetrics()

Method Details

params

public static List<Object[]> params()

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

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

public void testScanMetricsDisabled()
                             throws Exception

Throws:

Exception

testScanMetricsWithScanMetricByRegionDisabled

public void testScanMetricsWithScanMetricByRegionDisabled()
                                                   throws Exception

Throws:

Exception

testScanMetricsResetWithScanMetricsByRegionDisabled

public void testScanMetricsResetWithScanMetricsByRegionDisabled()
                                                         throws Exception

Throws:

Exception

testScanMetricsByRegionForSingleRegionScan

public void testScanMetricsByRegionForSingleRegionScan()
                                                throws Exception

Throws:

Exception

testScanMetricsByRegionForMultiRegionScan

public void testScanMetricsByRegionForMultiRegionScan()
                                               throws Exception

Throws:

Exception

testScanMetricsByRegionReset

public void testScanMetricsByRegionReset()
                                  throws Exception

Throws:

Exception

testConcurrentUpdatesAndResetOfScanMetricsByRegion

public void testConcurrentUpdatesAndResetOfScanMetricsByRegion()
                                                        throws Exception

Throws:

Exception

testScanMetricsByRegionWithRegionMove

public void testScanMetricsByRegionWithRegionMove()
                                           throws Exception

Throws:

Exception

testScanMetricsByRegionWithRegionSplit

public void testScanMetricsByRegionWithRegionSplit()
                                            throws Exception

Throws:

Exception

testScanMetricsByRegionWithRegionMerge

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