org.apache.hadoop.hbase.master.balancer

Class TestStochasticLoadBalancer.MockCluster

java.lang.Object

org.apache.hadoop.hbase.master.balancer.TestStochasticLoadBalancer.MockCluster

Enclosing class:

TestStochasticLoadBalancer

private class TestStochasticLoadBalancer.MockCluster
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	org.apache.hadoop.hbase.master.balancer.BalancerClusterState.DefaultRackManager
(package private) static class	org.apache.hadoop.hbase.master.balancer.BalancerClusterState.LocalityType

Field Summary

Fields

Modifier and Type	Field and Description
(package private) Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>>	clusterState
(package private) org.agrona.collections.Int2IntCounterMap[]	colocatedReplicaCountsPerHost
(package private) org.agrona.collections.Int2IntCounterMap[]	colocatedReplicaCountsPerRack
(package private) org.agrona.collections.Int2IntCounterMap[]	colocatedReplicaCountsPerServer
(package private) boolean	hasRegionReplicas
(package private) String[]	hosts
(package private) Map<String,Integer>	hostsToIndex
(package private) int[]	initialRegionIndexToServerIndex
private int[][]	localities
(package private) float[]	localityPerServer
(package private) boolean	multiServersPerHost
(package private) int	numHosts
(package private) int[]	numMaxRegionsPerTable
(package private) int	numMovedRegions
(package private) int	numRacks
(package private) int	numRegions
(package private) int[][]	numRegionsPerServerPerTable
(package private) int[]	numRegionsPerTable
(package private) int	numServers
(package private) int	numTables
(package private) String[]	racks
(package private) Map<String,Integer>	racksToIndex
(package private) int[]	regionIndexToPrimaryIndex
(package private) int[]	regionIndexToServerIndex
(package private) int[]	regionIndexToTableIndex
(package private) Deque<org.apache.hadoop.hbase.master.balancer.BalancerRegionLoad>[]	regionLoads
(package private) int[][]	regionLocations
(package private) org.apache.hadoop.hbase.client.RegionInfo[]	regions
(package private) int[][]	regionsPerHost
(package private) int[][]	regionsPerRack
(package private) int[][]	regionsPerServer
(package private) Map<org.apache.hadoop.hbase.client.RegionInfo,Integer>	regionsToIndex
(package private) int[]	serverIndexToHostIndex
(package private) int[]	serverIndexToRackIndex
(package private) int[]	serverIndexToRegionsOffset
(package private) Integer[]	serverIndicesSortedByLocality
(package private) Integer[]	serverIndicesSortedByRegionCount
(package private) org.apache.hadoop.hbase.ServerName[]	servers
(package private) int[][]	serversPerHost
(package private) int[][]	serversPerRack
(package private) Map<org.apache.hadoop.hbase.net.Address,Integer>	serversToIndex
(package private) ArrayList<String>	tables
(package private) Map<String,Integer>	tablesToIndex

Constructor Summary

Constructors

Constructor and Description
MockCluster(int[][] regions)

Method Summary

Modifier and Type	Method and Description
(package private) int[]	addRegion(int[] arg0, int arg1)
(package private) int[]	addRegionSorted(int[] arg0, int arg1)
(package private) boolean	contains(int[] arg0, int arg1)
void	doAction(org.apache.hadoop.hbase.master.balancer.BalanceAction arg0)
(package private) void	doAssignRegion(org.apache.hadoop.hbase.client.RegionInfo arg0, org.apache.hadoop.hbase.ServerName arg1)
(package private) float	getLocalityOfRegion(int region, int server)
(package private) int	getLowestLocalityRegionOnServer(int arg0)
(package private) int	getNumRegions(int arg0)
Comparator<Integer>	getNumRegionsComparator()
float	getOrComputeLocality(int arg0, int arg1, org.apache.hadoop.hbase.master.balancer.BalancerClusterState.LocalityType arg2)
float[][]	getOrComputeRackLocalities()
int[]	getOrComputeRegionsToMostLocalEntities(org.apache.hadoop.hbase.master.balancer.BalancerClusterState.LocalityType arg0)
double	getOrComputeWeightedLocality(int arg0, int arg1, org.apache.hadoop.hbase.master.balancer.BalancerClusterState.LocalityType arg2)
int	getRackForRegion(int arg0)
int	getRegionSizeMB(int region)
(package private) void	regionMoved(int arg0, int arg1, int arg2)
(package private) int[]	removeRegion(int[] arg0, int arg1)
(package private) int[]	replaceRegion(int[] arg0, int arg1, int arg2)
boolean	serverHasTooFewRegions(int arg0)
(package private) void	setNumMovedRegions(int arg0)
(package private) void	setNumRegions(int arg0)
(package private) void	sortServersByRegionCount()
String	toString()
(package private) boolean	wouldLowerAvailability(org.apache.hadoop.hbase.client.RegionInfo arg0, org.apache.hadoop.hbase.ServerName arg1)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

localities

private int[][] localities

servers

org.apache.hadoop.hbase.ServerName[] servers

hosts

String[] hosts

racks

String[] racks

multiServersPerHost

boolean multiServersPerHost

tables

ArrayList<String> tables

regions

org.apache.hadoop.hbase.client.RegionInfo[] regions

regionLoads

Deque<org.apache.hadoop.hbase.master.balancer.BalancerRegionLoad>[] regionLoads

regionLocations

int[][] regionLocations

serverIndexToHostIndex

int[] serverIndexToHostIndex

serverIndexToRackIndex

int[] serverIndexToRackIndex

regionsPerServer

int[][] regionsPerServer

serverIndexToRegionsOffset

int[] serverIndexToRegionsOffset

regionsPerHost

int[][] regionsPerHost

regionsPerRack

int[][] regionsPerRack

colocatedReplicaCountsPerServer

org.agrona.collections.Int2IntCounterMap[] colocatedReplicaCountsPerServer

colocatedReplicaCountsPerHost

org.agrona.collections.Int2IntCounterMap[] colocatedReplicaCountsPerHost

colocatedReplicaCountsPerRack

org.agrona.collections.Int2IntCounterMap[] colocatedReplicaCountsPerRack

serversPerHost

int[][] serversPerHost

serversPerRack

int[][] serversPerRack

regionIndexToServerIndex

int[] regionIndexToServerIndex

initialRegionIndexToServerIndex

int[] initialRegionIndexToServerIndex

regionIndexToTableIndex

int[] regionIndexToTableIndex

numRegionsPerServerPerTable

int[][] numRegionsPerServerPerTable

numRegionsPerTable

int[] numRegionsPerTable

numMaxRegionsPerTable

int[] numMaxRegionsPerTable

regionIndexToPrimaryIndex

int[] regionIndexToPrimaryIndex

hasRegionReplicas

boolean hasRegionReplicas

serverIndicesSortedByRegionCount

Integer[] serverIndicesSortedByRegionCount

serverIndicesSortedByLocality

Integer[] serverIndicesSortedByLocality

serversToIndex

Map<org.apache.hadoop.hbase.net.Address,Integer> serversToIndex

hostsToIndex

Map<String,Integer> hostsToIndex

racksToIndex

Map<String,Integer> racksToIndex

tablesToIndex

Map<String,Integer> tablesToIndex

regionsToIndex

Map<org.apache.hadoop.hbase.client.RegionInfo,Integer> regionsToIndex

localityPerServer

float[] localityPerServer

numServers

int numServers

numHosts

int numHosts

numRacks

int numRacks

numTables

int numTables

numRegions

int numRegions

numMovedRegions

int numMovedRegions

clusterState

Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> clusterState

Constructor Detail

MockCluster

public MockCluster(int[][] regions)

Method Detail

getLocalityOfRegion

float getLocalityOfRegion(int region,
                          int server)

getRegionSizeMB

public int getRegionSizeMB(int region)

serverHasTooFewRegions

public boolean serverHasTooFewRegions(int arg0)

getOrComputeRackLocalities

public float[][] getOrComputeRackLocalities()

getOrComputeRegionsToMostLocalEntities

public int[] getOrComputeRegionsToMostLocalEntities(org.apache.hadoop.hbase.master.balancer.BalancerClusterState.LocalityType arg0)

getOrComputeLocality

public float getOrComputeLocality(int arg0,
                                  int arg1,
                                  org.apache.hadoop.hbase.master.balancer.BalancerClusterState.LocalityType arg2)

getOrComputeWeightedLocality

public double getOrComputeWeightedLocality(int arg0,
                                           int arg1,
                                           org.apache.hadoop.hbase.master.balancer.BalancerClusterState.LocalityType arg2)

getRackForRegion

public int getRackForRegion(int arg0)

doAction

public void doAction(org.apache.hadoop.hbase.master.balancer.BalanceAction arg0)

wouldLowerAvailability

boolean wouldLowerAvailability(org.apache.hadoop.hbase.client.RegionInfo arg0,
                               org.apache.hadoop.hbase.ServerName arg1)

doAssignRegion

void doAssignRegion(org.apache.hadoop.hbase.client.RegionInfo arg0,
                    org.apache.hadoop.hbase.ServerName arg1)

regionMoved

void regionMoved(int arg0,
                 int arg1,
                 int arg2)

removeRegion

int[] removeRegion(int[] arg0,
                   int arg1)

addRegion

int[] addRegion(int[] arg0,
                int arg1)

addRegionSorted

int[] addRegionSorted(int[] arg0,
                      int arg1)

replaceRegion

int[] replaceRegion(int[] arg0,
                    int arg1,
                    int arg2)

sortServersByRegionCount

void sortServersByRegionCount()

getNumRegions

int getNumRegions(int arg0)

getNumRegionsComparator

public Comparator<Integer> getNumRegionsComparator()

contains

boolean contains(int[] arg0,
                 int arg1)

getLowestLocalityRegionOnServer

int getLowestLocalityRegionOnServer(int arg0)

setNumRegions

void setNumRegions(int arg0)

setNumMovedRegions

void setNumMovedRegions(int arg0)

toString

public String toString()

Overrides:

toString in class Object