Package org.apache.hadoop.hbase.master.balancer

Class TestCacheAwareLoadBalancer

java.lang.Object

org.apache.hadoop.hbase.master.balancer.BalancerTestBase

org.apache.hadoop.hbase.master.balancer.TestCacheAwareLoadBalancer

public class TestCacheAwareLoadBalancer
extends BalancerTestBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

BalancerTestBase.MockMapping

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.master.balancer.CacheAwareLoadBalancer	loadBalancer
private static final org.slf4j.Logger	LOG
(package private) static List<org.apache.hadoop.hbase.ServerName>	servers
(package private) static List<org.apache.hadoop.hbase.client.TableDescriptor>	tableDescs
(package private) static Map<org.apache.hadoop.hbase.TableName,String>	tableMap
(package private) static org.apache.hadoop.hbase.TableName[]	tables

Fields inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

clusterStateMocks, clusterStateMocksWithNoSlop, clusterStateMocksWithSlop, conf, largeCluster, regionId

Constructor Summary

Constructors

Constructor	Description
TestCacheAwareLoadBalancer()

Method Summary

Modifier and Type	Method	Description
static void	beforeAllTests()
private static List<org.apache.hadoop.hbase.client.TableDescriptor>	constructTableDesc(boolean hasBogusTable)
private static List<org.apache.hadoop.hbase.ServerName>	generateServers(int numServers)
private org.apache.hadoop.hbase.ServerMetrics	mockServerMetricsWithRegionCacheInfo(org.apache.hadoop.hbase.ServerName server, List<org.apache.hadoop.hbase.client.RegionInfo> regionsOnServer, float currentCacheRatio, List<org.apache.hadoop.hbase.client.RegionInfo> oldRegionCacheInfo, int oldRegionCachedSize, int regionSize)
void	testRegionsFullyCachedOnOldAndCurrentServers()
void	testRegionsFullyCachedOnOldServerAndNotCachedOnCurrentServers()
void	testRegionsNotCachedOnOldServerAndCurrentServer()
void	testRegionsPartiallyCachedOnOldServerAndCurrentServer()
void	testRegionsPartiallyCachedOnOldServerAndNotCachedOnCurrentServer()

Methods inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

assertClusterAsBalanced, assertClusterOverallAsBalanced, assertRegionReplicaPlacement, convertToList, createRegions, createServerMap, mockCluster, mockClusterServers, mockClusterServers, mockClusterServers, mockClusterServersUnsorted, mockClusterServersWithTables, mockUniformClusterServers, printMock, printStats, randomRegions, randomRegions, randomServer, randomServers, reconcile, returnRegions, returnServer, returnServers, uniformRegions, updateLoad

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

loadBalancer

private static org.apache.hadoop.hbase.master.balancer.CacheAwareLoadBalancer loadBalancer

servers

static List<org.apache.hadoop.hbase.ServerName> servers

tableDescs

static List<org.apache.hadoop.hbase.client.TableDescriptor> tableDescs

tableMap

static Map<org.apache.hadoop.hbase.TableName,String> tableMap

tables

static org.apache.hadoop.hbase.TableName[] tables

Constructor Details

TestCacheAwareLoadBalancer

public TestCacheAwareLoadBalancer()

Method Details

generateServers

private static List<org.apache.hadoop.hbase.ServerName> generateServers(int numServers)

constructTableDesc

private static List<org.apache.hadoop.hbase.client.TableDescriptor> constructTableDesc(boolean hasBogusTable)

mockServerMetricsWithRegionCacheInfo

private org.apache.hadoop.hbase.ServerMetrics mockServerMetricsWithRegionCacheInfo(org.apache.hadoop.hbase.ServerName server,
 List<org.apache.hadoop.hbase.client.RegionInfo> regionsOnServer,
 float currentCacheRatio,
 List<org.apache.hadoop.hbase.client.RegionInfo> oldRegionCacheInfo,
 int oldRegionCachedSize,
 int regionSize)

beforeAllTests

public static void beforeAllTests()
                           throws Exception

Throws:

Exception

testRegionsNotCachedOnOldServerAndCurrentServer

public void testRegionsNotCachedOnOldServerAndCurrentServer()
                                                     throws Exception

Throws:

Exception

testRegionsPartiallyCachedOnOldServerAndNotCachedOnCurrentServer

public void testRegionsPartiallyCachedOnOldServerAndNotCachedOnCurrentServer()
                                                                      throws Exception

Throws:

Exception

testRegionsFullyCachedOnOldServerAndNotCachedOnCurrentServers

public void testRegionsFullyCachedOnOldServerAndNotCachedOnCurrentServers()
                                                                   throws Exception

Throws:

Exception

testRegionsFullyCachedOnOldAndCurrentServers

public void testRegionsFullyCachedOnOldAndCurrentServers()
                                                  throws Exception

Throws:

Exception

testRegionsPartiallyCachedOnOldServerAndCurrentServer

public void testRegionsPartiallyCachedOnOldServerAndCurrentServer()
                                                           throws Exception

Throws:

Exception