Package org.apache.hadoop.hbase.master.normalizer

Class TestRegionNormalizerManagerConfigurationObserver

java.lang.Object

org.apache.hadoop.hbase.master.normalizer.TestRegionNormalizerManagerConfigurationObserver

public class TestRegionNormalizerManagerConfigurationObserver
extends Object

Test that configuration changes are propagated to all children.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerChore	chore
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.hbase.conf.ConfigurationManager	configurationManager
private org.apache.hadoop.hbase.master.MasterServices	masterServices
private org.apache.hadoop.hbase.master.normalizer.SimpleRegionNormalizer	normalizer
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorkQueue<org.apache.hadoop.hbase.TableName>	queue
private static final Pattern	rateLimitPattern
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerStateStore	stateStore
private static final HBaseTestingUtility	testUtil
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorker	worker

Constructor Summary

Constructors

Constructor	Description
TestRegionNormalizerManagerConfigurationObserver()

Method Summary

Modifier and Type	Method	Description
void	before()
private static long	parseConfiguredRateLimit(org.apache.hbase.thirdparty.com.google.common.util.concurrent.RateLimiter rateLimiter)	The RateLimiter class does not publicly expose its currently configured rate.
void	test()

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

testUtil

private static final HBaseTestingUtility testUtil

rateLimitPattern

private static final Pattern rateLimitPattern

conf

private org.apache.hadoop.conf.Configuration conf

normalizer

private org.apache.hadoop.hbase.master.normalizer.SimpleRegionNormalizer normalizer

masterServices

@Mock
private org.apache.hadoop.hbase.master.MasterServices masterServices

stateStore

@Mock
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerStateStore stateStore

chore

@Mock
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerChore chore

queue

@Mock
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorkQueue<org.apache.hadoop.hbase.TableName> queue

worker

private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorker worker

configurationManager

private org.apache.hadoop.hbase.conf.ConfigurationManager configurationManager

Constructor Details

TestRegionNormalizerManagerConfigurationObserver

public TestRegionNormalizerManagerConfigurationObserver()

Method Details

before

public void before()

test

public void test()

parseConfiguredRateLimit

private static long parseConfiguredRateLimit(org.apache.hbase.thirdparty.com.google.common.util.concurrent.RateLimiter rateLimiter)

The RateLimiter class does not publicly expose its currently configured rate. It does offer this information in the RateLimiter.toString() method. It's fragile, but parse this value. The alternative would be to track the value explicitly in the worker, and the associated coordination overhead paid at runtime. See the related note on RegionNormalizerWorker.getRateLimiter().