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 and Description
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerChore	chore
static 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 Pattern	rateLimitPattern
private static HBaseTestingUtility	testUtil
private org.apache.hadoop.hbase.zookeeper.RegionNormalizerTracker	tracker
private org.apache.hadoop.hbase.master.normalizer.RegionNormalizerWorker	worker

Constructor Summary

Constructors

Constructor and Description
TestRegionNormalizerManagerConfigurationObserver()

Method Summary

Modifier and Type	Method and 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 Detail

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

tracker

@Mock
private org.apache.hadoop.hbase.zookeeper.RegionNormalizerTracker tracker

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 Detail

TestRegionNormalizerManagerConfigurationObserver

public TestRegionNormalizerManagerConfigurationObserver()

Method Detail

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().