MasterServices (Apache HBase 2.5.0 API)

All Superinterfaces:

Abortable, Server, Stoppable

All Known Implementing Classes:

HMaster, HMasterCommandLine.LocalHMaster
```
@InterfaceAudience.Private
public interface MasterServices
extends Server
```
A curated subset of services provided by HMaster. For use internally only. Passed to Managers, Services and Chores so can pass less-than-a full-on HMaster at test-time. Be judicious adding API. Changes cause ripples through the code base.

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and Description
`boolean`	`abortProcedure(long procId, boolean mayInterruptIfRunning)` Abort a procedure.
`long`	`addColumn(TableName tableName, ColumnFamilyDescriptor column, long nonceGroup, long nonce)` Add a new column to an existing table
`long`	`addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled)` Add a new replication peer for replicating data to slave cluster
`void`	`checkIfShouldMoveSystemRegionAsync()` Called when a new RegionServer is added to the cluster.
`void`	`checkTableModifiable(TableName tableName)` Check table is modifiable; i.e.
`long`	`createSystemTable(TableDescriptor tableDescriptor)` Create a system table using the given table definition.
`long`	`createTable(TableDescriptor desc, byte[][] splitKeys, long nonceGroup, long nonce)` Create a table using the given table definition.
`long`	`deleteColumn(TableName tableName, byte[] columnName, long nonceGroup, long nonce)` Delete a column from an existing table
`long`	`deleteTable(TableName tableName, long nonceGroup, long nonce)` Delete a table
`long`	`disableReplicationPeer(String peerId)` Stop the replication stream to the specified peer
`long`	`disableTable(TableName tableName, long nonceGroup, long nonce)` Disable an existing table
`long`	`enableReplicationPeer(String peerId)` Restart the replication stream to the specified peer
`long`	`enableTable(TableName tableName, long nonceGroup, long nonce)` Enable an existing table
`List<RegionPlan>`	`executeRegionPlansWithThrottling(List<RegionPlan> plans)` Execute region plans with throttling
`void`	`flushMasterStore()` Flush master local region
`AccessChecker`	`getAccessChecker()` Returns the `AccessChecker`
`AssignmentManager`	`getAssignmentManager()` Returns Master's instance of the `AssignmentManager`
`CatalogJanitor`	`getCatalogJanitor()` Returns Master's instance of `CatalogJanitor`
`String`	`getClientIdAuditPrefix()`
`ClusterSchema`	`getClusterSchema()` Returns Master's instance of `ClusterSchema`
`ExecutorService`	`getExecutorService()` Returns Master's instance of `ExecutorService`
`FavoredNodesManager`	`getFavoredNodesManager()` Returns Favored Nodes Manager
`ProcedureEvent<?>`	`getInitializedEvent()` Returns Tripped when Master has finished initialization.
`long`	`getLastMajorCompactionTimestamp(TableName table)`
`long`	`getLastMajorCompactionTimestampForRegion(byte[] regionName)` n * @return the timestamp of the last successful major compaction for the passed region or 0 if no HFile resulting from a major compaction exists n
`LoadBalancer`	`getLoadBalancer()` Returns load balancer
`LockManager`	`getLockManager()` Returns `LockManager` to lock namespaces/tables/regions.
`List<LockedResource>`	`getLocks()` Get locks
`MasterCoprocessorHost`	`getMasterCoprocessorHost()` Returns Master's instance of `MasterCoprocessorHost`
`MasterFileSystem`	`getMasterFileSystem()` Returns Master's filesystem `MasterFileSystem` utility class.
`MetricsMaster`	`getMasterMetrics()` Returns Master's instance of `MetricsMaster`
`ProcedureExecutor<MasterProcedureEnv>`	`getMasterProcedureExecutor()` Returns Master's instance of `ProcedureExecutor`
`MasterProcedureManagerHost`	`getMasterProcedureManagerHost()` Returns the underlying MasterProcedureManagerHost
`MasterQuotaManager`	`getMasterQuotaManager()` Returns Master's instance of `MasterQuotaManager`
`MasterWalManager`	`getMasterWalManager()` Returns Master's WALs `MasterWalManager` utility class.
`MetaLocationSyncer`	`getMetaLocationSyncer()` Get the meta location syncer.
`List<Procedure<?>>`	`getProcedures()` Get procedures
`RegionNormalizerManager`	`getRegionNormalizerManager()` Returns Master's instance of `RegionNormalizerManager`
`String`	`getRegionServerVersion(ServerName sn)`
`ReplicationPeerConfig`	`getReplicationPeerConfig(String peerId)` Returns the configured ReplicationPeerConfig for the specified peer
`ReplicationPeerManager`	`getReplicationPeerManager()` Returns the `ReplicationPeerManager`.
`ServerManager`	`getServerManager()` Returns Master's `ServerManager` instance.
`SnapshotManager`	`getSnapshotManager()` Returns the underlying snapshot manager
`default SplitWALManager`	`getSplitWALManager()` Returns return null if current is zk-based WAL splitting
`TableDescriptors`	`getTableDescriptors()` Returns Return table descriptors implementation.
`TableStateManager`	`getTableStateManager()` Returns Master's instance of `TableStateManager`
`ZKPermissionWatcher`	`getZKPermissionWatcher()` Returns the `ZKPermissionWatcher`
`boolean`	`isActiveMaster()` Returns true if master is the active one
`boolean`	`isClusterUp()` Returns True if cluster is up; false if cluster is not up (we are shutting down).
`boolean`	`isInitialized()` Returns true if master is initialized
`boolean`	`isInMaintenanceMode()`
`boolean`	`isSplitOrMergeEnabled(MasterSwitchType switchType)`
`List<ReplicationPeerDescription>`	`listReplicationPeers(String regex)` Return a list of replication peers.
`List<TableDescriptor>`	`listTableDescriptorsByNamespace(String name)` Get list of table descriptors by namespace
`List<TableName>`	`listTableNamesByNamespace(String name)` Get list of table names by namespace
`long`	`mergeRegions(RegionInfo[] regionsToMerge, boolean forcible, long nonceGroup, long nonce)` Merge regions in a table.
`long`	`modifyColumn(TableName tableName, ColumnFamilyDescriptor descriptor, long nonceGroup, long nonce)` Modify the column descriptor of an existing column in an existing table
`long`	`modifyColumnStoreFileTracker(TableName tableName, byte[] family, String dstSFT, long nonceGroup, long nonce)` Modify the store file tracker of an existing column in an existing table
`long`	`modifyTable(TableName tableName, TableDescriptor descriptor, long nonceGroup, long nonce)` Modify the descriptor of an existing table
`long`	`modifyTableStoreFileTracker(TableName tableName, String dstSFT, long nonceGroup, long nonce)` Modify the store file tracker of an existing table
`boolean`	`normalizeRegions(NormalizeTableFilterParams ntfp, boolean isHighPriority)` Perform normalization of cluster.
`boolean`	`registerService(com.google.protobuf.Service instance)` Registers a new protocol buffer `Service` subclass as a master coprocessor endpoint.
`long`	`removeReplicationPeer(String peerId)` Removes a peer and stops the replication
`void`	`runReplicationBarrierCleaner()` Run the ReplicationBarrierChore.
`boolean`	`skipRegionManagementAction(String action)` Checks master state before initiating action over region topology.
`long`	`splitRegion(RegionInfo regionInfo, byte[] splitRow, long nonceGroup, long nonce)` Split a region.
`long`	`truncateTable(TableName tableName, boolean preserveSplits, long nonceGroup, long nonce)` Truncate a table
`long`	`updateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig)` Update the peerConfig for the specified peer

Methods inherited from interface org.apache.hadoop.hbase.Server
createConnection, getChoreService, getClusterConnection, getConfiguration, getConnection, getCoordinatedStateManager, getFileSystem, getServerName, getZooKeeper, isStopping

Methods inherited from interface org.apache.hadoop.hbase.Abortable
abort, abort, isAborted

Methods inherited from interface org.apache.hadoop.hbase.Stoppable
isStopped, stop

- Method Detail
  - getSnapshotManager
```
SnapshotManager getSnapshotManager()
```
    Returns the underlying snapshot manager
  - getMasterProcedureManagerHost
```
MasterProcedureManagerHost getMasterProcedureManagerHost()
```
    Returns the underlying MasterProcedureManagerHost
  - getClusterSchema
```
ClusterSchema getClusterSchema()
```
    Returns Master's instance of ClusterSchema
  - getAssignmentManager
```
AssignmentManager getAssignmentManager()
```
    Returns Master's instance of the AssignmentManager
  - getMasterFileSystem
```
MasterFileSystem getMasterFileSystem()
```
    Returns Master's filesystem MasterFileSystem utility class.
  - getMasterWalManager
```
MasterWalManager getMasterWalManager()
```
    Returns Master's WALs MasterWalManager utility class.
  - getServerManager
```
ServerManager getServerManager()
```
    Returns Master's ServerManager instance.
  - getExecutorService
```
ExecutorService getExecutorService()
```
    Returns Master's instance of ExecutorService
  - getTableStateManager
```
TableStateManager getTableStateManager()
```
    Returns Master's instance of TableStateManager
  - getMasterCoprocessorHost
```
MasterCoprocessorHost getMasterCoprocessorHost()
```
    Returns Master's instance of MasterCoprocessorHost
  - getMasterQuotaManager
```
MasterQuotaManager getMasterQuotaManager()
```
    Returns Master's instance of MasterQuotaManager
  - getRegionNormalizerManager
```
RegionNormalizerManager getRegionNormalizerManager()
```
    Returns Master's instance of RegionNormalizerManager
  - getCatalogJanitor
```
CatalogJanitor getCatalogJanitor()
```
    Returns Master's instance of CatalogJanitor
  - getMasterProcedureExecutor
```
ProcedureExecutor<MasterProcedureEnv> getMasterProcedureExecutor()
```
    Returns Master's instance of ProcedureExecutor
  - getInitializedEvent
```
ProcedureEvent<?> getInitializedEvent()
```
    Returns Tripped when Master has finished initialization.
  - getMasterMetrics
```
MetricsMaster getMasterMetrics()
```
    Returns Master's instance of MetricsMaster
  - checkTableModifiable
```
void checkTableModifiable(TableName tableName)
                   throws IOException,
                          TableNotFoundException,
                          TableNotDisabledException
```
    Check table is modifiable; i.e. exists and is offline.
    
    Parameters:
    
    tableName - Name of table to check. nnn
    
    Throws:
    
    IOException
    
    TableNotFoundException
    
    TableNotDisabledException
  - createTable
```
long createTable(TableDescriptor desc,
                 byte[][] splitKeys,
                 long nonceGroup,
                 long nonce)
          throws IOException
```
    Create a table using the given table definition.
    
    Parameters:
    
    desc - The table definition
    
    splitKeys - Starting row keys for the initial table regions. If null nn * a single region is created.
    
    Throws:
    
    IOException
  - createSystemTable
```
long createSystemTable(TableDescriptor tableDescriptor)
                throws IOException
```
    Create a system table using the given table definition.
    
    Parameters:
    
    tableDescriptor - The system table definition a single region is created.
    
    Throws:
    
    IOException
  - deleteTable
```
long deleteTable(TableName tableName,
                 long nonceGroup,
                 long nonce)
          throws IOException
```
    Delete a table
    
    Parameters:
    
    tableName - The table name nnn
    
    Throws:
    
    IOException
  - truncateTable
```
long truncateTable(TableName tableName,
                   boolean preserveSplits,
                   long nonceGroup,
                   long nonce)
            throws IOException
```
    Truncate a table
    
    Parameters:
    
    tableName - The table name
    
    preserveSplits - True if the splits should be preserved nnn
    
    Throws:
    
    IOException
  - modifyTable
```
long modifyTable(TableName tableName,
                 TableDescriptor descriptor,
                 long nonceGroup,
                 long nonce)
          throws IOException
```
    Modify the descriptor of an existing table
    
    Parameters:
    
    tableName - The table name
    
    descriptor - The updated table descriptor nnn
    
    Throws:
    
    IOException
  - modifyTableStoreFileTracker
```
long modifyTableStoreFileTracker(TableName tableName,
                                 String dstSFT,
                                 long nonceGroup,
                                 long nonce)
                          throws IOException
```
    Modify the store file tracker of an existing table
    
    Throws:
    
    IOException
  - enableTable
```
long enableTable(TableName tableName,
                 long nonceGroup,
                 long nonce)
          throws IOException
```
    Enable an existing table
    
    Parameters:
    
    tableName - The table name nnn
    
    Throws:
    
    IOException
  - disableTable
```
long disableTable(TableName tableName,
                  long nonceGroup,
                  long nonce)
           throws IOException
```
    Disable an existing table
    
    Parameters:
    
    tableName - The table name nnn
    
    Throws:
    
    IOException
  - addColumn
```
long addColumn(TableName tableName,
               ColumnFamilyDescriptor column,
               long nonceGroup,
               long nonce)
        throws IOException
```
    Add a new column to an existing table
    
    Parameters:
    
    tableName - The table name
    
    column - The column definition nnn
    
    Throws:
    
    IOException
  - modifyColumn
```
long modifyColumn(TableName tableName,
                  ColumnFamilyDescriptor descriptor,
                  long nonceGroup,
                  long nonce)
           throws IOException
```
    Modify the column descriptor of an existing column in an existing table
    
    Parameters:
    
    tableName - The table name
    
    descriptor - The updated column definition nnn
    
    Throws:
    
    IOException
  - modifyColumnStoreFileTracker
```
long modifyColumnStoreFileTracker(TableName tableName,
                                  byte[] family,
                                  String dstSFT,
                                  long nonceGroup,
                                  long nonce)
                           throws IOException
```
    Modify the store file tracker of an existing column in an existing table
    
    Throws:
    
    IOException
  - deleteColumn
```
long deleteColumn(TableName tableName,
                  byte[] columnName,
                  long nonceGroup,
                  long nonce)
           throws IOException
```
    Delete a column from an existing table
    
    Parameters:
    
    tableName - The table name
    
    columnName - The column name nnn
    
    Throws:
    
    IOException
  - mergeRegions
```
long mergeRegions(RegionInfo[] regionsToMerge,
                  boolean forcible,
                  long nonceGroup,
                  long nonce)
           throws IOException
```
    Merge regions in a table.
    
    Parameters:
    
    regionsToMerge - daughter regions to merge
    
    forcible - whether to force to merge even two regions are not adjacent
    
    nonceGroup - used to detect duplicate
    
    nonce - used to detect duplicate
    
    Returns:
    
    procedure Id n
    
    Throws:
    
    IOException
  - splitRegion
```
long splitRegion(RegionInfo regionInfo,
                 byte[] splitRow,
                 long nonceGroup,
                 long nonce)
          throws IOException
```
    Split a region.
    
    Parameters:
    
    regionInfo - region to split
    
    splitRow - split point
    
    nonceGroup - used to detect duplicate
    
    nonce - used to detect duplicate
    
    Returns:
    
    procedure Id n
    
    Throws:
    
    IOException
  - getTableDescriptors
```
TableDescriptors getTableDescriptors()
```
    Returns Return table descriptors implementation.
  - registerService
```
boolean registerService(com.google.protobuf.Service instance)
```
    Registers a new protocol buffer Service subclass as a master coprocessor endpoint.
    Only a single instance may be registered for a given Service subclass (the instances are keyed on Descriptors.ServiceDescriptor.getFullName(). After the first registration, subsequent calls with the same service name will fail with a return value of false.
    
    Parameters:
    
    instance - the Service subclass instance to expose as a coprocessor endpoint
    
    Returns:
    
    true if the registration was successful, false otherwise
  - isActiveMaster
```
boolean isActiveMaster()
```
    Returns true if master is the active one
  - isInitialized
```
boolean isInitialized()
```
    Returns true if master is initialized
  - isInMaintenanceMode
```
boolean isInMaintenanceMode()
```
    Returns:
    
    true if master is in maintanceMode
    
    Throws:
    
    IOException - if the inquiry failed due to an IO problem
  - skipRegionManagementAction
```
boolean skipRegionManagementAction(String action)
```
    Checks master state before initiating action over region topology.
    
    Parameters:
    
    action - the name of the action under consideration, for logging.
    
    Returns:
    
    true when the caller should exit early, false otherwise.
  - abortProcedure
```
boolean abortProcedure(long procId,
                       boolean mayInterruptIfRunning)
                throws IOException
```
    Abort a procedure.
    
    Parameters:
    
    procId - ID of the procedure
    
    mayInterruptIfRunning - if the proc completed at least one step, should it be aborted?
    
    Returns:
    
    true if aborted, false if procedure already completed or does not exist n
    
    Throws:
    
    IOException
  - getProcedures
```
List<Procedure<?>> getProcedures()
                          throws IOException
```
    Get procedures
    
    Returns:
    
    procedure list n
    
    Throws:
    
    IOException
  - getLocks
```
List<LockedResource> getLocks()
                       throws IOException
```
    Get locks
    
    Returns:
    
    lock list n
    
    Throws:
    
    IOException
  - listTableDescriptorsByNamespace
```
List<TableDescriptor> listTableDescriptorsByNamespace(String name)
                                               throws IOException
```
    Get list of table descriptors by namespace
    
    Parameters:
    
    name - namespace name nn
    
    Throws:
    
    IOException
  - listTableNamesByNamespace
```
List<TableName> listTableNamesByNamespace(String name)
                                   throws IOException
```
    Get list of table names by namespace
    
    Parameters:
    
    name - namespace name
    
    Returns:
    
    table names n
    
    Throws:
    
    IOException
  - getLastMajorCompactionTimestamp
```
long getLastMajorCompactionTimestamp(TableName table)
                              throws IOException
```
    Parameters:
    
    table - the table for which last successful major compaction time is queried
    
    Returns:
    
    the timestamp of the last successful major compaction for the passed table, or 0 if no HFile resulting from a major compaction exists n
    
    Throws:
    
    IOException
  - getLastMajorCompactionTimestampForRegion
```
long getLastMajorCompactionTimestampForRegion(byte[] regionName)
                                       throws IOException
```
    n * @return the timestamp of the last successful major compaction for the passed region or 0 if no HFile resulting from a major compaction exists n
    
    Throws:
    
    IOException
  - getLoadBalancer
```
LoadBalancer getLoadBalancer()
```
    Returns load balancer
  - isSplitOrMergeEnabled
```
boolean isSplitOrMergeEnabled(MasterSwitchType switchType)
```
  - getFavoredNodesManager
```
FavoredNodesManager getFavoredNodesManager()
```
    Returns Favored Nodes Manager
  - addReplicationPeer
```
long addReplicationPeer(String peerId,
                        ReplicationPeerConfig peerConfig,
                        boolean enabled)
                 throws ReplicationException,
                        IOException
```
    Add a new replication peer for replicating data to slave cluster
    
    Parameters:
    
    peerId - a short name that identifies the peer
    
    peerConfig - configuration for the replication slave cluster
    
    enabled - peer state, true if ENABLED and false if DISABLED
    
    Throws:
    
    ReplicationException
    
    IOException
  - removeReplicationPeer
```
long removeReplicationPeer(String peerId)
                    throws ReplicationException,
                           IOException
```
    Removes a peer and stops the replication
    
    Parameters:
    
    peerId - a short name that identifies the peer
    
    Throws:
    
    ReplicationException
    
    IOException
  - enableReplicationPeer
```
long enableReplicationPeer(String peerId)
                    throws ReplicationException,
                           IOException
```
    Restart the replication stream to the specified peer
    
    Parameters:
    
    peerId - a short name that identifies the peer
    
    Throws:
    
    ReplicationException
    
    IOException
  - disableReplicationPeer
```
long disableReplicationPeer(String peerId)
                     throws ReplicationException,
                            IOException
```
    Stop the replication stream to the specified peer
    
    Parameters:
    
    peerId - a short name that identifies the peer
    
    Throws:
    
    ReplicationException
    
    IOException
  - getReplicationPeerConfig
```
ReplicationPeerConfig getReplicationPeerConfig(String peerId)
                                        throws ReplicationException,
                                               IOException
```
    Returns the configured ReplicationPeerConfig for the specified peer
    
    Parameters:
    
    peerId - a short name that identifies the peer
    
    Returns:
    
    ReplicationPeerConfig for the peer
    
    Throws:
    
    ReplicationException
    
    IOException
  - getReplicationPeerManager
```
ReplicationPeerManager getReplicationPeerManager()
```
    Returns the ReplicationPeerManager.
  - updateReplicationPeerConfig
```
long updateReplicationPeerConfig(String peerId,
                                 ReplicationPeerConfig peerConfig)
                          throws ReplicationException,
                                 IOException
```
    Update the peerConfig for the specified peer
    
    Parameters:
    
    peerId - a short name that identifies the peer
    
    peerConfig - new config for the peer
    
    Throws:
    
    ReplicationException
    
    IOException
  - listReplicationPeers
```
List<ReplicationPeerDescription> listReplicationPeers(String regex)
                                               throws ReplicationException,
                                                      IOException
```
    Return a list of replication peers.
    
    Parameters:
    
    regex - The regular expression to match peer id
    
    Returns:
    
    a list of replication peers description
    
    Throws:
    
    ReplicationException
    
    IOException
  - getLockManager
```
LockManager getLockManager()
```
    Returns LockManager to lock namespaces/tables/regions.
  - getRegionServerVersion
```
String getRegionServerVersion(ServerName sn)
```
  - checkIfShouldMoveSystemRegionAsync
```
void checkIfShouldMoveSystemRegionAsync()
```
    Called when a new RegionServer is added to the cluster. Checks if new server has a newer version than any existing server and will move system tables there if so.
  - getClientIdAuditPrefix
```
String getClientIdAuditPrefix()
```
  - isClusterUp
```
boolean isClusterUp()
```
    Returns True if cluster is up; false if cluster is not up (we are shutting down).
  - getSplitWALManager
```
default SplitWALManager getSplitWALManager()
```
    Returns return null if current is zk-based WAL splitting
  - getAccessChecker
```
AccessChecker getAccessChecker()
```
    Returns the AccessChecker
  - getZKPermissionWatcher
```
ZKPermissionWatcher getZKPermissionWatcher()
```
    Returns the ZKPermissionWatcher
  - executeRegionPlansWithThrottling
```
List<RegionPlan> executeRegionPlansWithThrottling(List<RegionPlan> plans)
```
    Execute region plans with throttling
    
    Parameters:
    
    plans - to execute
    
    Returns:
    
    succeeded plans
  - runReplicationBarrierCleaner
```
void runReplicationBarrierCleaner()
```
    Run the ReplicationBarrierChore.
  - normalizeRegions
```
boolean normalizeRegions(NormalizeTableFilterParams ntfp,
                         boolean isHighPriority)
                  throws IOException
```
    Perform normalization of cluster.
    
    Parameters:
    
    ntfp - Selection criteria for identifying which tables to normalize.
    
    isHighPriority - true when these requested tables should skip to the front of the queue.
    
    Returns:
    
    true when the request was submitted, false otherwise.
    
    Throws:
    
    IOException
  - getMetaLocationSyncer
```
MetaLocationSyncer getMetaLocationSyncer()
```
    Get the meta location syncer.
    We need to get this in MTP to tell the syncer the new meta replica count.
  - flushMasterStore
```
void flushMasterStore()
               throws IOException
```
    Flush master local region
    
    Throws:
    
    IOException

Interface MasterServices

Method Summary

Methods inherited from interface org.apache.hadoop.hbase.Server

Methods inherited from interface org.apache.hadoop.hbase.Abortable

Methods inherited from interface org.apache.hadoop.hbase.Stoppable

Method Detail

getSnapshotManager

getMasterProcedureManagerHost

getClusterSchema

getAssignmentManager

getMasterFileSystem

getMasterWalManager

getServerManager

getExecutorService

getTableStateManager

getMasterCoprocessorHost

getMasterQuotaManager

getRegionNormalizerManager

getCatalogJanitor

getMasterProcedureExecutor

getInitializedEvent

getMasterMetrics

checkTableModifiable

createTable

createSystemTable

deleteTable

truncateTable

modifyTable

modifyTableStoreFileTracker

enableTable

disableTable

addColumn

modifyColumn

modifyColumnStoreFileTracker

deleteColumn

mergeRegions

splitRegion

getTableDescriptors

registerService

isActiveMaster

isInitialized

isInMaintenanceMode

skipRegionManagementAction

abortProcedure

getProcedures

getLocks

listTableDescriptorsByNamespace

listTableNamesByNamespace

getLastMajorCompactionTimestamp

getLastMajorCompactionTimestampForRegion

getLoadBalancer

isSplitOrMergeEnabled

getFavoredNodesManager

addReplicationPeer

removeReplicationPeer

enableReplicationPeer

disableReplicationPeer

getReplicationPeerConfig

getReplicationPeerManager

updateReplicationPeerConfig

listReplicationPeers

getLockManager

getRegionServerVersion

checkIfShouldMoveSystemRegionAsync

getClientIdAuditPrefix

isClusterUp

getSplitWALManager

getAccessChecker

getZKPermissionWatcher

executeRegionPlansWithThrottling

runReplicationBarrierCleaner

normalizeRegions

getMetaLocationSyncer

flushMasterStore