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

Class MasterClusterInfoProvider

java.lang.Object

org.apache.hadoop.hbase.master.balancer.MasterClusterInfoProvider

All Implemented Interfaces:

ConfigurationObserver, ClusterInfoProvider

@Private
public class MasterClusterInfoProvider
extends Object
implements ClusterInfoProvider

Master based cluster info provider.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	isBalancerDecisionRecording
private boolean	isBalancerRejectionRecording
private NamedQueueRecorder	namedQueueRecorder	Use to add balancer decision history to ring-buffer
private OffPeakHours	offPeakHours
private final MasterServices	services

Constructor Summary

Constructors

Constructor	Description
MasterClusterInfoProvider(MasterServices services)

Method Summary

Modifier and Type	Method	Description
HDFSBlocksDistribution	computeHDFSBlocksDistribution(org.apache.hadoop.conf.Configuration conf, TableDescriptor tableDescriptor, RegionInfo regionInfo)	Compute the block distribution for the given region.
List<RegionInfo>	getAssignedRegions()	Get all the regions of this cluster.
org.apache.hadoop.conf.Configuration	getConfiguration()	Get the configuration.
Connection	getConnection()	Returns a reference to the cluster's connection.
ServerMetrics	getLoad(ServerName serverName)	Returns server metrics of the given server if serverName is known else null
(package private) NamedQueueRecorder	getNamedQueueRecorder()
int	getNumberOfTables()	Returns the number of tables on this cluster.
List<ServerName>	getOnlineServersList()	Returns a copy of the internal list of online servers.
List<ServerName>	getOnlineServersListWithPredicator(List<ServerName> servers, Predicate<ServerMetrics> filter)	Returns a copy of the internal list of online servers matched by the given filter.
Map<ServerName,List<RegionInfo>>	getSnapShotOfAssignment(Collection<RegionInfo> regions)	Get a snapshot of the current assignment status.
TableDescriptor	getTableDescriptor(TableName tableName)	Get the table descriptor for the given table.
boolean	hasRegionReplica(Collection<RegionInfo> regions)	Check whether we have region replicas enabled for the tables of the given regions.
boolean	isOffPeakHour()	Test whether we are in off peak hour.
private void	loadConf(org.apache.hadoop.conf.Configuration conf)
void	onConfigurationChange(org.apache.hadoop.conf.Configuration conf)	This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.
void	recordBalancerDecision(Supplier<BalancerDecision> decision)	Record the given balancer decision.
void	recordBalancerRejection(Supplier<BalancerRejection> rejection)	Record the given balancer rejection.
void	unassign(RegionInfo regionInfo)	Unassign the given region.

Methods inherited from class java.lang.Object

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

Field Details

services

private final MasterServices services

isBalancerDecisionRecording

private boolean isBalancerDecisionRecording

isBalancerRejectionRecording

private boolean isBalancerRejectionRecording

namedQueueRecorder

private NamedQueueRecorder namedQueueRecorder

Use to add balancer decision history to ring-buffer

offPeakHours

private OffPeakHours offPeakHours

Constructor Details

MasterClusterInfoProvider

public MasterClusterInfoProvider(MasterServices services)

Method Details

loadConf

private void loadConf(org.apache.hadoop.conf.Configuration conf)

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Description copied from interface: ClusterInfoProvider

Get the configuration.

Specified by:

getConfiguration in interface ClusterInfoProvider

getConnection

public Connection getConnection()

Description copied from interface: ClusterInfoProvider

Returns a reference to the cluster's connection.

Specified by:

getConnection in interface ClusterInfoProvider

getAssignedRegions

public List<RegionInfo> getAssignedRegions()

Description copied from interface: ClusterInfoProvider

Get all the regions of this cluster.

Used to refresh region block locations on HDFS.

Specified by:

getAssignedRegions in interface ClusterInfoProvider

unassign

public void unassign(RegionInfo regionInfo)
              throws IOException

Description copied from interface: ClusterInfoProvider

Unassign the given region.

Specified by:

unassign in interface ClusterInfoProvider

Throws:

IOException

getTableDescriptor

public TableDescriptor getTableDescriptor(TableName tableName)
                                   throws IOException

Description copied from interface: ClusterInfoProvider

Get the table descriptor for the given table.

Specified by:

getTableDescriptor in interface ClusterInfoProvider

Throws:

IOException

computeHDFSBlocksDistribution

public HDFSBlocksDistribution computeHDFSBlocksDistribution(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor tableDescriptor,
 RegionInfo regionInfo)
                                                     throws IOException

Description copied from interface: ClusterInfoProvider

Compute the block distribution for the given region.

Used to refresh region block locations on HDFS.

Specified by:

computeHDFSBlocksDistribution in interface ClusterInfoProvider

Throws:

IOException

hasRegionReplica

public boolean hasRegionReplica(Collection<RegionInfo> regions)
                         throws IOException

Description copied from interface: ClusterInfoProvider

Check whether we have region replicas enabled for the tables of the given regions.

Specified by:

hasRegionReplica in interface ClusterInfoProvider

Throws:

IOException

getOnlineServersList

public List<ServerName> getOnlineServersList()

Description copied from interface: ClusterInfoProvider

Returns a copy of the internal list of online servers.

Specified by:

getOnlineServersList in interface ClusterInfoProvider

getOnlineServersListWithPredicator

public List<ServerName> getOnlineServersListWithPredicator(List<ServerName> servers,
 Predicate<ServerMetrics> filter)

Description copied from interface: ClusterInfoProvider

Returns a copy of the internal list of online servers matched by the given filter.

Specified by:

getOnlineServersListWithPredicator in interface ClusterInfoProvider

getSnapShotOfAssignment

public Map<ServerName,List<RegionInfo>> getSnapShotOfAssignment(Collection<RegionInfo> regions)

Description copied from interface: ClusterInfoProvider

Get a snapshot of the current assignment status.

Specified by:

getSnapShotOfAssignment in interface ClusterInfoProvider

getNumberOfTables

public int getNumberOfTables()
                      throws IOException

Description copied from interface: ClusterInfoProvider

Returns the number of tables on this cluster.

Specified by:

getNumberOfTables in interface ClusterInfoProvider

Throws:

IOException

isOffPeakHour

public boolean isOffPeakHour()

Description copied from interface: ClusterInfoProvider

Test whether we are in off peak hour.

For peak and off peak hours we may have different cost for the same balancing operation.

Specified by:

isOffPeakHour in interface ClusterInfoProvider

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: ConfigurationObserver

This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.

Specified by:

onConfigurationChange in interface ConfigurationObserver

recordBalancerDecision

public void recordBalancerDecision(Supplier<BalancerDecision> decision)

Description copied from interface: ClusterInfoProvider

Record the given balancer decision.

Specified by:

recordBalancerDecision in interface ClusterInfoProvider

recordBalancerRejection

public void recordBalancerRejection(Supplier<BalancerRejection> rejection)

Description copied from interface: ClusterInfoProvider

Record the given balancer rejection.

Specified by:

recordBalancerRejection in interface ClusterInfoProvider

getLoad

public ServerMetrics getLoad(ServerName serverName)

Description copied from interface: ClusterInfoProvider

Returns server metrics of the given server if serverName is known else null

Specified by:

getLoad in interface ClusterInfoProvider

getNamedQueueRecorder

NamedQueueRecorder getNamedQueueRecorder()