org.apache.hadoop.hbase.master.balancer

Class RegionReplicaCandidateGenerator

java.lang.Object

org.apache.hadoop.hbase.master.balancer.CandidateGenerator

org.apache.hadoop.hbase.master.balancer.RegionReplicaCandidateGenerator

Direct Known Subclasses:

RegionReplicaRackCandidateGenerator

@InterfaceAudience.Private
class RegionReplicaCandidateGenerator
extends CandidateGenerator

Generates candidates which moves the replicas out of the region server for co-hosted region replicas

Field Summary

Fields

Modifier and Type	Field and Description
protected RandomCandidateGenerator	randomGenerator

Constructor Summary

Constructors

Constructor and Description
RegionReplicaCandidateGenerator()

Method Summary

Modifier and Type	Method and Description
(package private) BalanceAction	generate(BalancerClusterState cluster)
(package private) int	selectCoHostedRegionPerGroup(org.agrona.collections.Int2IntCounterMap colocatedReplicaCountsPerGroup, int[] regionsPerGroup, int[] regionIndexToPrimaryIndex) Randomly select one regionIndex out of all region replicas co-hosted in the same group (a group is a server, host or rack)

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

getAction, pickOtherRandomRack, pickOtherRandomServer, pickRandomRack, pickRandomRegion, pickRandomRegions, pickRandomServer

Methods inherited from class java.lang.Object

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

Field Detail

randomGenerator

protected final RandomCandidateGenerator randomGenerator

Constructor Detail

RegionReplicaCandidateGenerator

RegionReplicaCandidateGenerator()

Method Detail

selectCoHostedRegionPerGroup

int selectCoHostedRegionPerGroup(org.agrona.collections.Int2IntCounterMap colocatedReplicaCountsPerGroup,
                                 int[] regionsPerGroup,
                                 int[] regionIndexToPrimaryIndex)

Randomly select one regionIndex out of all region replicas co-hosted in the same group (a group is a server, host or rack)

Parameters:

colocatedReplicaCountsPerGroup - either Cluster.colocatedReplicaCountsPerServer, colocatedReplicaCountsPerHost or colocatedReplicaCountsPerRack

regionsPerGroup - either Cluster.regionsPerServer, regionsPerHost or regionsPerRack

regionIndexToPrimaryIndex - Cluster.regionsIndexToPrimaryIndex

Returns:

a regionIndex for the selected primary or -1 if there is no co-locating

generate

BalanceAction generate(BalancerClusterState cluster)

Specified by:

generate in class CandidateGenerator