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

Class BalancerConditionalsTestUtil

java.lang.Object

org.apache.hadoop.hbase.master.balancer.BalancerConditionalsTestUtil

public final class BalancerConditionalsTestUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	BalancerConditionalsTestUtil.AssertionRunnable

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BalancerConditionalsTestUtil()

Method Summary

Modifier and Type	Method	Description
(package private) static byte[][]	generateSplits(int numRegions)
(package private) static Map<org.apache.hadoop.hbase.TableName,Set<org.apache.hadoop.hbase.ServerName>>	getTableToServers(org.apache.hadoop.hbase.client.Connection connection, Set<org.apache.hadoop.hbase.TableName> tableNames)
private static Map<org.apache.hadoop.hbase.TableName,List<org.apache.hadoop.hbase.client.RegionInfo>>	listRegionsByTable(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.ServerName server, Set<org.apache.hadoop.hbase.TableName> tableNames)
(package private) static void	printRegionLocations(org.apache.hadoop.hbase.client.Connection connection)
(package private) static void	validateAssertionsWithRetries(HBaseTestingUtil testUtil, boolean runBalancerOnFailure, Set<BalancerConditionalsTestUtil.AssertionRunnable> assertions)
(package private) static void	validateAssertionsWithRetries(HBaseTestingUtil testUtil, boolean runBalancerOnFailure, BalancerConditionalsTestUtil.AssertionRunnable assertion)
(package private) static void	validateRegionLocations(Map<org.apache.hadoop.hbase.TableName,Set<org.apache.hadoop.hbase.ServerName>> tableToServers, org.apache.hadoop.hbase.TableName productTableName, boolean shouldBeBalanced)
(package private) static void	validateReplicaDistribution(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName tableName, boolean shouldBeDistributed)

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

Constructor Details

BalancerConditionalsTestUtil

private BalancerConditionalsTestUtil()

Method Details

generateSplits

static byte[][] generateSplits(int numRegions)

printRegionLocations

static void printRegionLocations(org.apache.hadoop.hbase.client.Connection connection)
                          throws IOException

Throws:

IOException

listRegionsByTable

private static Map<org.apache.hadoop.hbase.TableName,List<org.apache.hadoop.hbase.client.RegionInfo>> listRegionsByTable(org.apache.hadoop.hbase.client.Connection connection,
 org.apache.hadoop.hbase.ServerName server,
 Set<org.apache.hadoop.hbase.TableName> tableNames)
                                                                                                                  throws IOException

Throws:

IOException

validateReplicaDistribution

static void validateReplicaDistribution(org.apache.hadoop.hbase.client.Connection connection,
 org.apache.hadoop.hbase.TableName tableName,
 boolean shouldBeDistributed)

validateRegionLocations

static void validateRegionLocations(Map<org.apache.hadoop.hbase.TableName,Set<org.apache.hadoop.hbase.ServerName>> tableToServers,
 org.apache.hadoop.hbase.TableName productTableName,
 boolean shouldBeBalanced)

getTableToServers

static Map<org.apache.hadoop.hbase.TableName,Set<org.apache.hadoop.hbase.ServerName>> getTableToServers(org.apache.hadoop.hbase.client.Connection connection,
 Set<org.apache.hadoop.hbase.TableName> tableNames)

validateAssertionsWithRetries

static void validateAssertionsWithRetries(HBaseTestingUtil testUtil,
 boolean runBalancerOnFailure,
 BalancerConditionalsTestUtil.AssertionRunnable assertion)

validateAssertionsWithRetries

static void validateAssertionsWithRetries(HBaseTestingUtil testUtil,
 boolean runBalancerOnFailure,
 Set<BalancerConditionalsTestUtil.AssertionRunnable> assertions)