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

Class LoadBalancerPerformanceEvaluation.DummyClusterInfoProvider

java.lang.Object

org.apache.hadoop.hbase.master.balancer.LoadBalancerPerformanceEvaluation.DummyClusterInfoProvider

All Implemented Interfaces:

ConfigurationObserver, ClusterInfoProvider

Enclosing class:

LoadBalancerPerformanceEvaluation

private static class LoadBalancerPerformanceEvaluation.DummyClusterInfoProvider
extends Object
implements ClusterInfoProvider

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf

Constructor Summary

Constructors

Constructor	Description
DummyClusterInfoProvider(org.apache.hadoop.conf.Configuration conf)

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
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.
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

conf

private volatile org.apache.hadoop.conf.Configuration conf

Constructor Details

DummyClusterInfoProvider

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

Method Details

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

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

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

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

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

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