public class DummyClusterInfoProvider extends Object implements org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf |
Constructor and Description |
---|
DummyClusterInfoProvider(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.HDFSBlocksDistribution |
computeHDFSBlocksDistribution(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor,
org.apache.hadoop.hbase.client.RegionInfo regionInfo) |
List<org.apache.hadoop.hbase.client.RegionInfo> |
getAssignedRegions() |
org.apache.hadoop.conf.Configuration |
getConfiguration() |
org.apache.hadoop.hbase.client.Connection |
getConnection() |
org.apache.hadoop.hbase.ServerMetrics |
getLoad(org.apache.hadoop.hbase.ServerName serverName) |
int |
getNumberOfTables() |
List<org.apache.hadoop.hbase.ServerName> |
getOnlineServersList() |
List<org.apache.hadoop.hbase.ServerName> |
getOnlineServersListWithPredicator(List<org.apache.hadoop.hbase.ServerName> servers,
Predicate<org.apache.hadoop.hbase.ServerMetrics> filter) |
Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> |
getSnapShotOfAssignment(Collection<org.apache.hadoop.hbase.client.RegionInfo> regions) |
org.apache.hadoop.hbase.client.TableDescriptor |
getTableDescriptor(org.apache.hadoop.hbase.TableName tableName) |
boolean |
hasRegionReplica(Collection<org.apache.hadoop.hbase.client.RegionInfo> regions) |
boolean |
isOffPeakHour() |
void |
onConfigurationChange(org.apache.hadoop.conf.Configuration conf) |
void |
recordBalancerDecision(Supplier<org.apache.hadoop.hbase.client.BalancerDecision> decision) |
void |
recordBalancerRejection(Supplier<org.apache.hadoop.hbase.client.BalancerRejection> rejection) |
void |
unassign(org.apache.hadoop.hbase.client.RegionInfo regionInfo) |
private volatile org.apache.hadoop.conf.Configuration conf
public DummyClusterInfoProvider(org.apache.hadoop.conf.Configuration conf)
public org.apache.hadoop.conf.Configuration getConfiguration()
getConfiguration
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public org.apache.hadoop.hbase.client.Connection getConnection()
getConnection
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public List<org.apache.hadoop.hbase.client.RegionInfo> getAssignedRegions()
getAssignedRegions
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public void unassign(org.apache.hadoop.hbase.client.RegionInfo regionInfo) throws IOException
unassign
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
IOException
public org.apache.hadoop.hbase.client.TableDescriptor getTableDescriptor(org.apache.hadoop.hbase.TableName tableName) throws IOException
getTableDescriptor
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
IOException
public int getNumberOfTables() throws IOException
getNumberOfTables
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
IOException
public org.apache.hadoop.hbase.HDFSBlocksDistribution computeHDFSBlocksDistribution(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor, org.apache.hadoop.hbase.client.RegionInfo regionInfo) throws IOException
computeHDFSBlocksDistribution
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
IOException
public boolean hasRegionReplica(Collection<org.apache.hadoop.hbase.client.RegionInfo> regions) throws IOException
hasRegionReplica
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
IOException
public List<org.apache.hadoop.hbase.ServerName> getOnlineServersList()
getOnlineServersList
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public List<org.apache.hadoop.hbase.ServerName> getOnlineServersListWithPredicator(List<org.apache.hadoop.hbase.ServerName> servers, Predicate<org.apache.hadoop.hbase.ServerMetrics> filter)
getOnlineServersListWithPredicator
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> getSnapShotOfAssignment(Collection<org.apache.hadoop.hbase.client.RegionInfo> regions)
getSnapShotOfAssignment
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public boolean isOffPeakHour()
isOffPeakHour
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public void recordBalancerDecision(Supplier<org.apache.hadoop.hbase.client.BalancerDecision> decision)
recordBalancerDecision
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public void recordBalancerRejection(Supplier<org.apache.hadoop.hbase.client.BalancerRejection> rejection)
recordBalancerRejection
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)
onConfigurationChange
in interface org.apache.hadoop.hbase.conf.ConfigurationObserver
public org.apache.hadoop.hbase.ServerMetrics getLoad(org.apache.hadoop.hbase.ServerName serverName)
getLoad
in interface org.apache.hadoop.hbase.master.balancer.ClusterInfoProvider
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.