Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.favored | |
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.master.assignment | |
org.apache.hadoop.hbase.master.balancer | |
org.apache.hadoop.hbase.rsgroup |
Modifier and Type | Method and Description |
---|---|
default void |
MasterObserver.postBalance(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<RegionPlan> plans)
Called after the balancing plan has been submitted.
|
Modifier and Type | Method and Description |
---|---|
List<RegionPlan> |
FavoredNodeLoadBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable) |
Modifier and Type | Method and Description |
---|---|
List<RegionPlan> |
LoadBalancer.balanceCluster(Map<TableName,Map<ServerName,List<RegionInfo>>> loadOfAllTable)
Perform the major balance operation for cluster, will invoke
LoadBalancer.balanceTable(org.apache.hadoop.hbase.TableName, java.util.Map<org.apache.hadoop.hbase.ServerName, java.util.List<org.apache.hadoop.hbase.client.RegionInfo>>) to do
actual balance. |
List<RegionPlan> |
LoadBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable)
Perform the major balance operation for table, all class implement of
LoadBalancer
should override this method |
List<RegionPlan> |
HMaster.executeRegionPlansWithThrottling(List<RegionPlan> plans)
Execute region plans with throttling
|
List<RegionPlan> |
MasterServices.executeRegionPlansWithThrottling(List<RegionPlan> plans)
Execute region plans with throttling
|
Modifier and Type | Method and Description |
---|---|
int |
RegionPlan.RegionPlanComparator.compare(RegionPlan l,
RegionPlan r) |
int |
RegionPlan.compareTo(RegionPlan other)
Compare the region info.
|
private static int |
RegionPlan.compareTo(RegionPlan left,
RegionPlan right) |
Modifier and Type | Method and Description |
---|---|
List<RegionPlan> |
HMaster.executeRegionPlansWithThrottling(List<RegionPlan> plans)
Execute region plans with throttling
|
List<RegionPlan> |
MasterServices.executeRegionPlansWithThrottling(List<RegionPlan> plans)
Execute region plans with throttling
|
void |
MasterCoprocessorHost.postBalance(List<RegionPlan> plans) |
Modifier and Type | Field and Description |
---|---|
private RegionPlan |
MoveRegionProcedure.plan
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Future<byte[]> |
AssignmentManager.moveAsync(RegionPlan regionPlan) |
Modifier and Type | Method and Description |
---|---|
List<RegionPlan> |
SimpleLoadBalancer.balanceCluster(Map<TableName,Map<ServerName,List<RegionInfo>>> loadOfAllTable)
Override to invoke
SimpleLoadBalancer.setClusterLoad(java.util.Map<org.apache.hadoop.hbase.TableName, java.util.Map<org.apache.hadoop.hbase.ServerName, java.util.List<org.apache.hadoop.hbase.client.RegionInfo>>>) before balance, We need clusterLoad of all regions
on every server to achieve overall balanced |
List<RegionPlan> |
BaseLoadBalancer.balanceCluster(Map<TableName,Map<ServerName,List<RegionInfo>>> loadOfAllTable) |
protected List<RegionPlan> |
BaseLoadBalancer.balanceMasterRegions(Map<ServerName,List<RegionInfo>> clusterMap)
Balance the regions that should be on master regionserver.
|
List<RegionPlan> |
StochasticLoadBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable)
Given the cluster state this will try and approach an optimal balance.
|
List<RegionPlan> |
SimpleLoadBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable)
Generate a global load balancing plan according to the specified map of
server information to the most loaded regions of each server.
|
List<RegionPlan> |
FavoredStochasticBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable) |
abstract List<RegionPlan> |
BaseLoadBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable) |
private List<RegionPlan> |
StochasticLoadBalancer.createRegionPlans(BaseLoadBalancer.Cluster cluster)
Create all of the RegionPlan's needed to move from the initial cluster state to the desired
state.
|
Modifier and Type | Method and Description |
---|---|
private void |
SimpleLoadBalancer.addRegionPlan(org.apache.hbase.thirdparty.com.google.common.collect.MinMaxPriorityQueue<RegionPlan> regionsToMove,
boolean fetchFromTail,
ServerName sn,
List<RegionPlan> regionsToReturn)
Add a region from the head or tail to the List of regions to return.
|
private void |
SimpleLoadBalancer.addRegionPlan(org.apache.hbase.thirdparty.com.google.common.collect.MinMaxPriorityQueue<RegionPlan> regionsToMove,
boolean fetchFromTail,
ServerName sn,
List<RegionPlan> regionsToReturn)
Add a region from the head or tail to the List of regions to return.
|
void |
SimpleLoadBalancer.balanceOverall(List<RegionPlan> regionsToReturn,
Map<ServerName,SimpleLoadBalancer.BalanceInfo> serverBalanceInfo,
boolean fetchFromTail,
org.apache.hbase.thirdparty.com.google.common.collect.MinMaxPriorityQueue<RegionPlan> regionsToMove,
int max,
int min)
If we need to balanceoverall, we need to add one more round to peel off one region from each max.
|
void |
SimpleLoadBalancer.balanceOverall(List<RegionPlan> regionsToReturn,
Map<ServerName,SimpleLoadBalancer.BalanceInfo> serverBalanceInfo,
boolean fetchFromTail,
org.apache.hbase.thirdparty.com.google.common.collect.MinMaxPriorityQueue<RegionPlan> regionsToMove,
int max,
int min)
If we need to balanceoverall, we need to add one more round to peel off one region from each max.
|
Modifier and Type | Method and Description |
---|---|
List<RegionPlan> |
RSGroupBasedLoadBalancer.balanceCluster(Map<TableName,Map<ServerName,List<RegionInfo>>> loadOfAllTable)
Override to balance by RSGroup
not invoke
RSGroupBasedLoadBalancer.balanceTable(TableName, Map) |
List<RegionPlan> |
RSGroupBasedLoadBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable)
can achieve table balanced rather than overall balanced
|
private Pair<Map<TableName,Map<ServerName,List<RegionInfo>>>,List<RegionPlan>> |
RSGroupBasedLoadBalancer.correctAssignments(Map<TableName,Map<ServerName,List<RegionInfo>>> existingAssignments) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.