public class MockNoopMasterServices extends Object implements org.apache.hadoop.hbase.master.MasterServices
| Modifier and Type | Field and Description |
|---|---|
private org.apache.hadoop.conf.Configuration |
conf |
private org.apache.hadoop.hbase.master.MetricsMaster |
metricsMaster |
private boolean |
stopped |
| Constructor and Description |
|---|
MockNoopMasterServices() |
MockNoopMasterServices(org.apache.hadoop.conf.Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
void |
abort(String why,
Throwable e) |
boolean |
abortProcedure(long procId,
boolean mayInterruptIfRunning) |
long |
addColumn(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.client.ColumnFamilyDescriptor columnDescriptor,
long nonceGroup,
long nonce) |
long |
addReplicationPeer(String peerId,
org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig,
boolean enabled) |
void |
checkIfShouldMoveSystemRegionAsync() |
void |
checkTableModifiable(org.apache.hadoop.hbase.TableName tableName) |
org.apache.hadoop.hbase.client.Connection |
createConnection(org.apache.hadoop.conf.Configuration conf) |
long |
createSystemTable(org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor) |
long |
createTable(org.apache.hadoop.hbase.client.TableDescriptor desc,
byte[][] splitKeys,
long nonceGroup,
long nonce) |
long |
deleteColumn(org.apache.hadoop.hbase.TableName tableName,
byte[] columnName,
long nonceGroup,
long nonce) |
long |
deleteTable(org.apache.hadoop.hbase.TableName tableName,
long nonceGroup,
long nonce) |
long |
disableReplicationPeer(String peerId) |
long |
disableTable(org.apache.hadoop.hbase.TableName tableName,
long nonceGroup,
long nonce) |
long |
enableReplicationPeer(String peerId) |
long |
enableTable(org.apache.hadoop.hbase.TableName tableName,
long nonceGroup,
long nonce) |
List<org.apache.hadoop.hbase.master.RegionPlan> |
executeRegionPlansWithThrottling(List<org.apache.hadoop.hbase.master.RegionPlan> plans) |
org.apache.hadoop.hbase.security.access.AccessChecker |
getAccessChecker() |
org.apache.hadoop.hbase.master.assignment.AssignmentManager |
getAssignmentManager() |
org.apache.hadoop.hbase.master.CatalogJanitor |
getCatalogJanitor() |
org.apache.hadoop.hbase.ChoreService |
getChoreService() |
String |
getClientIdAuditPrefix() |
org.apache.hadoop.hbase.client.ClusterConnection |
getClusterConnection() |
org.apache.hadoop.hbase.master.ClusterSchema |
getClusterSchema() |
org.apache.hadoop.conf.Configuration |
getConfiguration() |
org.apache.hadoop.hbase.client.ClusterConnection |
getConnection() |
org.apache.hadoop.hbase.CoordinatedStateManager |
getCoordinatedStateManager() |
org.apache.hadoop.hbase.executor.ExecutorService |
getExecutorService() |
org.apache.hadoop.hbase.favored.FavoredNodesManager |
getFavoredNodesManager() |
org.apache.hadoop.fs.FileSystem |
getFileSystem() |
org.apache.hadoop.hbase.procedure2.ProcedureEvent<?> |
getInitializedEvent() |
long |
getLastMajorCompactionTimestamp(org.apache.hadoop.hbase.TableName table) |
long |
getLastMajorCompactionTimestampForRegion(byte[] regionName) |
org.apache.hadoop.hbase.master.LoadBalancer |
getLoadBalancer() |
org.apache.hadoop.hbase.master.locking.LockManager |
getLockManager() |
List<org.apache.hadoop.hbase.procedure2.LockedResource> |
getLocks() |
org.apache.hadoop.hbase.master.MasterCoprocessorHost |
getMasterCoprocessorHost() |
org.apache.hadoop.hbase.master.MasterFileSystem |
getMasterFileSystem() |
org.apache.hadoop.hbase.master.MetricsMaster |
getMasterMetrics() |
org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> |
getMasterProcedureExecutor() |
org.apache.hadoop.hbase.procedure.MasterProcedureManagerHost |
getMasterProcedureManagerHost() |
org.apache.hadoop.hbase.quotas.MasterQuotaManager |
getMasterQuotaManager() |
org.apache.hadoop.hbase.master.MasterWalManager |
getMasterWalManager() |
List<org.apache.hadoop.hbase.procedure2.Procedure<?>> |
getProcedures() |
org.apache.hadoop.hbase.master.normalizer.RegionNormalizer |
getRegionNormalizer() |
String |
getRegionServerVersion(org.apache.hadoop.hbase.ServerName sn) |
org.apache.hadoop.hbase.replication.ReplicationPeerConfig |
getReplicationPeerConfig(String peerId) |
org.apache.hadoop.hbase.master.replication.ReplicationPeerManager |
getReplicationPeerManager() |
org.apache.hadoop.hbase.master.ServerManager |
getServerManager() |
org.apache.hadoop.hbase.ServerName |
getServerName() |
org.apache.hadoop.hbase.master.snapshot.SnapshotManager |
getSnapshotManager() |
org.apache.hadoop.hbase.TableDescriptors |
getTableDescriptors() |
org.apache.hadoop.hbase.master.TableStateManager |
getTableStateManager() |
org.apache.hadoop.hbase.security.access.ZKPermissionWatcher |
getZKPermissionWatcher() |
org.apache.hadoop.hbase.zookeeper.ZKWatcher |
getZooKeeper() |
boolean |
isAborted() |
boolean |
isActiveMaster() |
boolean |
isClusterUp() |
boolean |
isInitialized() |
boolean |
isInMaintenanceMode() |
boolean |
isSplitOrMergeEnabled(org.apache.hadoop.hbase.client.MasterSwitchType switchType) |
boolean |
isStopped() |
boolean |
isStopping() |
List<org.apache.hadoop.hbase.replication.ReplicationPeerDescription> |
listReplicationPeers(String regex) |
List<org.apache.hadoop.hbase.client.TableDescriptor> |
listTableDescriptorsByNamespace(String name) |
List<org.apache.hadoop.hbase.TableName> |
listTableNamesByNamespace(String name) |
long |
mergeRegions(org.apache.hadoop.hbase.client.RegionInfo[] regionsToMerge,
boolean forcible,
long nonceGroup,
long nonce) |
long |
modifyColumn(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.client.ColumnFamilyDescriptor descriptor,
long nonceGroup,
long nonce) |
long |
modifyTable(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.client.TableDescriptor descriptor,
long nonceGroup,
long nonce) |
boolean |
registerService(com.google.protobuf.Service instance) |
long |
removeReplicationPeer(String peerId) |
void |
runReplicationBarrierCleaner() |
long |
splitRegion(org.apache.hadoop.hbase.client.RegionInfo regionInfo,
byte[] splitRow,
long nonceGroup,
long nonce) |
void |
stop(String why) |
long |
truncateTable(org.apache.hadoop.hbase.TableName tableName,
boolean preserveSplits,
long nonceGroup,
long nonce) |
long |
updateReplicationPeerConfig(String peerId,
org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig) |
private final org.apache.hadoop.conf.Configuration conf
private final org.apache.hadoop.hbase.master.MetricsMaster metricsMaster
private boolean stopped
public MockNoopMasterServices()
public MockNoopMasterServices(org.apache.hadoop.conf.Configuration conf)
public void checkTableModifiable(org.apache.hadoop.hbase.TableName tableName) throws IOException
checkTableModifiable in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long createTable(org.apache.hadoop.hbase.client.TableDescriptor desc, byte[][] splitKeys, long nonceGroup, long nonce) throws IOException
createTable in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long createSystemTable(org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor) throws IOException
createSystemTable in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic org.apache.hadoop.hbase.master.assignment.AssignmentManager getAssignmentManager()
getAssignmentManager in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.executor.ExecutorService getExecutorService()
getExecutorService in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.ChoreService getChoreService()
getChoreService in interface org.apache.hadoop.hbase.Serverpublic org.apache.hadoop.hbase.master.normalizer.RegionNormalizer getRegionNormalizer()
getRegionNormalizer in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.master.CatalogJanitor getCatalogJanitor()
getCatalogJanitor in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.master.MasterFileSystem getMasterFileSystem()
getMasterFileSystem in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.master.MasterWalManager getMasterWalManager()
getMasterWalManager in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.master.MasterCoprocessorHost getMasterCoprocessorHost()
getMasterCoprocessorHost in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.quotas.MasterQuotaManager getMasterQuotaManager()
getMasterQuotaManager in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> getMasterProcedureExecutor()
getMasterProcedureExecutor in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.master.MetricsMaster getMasterMetrics()
getMasterMetrics in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.master.ServerManager getServerManager()
getServerManager in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.zookeeper.ZKWatcher getZooKeeper()
getZooKeeper in interface org.apache.hadoop.hbase.Serverpublic org.apache.hadoop.hbase.CoordinatedStateManager getCoordinatedStateManager()
getCoordinatedStateManager in interface org.apache.hadoop.hbase.Serverpublic org.apache.hadoop.hbase.client.ClusterConnection getConnection()
getConnection in interface org.apache.hadoop.hbase.Serverpublic org.apache.hadoop.conf.Configuration getConfiguration()
getConfiguration in interface org.apache.hadoop.hbase.Serverpublic org.apache.hadoop.hbase.ServerName getServerName()
getServerName in interface org.apache.hadoop.hbase.Serverpublic void abort(String why, Throwable e)
abort in interface org.apache.hadoop.hbase.Abortablepublic boolean isAborted()
isAborted in interface org.apache.hadoop.hbase.Abortablepublic boolean isStopping()
isStopping in interface org.apache.hadoop.hbase.Serverpublic boolean isStopped()
isStopped in interface org.apache.hadoop.hbase.Stoppablepublic org.apache.hadoop.hbase.TableDescriptors getTableDescriptors()
getTableDescriptors in interface org.apache.hadoop.hbase.master.MasterServicespublic boolean registerService(com.google.protobuf.Service instance)
registerService in interface org.apache.hadoop.hbase.master.MasterServicespublic boolean abortProcedure(long procId, boolean mayInterruptIfRunning) throws IOException
abortProcedure in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic List<org.apache.hadoop.hbase.procedure2.Procedure<?>> getProcedures() throws IOException
getProcedures in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic List<org.apache.hadoop.hbase.procedure2.LockedResource> getLocks() throws IOException
getLocks in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic List<org.apache.hadoop.hbase.client.TableDescriptor> listTableDescriptorsByNamespace(String name) throws IOException
listTableDescriptorsByNamespace in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic List<org.apache.hadoop.hbase.TableName> listTableNamesByNamespace(String name) throws IOException
listTableNamesByNamespace in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long deleteTable(org.apache.hadoop.hbase.TableName tableName, long nonceGroup, long nonce) throws IOException
deleteTable in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long truncateTable(org.apache.hadoop.hbase.TableName tableName, boolean preserveSplits, long nonceGroup, long nonce) throws IOException
truncateTable in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long modifyTable(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.TableDescriptor descriptor, long nonceGroup, long nonce) throws IOException
modifyTable in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long enableTable(org.apache.hadoop.hbase.TableName tableName, long nonceGroup, long nonce) throws IOException
enableTable in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long disableTable(org.apache.hadoop.hbase.TableName tableName, long nonceGroup, long nonce) throws IOException
disableTable in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long addColumn(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor columnDescriptor, long nonceGroup, long nonce) throws IOException
addColumn in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long modifyColumn(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor descriptor, long nonceGroup, long nonce) throws IOException
modifyColumn in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long deleteColumn(org.apache.hadoop.hbase.TableName tableName, byte[] columnName, long nonceGroup, long nonce) throws IOException
deleteColumn in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long mergeRegions(org.apache.hadoop.hbase.client.RegionInfo[] regionsToMerge, boolean forcible, long nonceGroup, long nonce) throws IOException
mergeRegions in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long splitRegion(org.apache.hadoop.hbase.client.RegionInfo regionInfo, byte[] splitRow, long nonceGroup, long nonce) throws IOException
splitRegion in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic org.apache.hadoop.hbase.master.TableStateManager getTableStateManager()
getTableStateManager in interface org.apache.hadoop.hbase.master.MasterServicespublic boolean isActiveMaster()
isActiveMaster in interface org.apache.hadoop.hbase.master.MasterServicespublic boolean isInitialized()
isInitialized in interface org.apache.hadoop.hbase.master.MasterServicespublic boolean isInMaintenanceMode()
isInMaintenanceMode in interface org.apache.hadoop.hbase.master.MasterServicespublic long getLastMajorCompactionTimestamp(org.apache.hadoop.hbase.TableName table) throws IOException
getLastMajorCompactionTimestamp in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic long getLastMajorCompactionTimestampForRegion(byte[] regionName) throws IOException
getLastMajorCompactionTimestampForRegion in interface org.apache.hadoop.hbase.master.MasterServicesIOExceptionpublic org.apache.hadoop.hbase.master.ClusterSchema getClusterSchema()
getClusterSchema in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.client.ClusterConnection getClusterConnection()
getClusterConnection in interface org.apache.hadoop.hbase.Serverpublic org.apache.hadoop.hbase.master.LoadBalancer getLoadBalancer()
getLoadBalancer in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.favored.FavoredNodesManager getFavoredNodesManager()
getFavoredNodesManager in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.master.snapshot.SnapshotManager getSnapshotManager()
getSnapshotManager in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.procedure.MasterProcedureManagerHost getMasterProcedureManagerHost()
getMasterProcedureManagerHost in interface org.apache.hadoop.hbase.master.MasterServicespublic boolean isSplitOrMergeEnabled(org.apache.hadoop.hbase.client.MasterSwitchType switchType)
isSplitOrMergeEnabled in interface org.apache.hadoop.hbase.master.MasterServicespublic long addReplicationPeer(String peerId, org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig, boolean enabled) throws org.apache.hadoop.hbase.replication.ReplicationException
addReplicationPeer in interface org.apache.hadoop.hbase.master.MasterServicesorg.apache.hadoop.hbase.replication.ReplicationExceptionpublic long removeReplicationPeer(String peerId) throws org.apache.hadoop.hbase.replication.ReplicationException
removeReplicationPeer in interface org.apache.hadoop.hbase.master.MasterServicesorg.apache.hadoop.hbase.replication.ReplicationExceptionpublic long enableReplicationPeer(String peerId) throws org.apache.hadoop.hbase.replication.ReplicationException, IOException
enableReplicationPeer in interface org.apache.hadoop.hbase.master.MasterServicesorg.apache.hadoop.hbase.replication.ReplicationExceptionIOExceptionpublic long disableReplicationPeer(String peerId) throws org.apache.hadoop.hbase.replication.ReplicationException, IOException
disableReplicationPeer in interface org.apache.hadoop.hbase.master.MasterServicesorg.apache.hadoop.hbase.replication.ReplicationExceptionIOExceptionpublic org.apache.hadoop.hbase.replication.ReplicationPeerConfig getReplicationPeerConfig(String peerId) throws org.apache.hadoop.hbase.replication.ReplicationException, IOException
getReplicationPeerConfig in interface org.apache.hadoop.hbase.master.MasterServicesorg.apache.hadoop.hbase.replication.ReplicationExceptionIOExceptionpublic long updateReplicationPeerConfig(String peerId, org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig) throws org.apache.hadoop.hbase.replication.ReplicationException, IOException
updateReplicationPeerConfig in interface org.apache.hadoop.hbase.master.MasterServicesorg.apache.hadoop.hbase.replication.ReplicationExceptionIOExceptionpublic List<org.apache.hadoop.hbase.replication.ReplicationPeerDescription> listReplicationPeers(String regex) throws org.apache.hadoop.hbase.replication.ReplicationException, IOException
listReplicationPeers in interface org.apache.hadoop.hbase.master.MasterServicesorg.apache.hadoop.hbase.replication.ReplicationExceptionIOExceptionpublic org.apache.hadoop.hbase.master.locking.LockManager getLockManager()
getLockManager in interface org.apache.hadoop.hbase.master.MasterServicespublic String getRegionServerVersion(org.apache.hadoop.hbase.ServerName sn)
getRegionServerVersion in interface org.apache.hadoop.hbase.master.MasterServicespublic void checkIfShouldMoveSystemRegionAsync()
checkIfShouldMoveSystemRegionAsync in interface org.apache.hadoop.hbase.master.MasterServicespublic String getClientIdAuditPrefix()
getClientIdAuditPrefix in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.procedure2.ProcedureEvent<?> getInitializedEvent()
getInitializedEvent in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.fs.FileSystem getFileSystem()
getFileSystem in interface org.apache.hadoop.hbase.Serverpublic org.apache.hadoop.hbase.client.Connection createConnection(org.apache.hadoop.conf.Configuration conf) throws IOException
createConnection in interface org.apache.hadoop.hbase.ServerIOExceptionpublic org.apache.hadoop.hbase.master.replication.ReplicationPeerManager getReplicationPeerManager()
getReplicationPeerManager in interface org.apache.hadoop.hbase.master.MasterServicespublic boolean isClusterUp()
isClusterUp in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.security.access.AccessChecker getAccessChecker()
getAccessChecker in interface org.apache.hadoop.hbase.master.MasterServicespublic org.apache.hadoop.hbase.security.access.ZKPermissionWatcher getZKPermissionWatcher()
getZKPermissionWatcher in interface org.apache.hadoop.hbase.master.MasterServicespublic List<org.apache.hadoop.hbase.master.RegionPlan> executeRegionPlansWithThrottling(List<org.apache.hadoop.hbase.master.RegionPlan> plans)
executeRegionPlansWithThrottling in interface org.apache.hadoop.hbase.master.MasterServicespublic void runReplicationBarrierCleaner()
runReplicationBarrierCleaner in interface org.apache.hadoop.hbase.master.MasterServicesCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.