Package org.apache.hadoop.hbase.regionserver

Class TestRegionServerMetrics

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionServerMetrics

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

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Admin	admin
private static byte[]	cf
private static SingleProcessHBaseCluster	cluster
private static org.apache.hadoop.conf.Configuration	conf
private static org.apache.hadoop.hbase.client.Connection	connection
private static final org.slf4j.Logger	LOG
private static MetricsAssertHelper	metricsHelper
private static org.apache.hadoop.hbase.regionserver.MetricsRegionServer	metricsRegionServer
private static final int	NUM_SCAN_NEXT
private static int	numScanNext
private static byte[]	qualifier
private static byte[]	row
private static org.apache.hadoop.hbase.regionserver.HRegionServer	rs
private static org.apache.hadoop.hbase.regionserver.MetricsRegionServerSource	serverSource
(package private) org.apache.hadoop.hbase.client.Table	table
(package private) org.apache.hadoop.hbase.TableName	tableName
private static HBaseTestingUtil	TEST_UTIL
private static byte[]	val

Constructor Summary

Constructors

Constructor	Description
TestRegionServerMetrics()

Method Summary

Modifier and Type	Method	Description
static void	after()
void	afterTestMethod()
private void	assertCounter(String metric, long expectedValue)
private void	assertGauge(String metric, long expectedValue)
private void	assertRegionMetrics(String metric, long expectedValue)
void	beforeTestMethod(org.junit.jupiter.api.TestInfo testInfo)
private void	doNGets(int n, boolean batch)
private void	doNPuts(int n, boolean batch)
private void	doScan(int n, boolean caching)
private static org.apache.hadoop.hbase.regionserver.Region	setMobThreshold(org.apache.hadoop.hbase.regionserver.Region region, byte[] cfName, long modThreshold)
static void	startCluster()
void	testAppend()
void	testAverageRegionSize()
void	testCheckAndPutCount()
void	testGet()
void	testIncrement()
void	testLocalFiles()
void	testMobMetrics()
void	testMutationsWithoutWal()
void	testRangeCountMetrics()
void	testReadBytes()
void	testRegionCount()
void	testRequestCount()
void	testScanSize()
void	testScanSizeForSmallScan()
void	testScanTime()
void	testStoreCount()
void	testStoreFileAge()
void	testTableDescriptorHashMetric()

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

metricsHelper

private static MetricsAssertHelper metricsHelper

cluster

private static SingleProcessHBaseCluster cluster

rs

private static org.apache.hadoop.hbase.regionserver.HRegionServer rs

conf

private static org.apache.hadoop.conf.Configuration conf

TEST_UTIL

private static HBaseTestingUtil TEST_UTIL

connection

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

metricsRegionServer

private static org.apache.hadoop.hbase.regionserver.MetricsRegionServer metricsRegionServer

serverSource

private static org.apache.hadoop.hbase.regionserver.MetricsRegionServerSource serverSource

NUM_SCAN_NEXT

private static final int NUM_SCAN_NEXT

See Also:

• Constant Field Values

numScanNext

private static int numScanNext

cf

private static byte[] cf

row

private static byte[] row

qualifier

private static byte[] qualifier

val

private static byte[] val

admin

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

tableName

org.apache.hadoop.hbase.TableName tableName

table

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

Constructor Details

TestRegionServerMetrics

public TestRegionServerMetrics()

Method Details

startCluster

@BeforeAll
public static void startCluster()
                         throws Exception

Throws:

Exception

after

@AfterAll
public static void after()
                  throws Exception

Throws:

Exception

beforeTestMethod

@BeforeEach
public void beforeTestMethod(org.junit.jupiter.api.TestInfo testInfo)
                      throws Exception

Throws:

Exception

afterTestMethod

@AfterEach
public void afterTestMethod()
                     throws Exception

Throws:

Exception

assertCounter

private void assertCounter(String metric,
 long expectedValue)

assertGauge

private void assertGauge(String metric,
 long expectedValue)

assertRegionMetrics

private void assertRegionMetrics(String metric,
 long expectedValue)
                          throws Exception

Throws:

Exception

doNPuts

private void doNPuts(int n,
 boolean batch)
              throws Exception

Throws:

Exception

doNGets

private void doNGets(int n,
 boolean batch)
              throws Exception

Throws:

Exception

doScan

private void doScan(int n,
 boolean caching)
             throws IOException

Throws:

IOException

testRegionCount

@Test
public void testRegionCount()
                     throws Exception

Throws:

Exception

testLocalFiles

@Test
public void testLocalFiles()
                    throws Exception

Throws:

Exception

testRequestCount

@Test
public void testRequestCount()
                      throws Exception

Throws:

Exception

testGet

@Test
public void testGet()
             throws Exception

Throws:

Exception

testMutationsWithoutWal

@Test
public void testMutationsWithoutWal()
                             throws Exception

Throws:

Exception

testStoreCount

@Test
public void testStoreCount()
                    throws Exception

Throws:

Exception

testStoreFileAge

@Test
public void testStoreFileAge()
                      throws Exception

Throws:

Exception

testCheckAndPutCount

@Test
public void testCheckAndPutCount()
                          throws Exception

Throws:

Exception

testIncrement

@Test
public void testIncrement()
                   throws Exception

Throws:

Exception

testAppend

@Test
public void testAppend()
                throws Exception

Throws:

Exception

testScanSize

@Test
public void testScanSize()
                  throws Exception

Throws:

Exception

testScanTime

@Test
public void testScanTime()
                  throws Exception

Throws:

Exception

testScanSizeForSmallScan

@Test
public void testScanSizeForSmallScan()
                              throws Exception

Throws:

Exception

testMobMetrics

@Test
public void testMobMetrics()
                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

setMobThreshold

private static org.apache.hadoop.hbase.regionserver.Region setMobThreshold(org.apache.hadoop.hbase.regionserver.Region region,
 byte[] cfName,
 long modThreshold)

testRangeCountMetrics

@Test
@Disabled
public void testRangeCountMetrics()
                           throws Exception

Throws:

Exception

testAverageRegionSize

@Test
public void testAverageRegionSize()
                           throws Exception

Throws:

Exception

testReadBytes

@Test
public void testReadBytes()
                   throws Exception

Throws:

Exception

testTableDescriptorHashMetric

@Test
public void testTableDescriptorHashMetric()
                                   throws Exception

Throws:

Exception