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,
BalanceRequest request,
List<RegionPlan> plans)
Called after the balancing plan has been submitted.
|
Modifier and Type | Method and Description |
---|---|
protected 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.
|
List<RegionPlan> |
MasterServices.executeRegionPlansWithThrottling(List<RegionPlan> plans)
Execute region plans with throttling
|
List<RegionPlan> |
HMaster.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> |
MasterServices.executeRegionPlansWithThrottling(List<RegionPlan> plans)
Execute region plans with throttling
|
List<RegionPlan> |
HMaster.executeRegionPlansWithThrottling(List<RegionPlan> plans)
Execute region plans with throttling
|
void |
MasterCoprocessorHost.postBalance(BalanceRequest request,
List<RegionPlan> plans) |
Modifier and Type | Field and Description |
---|---|
private RegionPlan |
MoveRegionProcedure.plan
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Future<byte[]> |
AssignmentManager.balance(RegionPlan regionPlan) |
Future<byte[]> |
AssignmentManager.moveAsync(RegionPlan regionPlan) |
Modifier and Type | Method and Description |
---|---|
List<RegionPlan> |
BaseLoadBalancer.balanceCluster(Map<TableName,Map<ServerName,List<RegionInfo>>> loadOfAllTable)
Perform the major balance operation for cluster, will invoke
BaseLoadBalancer.balanceTable(TableName, Map) to do actual balance. |
List<RegionPlan> |
MaintenanceLoadBalancer.balanceCluster(Map<TableName,Map<ServerName,List<RegionInfo>>> loadOfAllTable) |
protected List<RegionPlan> |
BaseLoadBalancer.balanceMasterRegions(Map<ServerName,List<RegionInfo>> clusterMap)
Deprecated.
since 2.4.0, will be removed in 3.0.0.
|
protected List<RegionPlan> |
StochasticLoadBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable)
Given the cluster state this will try and approach an optimal balance.
|
protected abstract List<RegionPlan> |
BaseLoadBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable)
Perform the major balance operation for table, all sub classes should override this method.
|
protected 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.
|
protected List<RegionPlan> |
FavoredStochasticBalancer.balanceTable(TableName tableName,
Map<ServerName,List<RegionInfo>> loadOfOneTable) |
private List<RegionPlan> |
StochasticLoadBalancer.createRegionPlans(BalancerClusterState 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.
|
private 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.
|
private 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.
|
private void |
StochasticLoadBalancer.sendRegionPlansToRingBuffer(List<RegionPlan> plans,
double currentCost,
double initCost,
String initFunctionTotalCosts,
long step) |
Modifier and Type | Method and Description |
---|---|
List<RegionPlan> |
RSGroupBasedLoadBalancer.balanceCluster(Map<TableName,Map<ServerName,List<RegionInfo>>> loadOfAllTable)
Balance by RSGroup.
|
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.