Package org.apache.hadoop.hbase.regionserver

Class TestRegionServerReadRequestMetrics

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionServerReadRequestMetrics

public class TestRegionServerReadRequestMetrics
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	TestRegionServerReadRequestMetrics.Metric
static class	TestRegionServerReadRequestMetrics.ScanRegionCoprocessor

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Admin	admin
private static final byte[]	CF1
private static final byte[]	CF2
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	COL1
private static final byte[]	COL2
private static final byte[]	COL3
private static final org.slf4j.Logger	LOG
private static final int	MAX_TRY
private static org.apache.hadoop.hbase.client.RegionInfo	regionInfo
private static Map<TestRegionServerReadRequestMetrics.Metric,Long>	requestsMap
private static Map<TestRegionServerReadRequestMetrics.Metric,Long>	requestsMapPrev
private static final byte[]	ROW1
private static final byte[]	ROW2
private static final byte[]	ROW3
private static Collection<org.apache.hadoop.hbase.ServerName>	serverNames
private static final int	SLEEP_MS
private static org.apache.hadoop.hbase.client.Table	table
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	TEST_UTIL
private static final int	TTL
private static final byte[]	VAL1
private static final byte[]	VAL2
private static final byte[]	VAL3

Constructor Summary

Constructors

Constructor	Description
TestRegionServerReadRequestMetrics()

Method Summary

Modifier and Type	Method	Description
private static org.apache.hadoop.hbase.client.Table	createTable()
private static long	getReadRequest(org.apache.hadoop.hbase.ServerMetrics serverMetrics, org.apache.hadoop.hbase.RegionMetrics regionMetrics, TestRegionServerReadRequestMetrics.Metric metric)
private static void	putData()
private static void	putTTLExpiredData()
static void	setUpOnce()
static void	tearDownOnce()
private void	testReadRequests(byte[] regionName, int expectedReadRequests)
private static void	testReadRequests(long resultCount, long expectedReadRequests, long expectedFilteredReadRequests)
void	testReadRequestsCountNotFiltered()
void	testReadRequestsCountWithDeletedRow()
void	testReadRequestsCountWithFilter()
void	testReadRequestsCountWithTTLExpiration()
void	testReadRequestsWithCoprocessor()
private static void	updateMetricsMap()

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

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

TABLE_NAME

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

CF1

private static final byte[] CF1

CF2

private static final byte[] CF2

ROW1

private static final byte[] ROW1

ROW2

private static final byte[] ROW2

ROW3

private static final byte[] ROW3

COL1

private static final byte[] COL1

COL2

private static final byte[] COL2

COL3

private static final byte[] COL3

VAL1

private static final byte[] VAL1

VAL2

private static final byte[] VAL2

VAL3

private static final byte[] VAL3

MAX_TRY

private static final int MAX_TRY

See Also:

• Constant Field Values

SLEEP_MS

private static final int SLEEP_MS

See Also:

• Constant Field Values

TTL

private static final int TTL

See Also:

• Constant Field Values

admin

private static org.apache.hadoop.hbase.client.Admin admin

serverNames

private static Collection<org.apache.hadoop.hbase.ServerName> serverNames

table

private static org.apache.hadoop.hbase.client.Table table

regionInfo

private static org.apache.hadoop.hbase.client.RegionInfo regionInfo

requestsMap

private static Map<TestRegionServerReadRequestMetrics.Metric,Long> requestsMap

requestsMapPrev

private static Map<TestRegionServerReadRequestMetrics.Metric,Long> requestsMapPrev

Constructor Details

TestRegionServerReadRequestMetrics

public TestRegionServerReadRequestMetrics()

Method Details

setUpOnce

public static void setUpOnce()
                      throws Exception

Throws:

Exception

createTable

private static org.apache.hadoop.hbase.client.Table createTable()
                                                         throws IOException

Throws:

IOException

testReadRequests

private static void testReadRequests(long resultCount,
 long expectedReadRequests,
 long expectedFilteredReadRequests)
                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

updateMetricsMap

private static void updateMetricsMap()
                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getReadRequest

private static long getReadRequest(org.apache.hadoop.hbase.ServerMetrics serverMetrics,
 org.apache.hadoop.hbase.RegionMetrics regionMetrics,
 TestRegionServerReadRequestMetrics.Metric metric)

putData

private static void putData()
                     throws IOException

Throws:

IOException

putTTLExpiredData

private static void putTTLExpiredData()
                               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

tearDownOnce

public static void tearDownOnce()
                         throws Exception

Throws:

Exception

testReadRequestsCountNotFiltered

public void testReadRequestsCountNotFiltered()
                                      throws Exception

Throws:

Exception

testReadRequestsCountWithFilter

public void testReadRequestsCountWithFilter()
                                     throws Exception

Throws:

Exception

testReadRequestsCountWithDeletedRow

public void testReadRequestsCountWithDeletedRow()
                                         throws Exception

Throws:

Exception

testReadRequestsCountWithTTLExpiration

public void testReadRequestsCountWithTTLExpiration()
                                            throws Exception

Throws:

Exception

testReadRequestsWithCoprocessor

public void testReadRequestsWithCoprocessor()
                                     throws Exception

Throws:

Exception

testReadRequests

private void testReadRequests(byte[] regionName,
 int expectedReadRequests)
                       throws Exception

Throws:

Exception