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

Class RegionPlanConditionalCandidateGenerator

java.lang.Object

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

org.apache.hadoop.hbase.master.balancer.RegionPlanConditionalCandidateGenerator

Direct Known Subclasses:

DistributeReplicasCandidateGenerator, SlopFixingCandidateGenerator, TableIsolationCandidateGenerator

@Private
@Evolving
public abstract class RegionPlanConditionalCandidateGenerator
extends CandidateGenerator

Field Summary

Fields

Modifier and Type	Field	Description
private final BalancerConditionals	balancerConditionals
private long	lastWeighedAt
private double	lastWeight
private static final org.slf4j.Logger	LOG
private static final Duration	WEIGHT_CACHE_TTL

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

MAX_WEIGHT

Constructor Summary

Constructors

Constructor	Description
RegionPlanConditionalCandidateGenerator(BalancerConditionals balancerConditionals)

Method Summary

Modifier and Type	Method	Description
(package private) BalanceAction	batchMovesAndResetClusterState(BalancerClusterState cluster, List<MoveRegionAction> moves)
(package private) void	clearWeightCache()
(package private) BalanceAction	generate(BalancerClusterState cluster)
(package private) abstract BalanceAction	generateCandidate(BalancerClusterState cluster, boolean isWeighing)	Generates a balancing action to appease the conditional.
(package private) BalancerConditionals	getBalancerConditionals()
(package private) double	getWeight(BalancerClusterState cluster)
(package private) void	undoBatchAction(BalancerClusterState cluster, MoveBatchAction batchAction)
(package private) boolean	willBeAccepted(BalancerClusterState cluster, BalanceAction action)

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 Details

LOG

private static final org.slf4j.Logger LOG

WEIGHT_CACHE_TTL

private static final Duration WEIGHT_CACHE_TTL

lastWeighedAt

private long lastWeighedAt

lastWeight

private double lastWeight

balancerConditionals

private final BalancerConditionals balancerConditionals

Constructor Details

RegionPlanConditionalCandidateGenerator

RegionPlanConditionalCandidateGenerator(BalancerConditionals balancerConditionals)

Method Details

getBalancerConditionals

BalancerConditionals getBalancerConditionals()

generateCandidate

abstract BalanceAction generateCandidate(BalancerClusterState cluster,
 boolean isWeighing)

Generates a balancing action to appease the conditional.

Parameters:

cluster - Current state of the cluster.

isWeighing - Flag indicating if the generator is being used for weighing.

Returns:

A BalanceAction, or NULL_ACTION if no action is needed.

generate

BalanceAction generate(BalancerClusterState cluster)

Specified by:

generate in class CandidateGenerator

batchMovesAndResetClusterState

BalanceAction batchMovesAndResetClusterState(BalancerClusterState cluster,
 List<MoveRegionAction> moves)

willBeAccepted

boolean willBeAccepted(BalancerClusterState cluster,
 BalanceAction action)

undoBatchAction

void undoBatchAction(BalancerClusterState cluster,
 MoveBatchAction batchAction)

clearWeightCache

void clearWeightCache()

getWeight

double getWeight(BalancerClusterState cluster)