@InterfaceAudience.LimitedPrivate(value="Tools") public class HMaster extends HRegionServer implements MasterServices, Server
The Master can be asked shutdown the cluster. See shutdown()
. In
this case it will tell all regionservers to go down and then wait on them
all reporting in that they are down. This master will then shut itself down.
You can also shutdown just this master. Call stopMaster()
.
org.apache.zookeeper.Watcher
Modifier and Type | Class and Description |
---|---|
static class |
HMaster.RedirectServlet |
HRegionServer.MovedRegionsCleaner
RegionServerServices.PostOpenDeployContext, RegionServerServices.RegionStateTransitionContext
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
MASTER |
cacheConfig, cacheFlusher, CLOSE, clusterConnection, clusterStatusTracker, compactSplitThread, conf, configurationManager, csm, fs, fsOk, fsUtilizationChore, hMemManager, infoServer, initLatch, leases, lock, metaTableLocator, movedRegions, msgInterval, numRegionsToReport, onlineRegions, OPEN, recoveringRegions, regionFavoredNodesMap, REGIONSERVER, regionsInTransitionInRS, replicationSinkHandler, replicationSourceHandler, rpcServices, serverName, service, sleeper, startcode, tableDescriptors, tableLockManager, threadWakeFrequency, walFactory, walFs, zooKeeper
Constructor and Description |
---|
HMaster(Configuration conf,
CoordinatedStateManager csm)
Initializes the HMaster.
|
Modifier and Type | Method and Description |
---|---|
void |
abort(java.lang.String msg,
java.lang.Throwable t)
Cause the server to exit without closing the regions it is serving, the log
it is using and without notifying the master.
|
boolean |
abortProcedure(long procId,
boolean mayInterruptIfRunning)
Abort a procedure.
|
void |
addColumn(TableName tableName,
HColumnDescriptor columnDescriptor,
long nonceGroup,
long nonce)
Add a new column to an existing table
|
void |
assignRegion(HRegionInfo hri) |
Pair<java.lang.Long,java.lang.String> |
backupTables(BackupType type,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth)
Full backup given list of tables
|
boolean |
balance() |
boolean |
balance(boolean force) |
boolean |
balanceSwitch(boolean b) |
protected boolean |
canCreateBaseZNode() |
protected boolean |
canUpdateTableDescriptor() |
void |
checkTableModifiable(TableName tableName)
Check table is modifiable; i.e.
|
protected void |
configureInfoServer() |
static HMaster |
constructMaster(java.lang.Class<? extends HMaster> masterClass,
Configuration conf,
CoordinatedStateManager cp)
Utility for constructing an instance of the passed HMaster class.
|
void |
createNamespace(NamespaceDescriptor descriptor)
Create a new namespace
|
protected RSRpcServices |
createRpcServices() |
long |
createTable(HTableDescriptor hTableDescriptor,
byte[][] splitKeys,
long nonceGroup,
long nonce)
Create a table using the given table definition.
|
void |
deleteColumn(TableName tableName,
byte[] columnName,
long nonceGroup,
long nonce)
Delete a column from an existing table
|
void |
deleteNamespace(java.lang.String name)
Delete an existing namespace.
|
long |
deleteTable(TableName tableName,
long nonceGroup,
long nonce)
Delete a table
|
long |
disableTable(TableName tableName,
long nonceGroup,
long nonce)
Disable an existing table
|
void |
dispatchMergingRegions(HRegionInfo region_a,
HRegionInfo region_b,
boolean forcible)
Merge two regions.
|
long |
enableTable(TableName tableName,
long nonceGroup,
long nonce)
Enable an existing table
|
AssignmentManager |
getAssignmentManager() |
double |
getAverageLoad()
Compute the average load across all region servers.
|
ClusterStatus |
getClusterStatus() |
protected java.lang.Class<? extends HttpServlet> |
getDumpServlet() |
HFileCleaner |
getHFileCleaner() |
long |
getLastMajorCompactionTimestamp(TableName table) |
long |
getLastMajorCompactionTimestampForRegion(byte[] regionName) |
LoadBalancer |
getLoadBalancer() |
java.lang.String |
getLoadBalancerClassName()
Fetch the configured
LoadBalancer class name. |
static java.lang.String |
getLoadedCoprocessors()
The set of loaded coprocessors is stored in a static set.
|
long |
getMasterActiveTime() |
MasterCoprocessorHost |
getMasterCoprocessorHost() |
java.lang.String[] |
getMasterCoprocessors() |
MasterFileSystem |
getMasterFileSystem() |
ProcedureExecutor<MasterProcedureEnv> |
getMasterProcedureExecutor() |
MasterProcedureManagerHost |
getMasterProcedureManagerHost() |
MasterQuotaManager |
getMasterQuotaManager() |
MasterRpcServices |
getMasterRpcServices() |
long |
getMasterStartTime() |
AdminProtos.GetRegionInfoResponse.CompactionState |
getMobCompactionState(TableName tableName)
Gets the mob file compaction state for a specific table.
|
NamespaceDescriptor |
getNamespaceDescriptor(java.lang.String name)
Get a namespace descriptor by name
|
int |
getNumWALFiles() |
protected java.lang.String |
getProcessName() |
QuotaObserverChore |
getQuotaObserverChore() |
RegionNormalizerTracker |
getRegionNormalizerTracker() |
MemoryBoundedLogMessageBuffer |
getRegionServerFatalLogBuffer() |
int |
getRegionServerInfoPort(ServerName sn) |
ServerManager |
getServerManager() |
ServerName |
getServerName() |
SnapshotManager |
getSnapshotManager() |
SpaceQuotaSnapshotNotifier |
getSpaceQuotaSnapshotNotifier() |
SplitOrMergeTracker |
getSplitOrMergeTracker() |
TableDescriptors |
getTableDescriptors() |
TableStateManager |
getTableStateManager() |
WALProcedureStore |
getWalProcedureStore() |
ZooKeeperWatcher |
getZooKeeper()
Gets the ZooKeeper instance for this server.
|
boolean |
isActiveMaster()
Report whether this master is currently the active master or not.
|
boolean |
isBalancerOn()
Queries the state of the
LoadBalancerTracker . |
boolean |
isInitializationStartsMetaRegionAssignment()
Report whether this master has started initialization and is about to do meta region assignment
|
boolean |
isInitialized()
Report whether this master has completed with its initialization and is
ready.
|
boolean |
isInMaintenanceMode()
Report whether this master is in maintenance mode.
|
boolean |
isMasterProcedureExecutorEnabled()
Check whether the procedure executor is enabled
|
boolean |
isNamespaceManagerInitialized()
Report whether this master has completed with its initialization and
namespace manager is ready
This method is used for testing.
|
boolean |
isNormalizerOn()
Queries the state of the
RegionNormalizerTracker . |
boolean |
isServerShutdownHandlerEnabled()
ServerShutdownHandlerEnabled is set false before completing
assignMeta to prevent processing of ServerShutdownHandler.
|
boolean |
isSplitOrMergeEnabled(Admin.MasterSwitchType switchType)
Queries the state of the
SplitOrMergeTracker . |
java.util.List<NamespaceDescriptor> |
listNamespaceDescriptors()
List available namespace descriptors
|
java.util.List<ProcedureInfo> |
listProcedures()
List procedures
|
java.util.List<HTableDescriptor> |
listTableDescriptors(java.lang.String namespace,
java.lang.String regex,
java.util.List<TableName> tableNameList,
boolean includeSysTables)
Returns the list of table descriptors that match the specified request
|
java.util.List<HTableDescriptor> |
listTableDescriptorsByNamespace(java.lang.String name)
Get list of table descriptors by namespace
|
java.util.List<TableName> |
listTableNames(java.lang.String namespace,
java.lang.String regex,
boolean includeSysTables)
Returns the list of table names that match the specified request
|
java.util.List<TableName> |
listTableNamesByNamespace(java.lang.String name)
Get list of table names by namespace
|
protected void |
login(UserProvider user,
java.lang.String host)
For compatibility, if failed with regionserver credentials, try the master one
|
static void |
main(java.lang.String[] args) |
void |
modifyColumn(TableName tableName,
HColumnDescriptor descriptor,
long nonceGroup,
long nonce)
Modify the column descriptor of an existing column in an existing table
|
void |
modifyNamespace(NamespaceDescriptor descriptor)
Modify an existing namespace
|
void |
modifyTable(TableName tableName,
HTableDescriptor descriptor,
long nonceGroup,
long nonce)
Modify the descriptor of an existing table
|
boolean |
normalizeRegions()
Perform normalization of cluster (invoked by
RegionNormalizerChore ). |
boolean |
registerService(Service instance)
Registers a new protocol buffer
Service subclass as a coprocessor endpoint to be
available for handling |
void |
reportMobCompactionEnd(TableName tableName) |
void |
reportMobCompactionStart(TableName tableName) |
void |
requestMobCompaction(TableName tableName,
java.util.List<HColumnDescriptor> columns,
boolean allFiles)
Requests mob compaction.
|
protected void |
sendShutdownInterrupt()
Called on stop/abort before closing the cluster connection and meta locator.
|
void |
setCatalogJanitorEnabled(boolean b)
Switch for the background CatalogJanitor thread.
|
void |
shutdown() |
void |
stopMaster() |
protected void |
stopServiceThreads()
Wait on all threads to finish.
|
void |
truncateTable(TableName tableName,
boolean preserveSplits,
long nonceGroup,
long nonce)
Truncate a table
|
void |
updateConfigurationForSpaceQuotaObserver(Configuration conf)
Adds the
MasterSpaceQuotaObserver to the list of configured Master observers to
automatically remove space quotas for a table when that table is deleted. |
protected void |
waitForMasterActive()
If configured to put regions on active master,
wait till a backup master becomes active.
|
abort, addToMovedRegions, addToOnlineRegions, checkFileSystem, cleanMovedRegions, closeAllRegions, closeRegion, constructRegionServer, convertThrowableToIOE, createClusterConnection, createRegionLoad, createRegionServerStatusStub, ensureMetaWALRoller, execRegionServerService, getCacheConfig, getChoreService, getClusterId, getCompactionPressure, getCompactionRequester, getCompactSplitThread, getConfiguration, getConfigurationManager, getConnection, getCoordinatedStateManager, getExecutorService, getFavoredNodesForRegion, getFileSystem, getFlushRequester, getFromOnlineRegions, getHeapMemoryManager, getInfoServer, getLastSequenceId, getLeases, getMasterAddressTracker, getMetaTableLocator, getMetrics, getMostLoadedRegions, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegions, getOnlineRegions, getOnlineRegionsLocalContext, getOnlineTables, getRecoveringRegions, getRegion, getRegionBlockLocations, getRegionByEncodedName, getRegionByEncodedName, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerMetrics, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSourceService, getRootDir, getRpcServer, getRSRpcServices, getStartcode, getTableLockManager, getThreadWakeFrequency, getWAL, getWALFileSystem, getWALRootDir, handleReportForDutyResponse, isAborted, isOnline, isStopped, isStopping, kill, movedRegionCleanerPeriod, postOpenDeployTasks, postOpenDeployTasks, removeFromOnlineRegions, reportRegionSizesForQuotas, reportRegionStateTransition, reportRegionStateTransition, reportRegionStateTransition, run, setInitLatch, setupClusterConnection, shouldUseThisHostnameInstead, stop, toString, tryRegionServerReport, updateConfiguration, updateRegionFavoredNodesMapping, waitForServerOnline
getName, getThread, interrupt, isAlive, isInterrupted, join, join, join, setDaemon, setName, setPriority, setUncaughtExceptionHandler, start
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getExecutorService, getTableLockManager
getChoreService, getConfiguration, getConnection, getCoordinatedStateManager, getMetaTableLocator
public static final java.lang.String MASTER
public HMaster(Configuration conf, CoordinatedStateManager csm) throws java.io.IOException, KeeperException, java.lang.InterruptedException
Remaining steps of initialization occur in #finishActiveMasterInitialization(MonitoredTask) after the master becomes the active one.
java.lang.InterruptedException
KeeperException
java.io.IOException
protected void login(UserProvider user, java.lang.String host) throws java.io.IOException
login
in class HRegionServer
java.io.IOException
protected void waitForMasterActive()
waitForMasterActive
in class HRegionServer
public MasterRpcServices getMasterRpcServices()
public boolean balanceSwitch(boolean b) throws java.io.IOException
java.io.IOException
protected java.lang.String getProcessName()
getProcessName
in class HRegionServer
protected boolean canCreateBaseZNode()
canCreateBaseZNode
in class HRegionServer
protected boolean canUpdateTableDescriptor()
canUpdateTableDescriptor
in class HRegionServer
protected RSRpcServices createRpcServices() throws java.io.IOException
createRpcServices
in class HRegionServer
java.io.IOException
protected void configureInfoServer()
configureInfoServer
in class HRegionServer
protected java.lang.Class<? extends HttpServlet> getDumpServlet()
getDumpServlet
in class HRegionServer
public void updateConfigurationForSpaceQuotaObserver(Configuration conf)
MasterSpaceQuotaObserver
to the list of configured Master observers to
automatically remove space quotas for a table when that table is deleted.public TableDescriptors getTableDescriptors()
getTableDescriptors
in interface MasterServices
getTableDescriptors
in class HRegionServer
public ServerManager getServerManager()
getServerManager
in interface MasterServices
ServerManager
instance.public MasterFileSystem getMasterFileSystem()
getMasterFileSystem
in interface MasterServices
MasterFileSystem
utility class.protected void sendShutdownInterrupt()
HRegionServer
sendShutdownInterrupt
in class HRegionServer
protected void stopServiceThreads()
HRegionServer
stopServiceThreads
in class HRegionServer
public boolean isMasterProcedureExecutorEnabled()
isMasterProcedureExecutorEnabled
in interface MasterServices
public boolean balance() throws java.io.IOException
java.io.IOException
public boolean balance(boolean force) throws java.io.IOException
java.io.IOException
public boolean normalizeRegions() throws java.io.IOException, CoordinatedStateException
RegionNormalizerChore
).IOException,
- CoordinatedStateExceptionjava.io.IOException
CoordinatedStateException
public void setCatalogJanitorEnabled(boolean b)
b
- If false, the catalog janitor won't do anything.public void dispatchMergingRegions(HRegionInfo region_a, HRegionInfo region_b, boolean forcible) throws java.io.IOException
MasterServices
dispatchMergingRegions
in interface MasterServices
region_a
- region to mergeregion_b
- region to mergeforcible
- true if do a compulsory merge, otherwise we will only merge
two adjacent regionsjava.io.IOException
public long createTable(HTableDescriptor hTableDescriptor, byte[][] splitKeys, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
createTable
in interface MasterServices
hTableDescriptor
- The table definitionsplitKeys
- Starting row keys for the initial table regions. If nullnonce
- a single region is created.java.io.IOException
public long deleteTable(TableName tableName, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
deleteTable
in interface MasterServices
tableName
- The table namejava.io.IOException
public void truncateTable(TableName tableName, boolean preserveSplits, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
truncateTable
in interface MasterServices
tableName
- The table namepreserveSplits
- True if the splits should be preservedjava.io.IOException
public void addColumn(TableName tableName, HColumnDescriptor columnDescriptor, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
addColumn
in interface MasterServices
tableName
- The table namecolumnDescriptor
- The column definitionjava.io.IOException
public void modifyColumn(TableName tableName, HColumnDescriptor descriptor, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
modifyColumn
in interface MasterServices
tableName
- The table namedescriptor
- The updated column definitionjava.io.IOException
public void deleteColumn(TableName tableName, byte[] columnName, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
deleteColumn
in interface MasterServices
tableName
- The table namecolumnName
- The column namejava.io.IOException
public long enableTable(TableName tableName, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
enableTable
in interface MasterServices
tableName
- The table namejava.io.IOException
public long disableTable(TableName tableName, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
disableTable
in interface MasterServices
tableName
- The table namejava.io.IOException
public void modifyTable(TableName tableName, HTableDescriptor descriptor, long nonceGroup, long nonce) throws java.io.IOException
MasterServices
modifyTable
in interface MasterServices
tableName
- The table namedescriptor
- The updated table descriptorjava.io.IOException
public void checkTableModifiable(TableName tableName) throws java.io.IOException, TableNotFoundException, TableNotDisabledException
MasterServices
checkTableModifiable
in interface MasterServices
tableName
- Name of table to check.TableNotDisabledException
TableNotFoundException
java.io.IOException
public ClusterStatus getClusterStatus() throws java.io.InterruptedIOException
java.io.InterruptedIOException
public static java.lang.String getLoadedCoprocessors()
public long getMasterStartTime()
public long getMasterActiveTime()
public int getNumWALFiles()
public WALProcedureStore getWalProcedureStore()
public int getRegionServerInfoPort(ServerName sn)
public java.lang.String[] getMasterCoprocessors()
public void abort(java.lang.String msg, java.lang.Throwable t)
HRegionServer
abort
in interface Abortable
abort
in class HRegionServer
msg
- the reason we are abortingt
- the exception that caused the abort, or nullpublic ZooKeeperWatcher getZooKeeper()
Server
getZooKeeper
in interface Server
getZooKeeper
in class HRegionServer
public MasterCoprocessorHost getMasterCoprocessorHost()
getMasterCoprocessorHost
in interface MasterServices
MasterCoprocessorHost
public MasterQuotaManager getMasterQuotaManager()
getMasterQuotaManager
in interface MasterServices
MasterQuotaManager
public ProcedureExecutor<MasterProcedureEnv> getMasterProcedureExecutor()
getMasterProcedureExecutor
in interface MasterServices
ProcedureExecutor
public ServerName getServerName()
getServerName
in interface Server
getServerName
in class HRegionServer
public AssignmentManager getAssignmentManager()
getAssignmentManager
in interface MasterServices
AssignmentManager
public MemoryBoundedLogMessageBuffer getRegionServerFatalLogBuffer()
public void shutdown() throws java.io.IOException
java.io.IOException
public void stopMaster() throws java.io.IOException
java.io.IOException
public boolean isActiveMaster()
public boolean isInitialized()
isInitialized
in interface MasterServices
public boolean isNamespaceManagerInitialized()
isNamespaceManagerInitialized
in interface MasterServices
public boolean isInMaintenanceMode()
isInMaintenanceMode
in interface MasterServices
public boolean isServerShutdownHandlerEnabled()
isServerShutdownHandlerEnabled
in interface MasterServices
public boolean isInitializationStartsMetaRegionAssignment()
public void assignRegion(HRegionInfo hri)
public double getAverageLoad()
public boolean registerService(Service instance)
RegionServerServices
Service
subclass as a coprocessor endpoint to be
available for handlingregisterService
in interface MasterServices
registerService
in interface RegionServerServices
registerService
in class HRegionServer
instance
- the Service
subclass instance to expose as a coprocessor endpointtrue
if the registration was successful, false
public static HMaster constructMaster(java.lang.Class<? extends HMaster> masterClass, Configuration conf, CoordinatedStateManager cp)
masterClass
- conf
- public static void main(java.lang.String[] args)
HMasterCommandLine
public HFileCleaner getHFileCleaner()
public SnapshotManager getSnapshotManager()
getSnapshotManager
in interface MasterServices
public MasterProcedureManagerHost getMasterProcedureManagerHost()
getMasterProcedureManagerHost
in interface MasterServices
public void createNamespace(NamespaceDescriptor descriptor) throws java.io.IOException
MasterServices
createNamespace
in interface MasterServices
descriptor
- descriptor which describes the new namespacejava.io.IOException
public void modifyNamespace(NamespaceDescriptor descriptor) throws java.io.IOException
MasterServices
modifyNamespace
in interface MasterServices
descriptor
- descriptor which updates the existing namespacejava.io.IOException
public void deleteNamespace(java.lang.String name) throws java.io.IOException
MasterServices
deleteNamespace
in interface MasterServices
name
- namespace namejava.io.IOException
public NamespaceDescriptor getNamespaceDescriptor(java.lang.String name) throws java.io.IOException
MasterServices
getNamespaceDescriptor
in interface MasterServices
name
- name of namespace descriptorjava.io.IOException
public java.util.List<NamespaceDescriptor> listNamespaceDescriptors() throws java.io.IOException
MasterServices
listNamespaceDescriptors
in interface MasterServices
java.io.IOException
public boolean abortProcedure(long procId, boolean mayInterruptIfRunning) throws java.io.IOException
MasterServices
abortProcedure
in interface MasterServices
procId
- ID of the proceduremayInterruptIfRunning
- if the proc completed at least one step, should it be aborted?java.io.IOException
public java.util.List<ProcedureInfo> listProcedures() throws java.io.IOException
MasterServices
listProcedures
in interface MasterServices
java.io.IOException
public java.util.List<HTableDescriptor> listTableDescriptorsByNamespace(java.lang.String name) throws java.io.IOException
MasterServices
listTableDescriptorsByNamespace
in interface MasterServices
name
- namespace namejava.io.IOException
public java.util.List<TableName> listTableNamesByNamespace(java.lang.String name) throws java.io.IOException
MasterServices
listTableNamesByNamespace
in interface MasterServices
name
- namespace namejava.io.IOException
public Pair<java.lang.Long,java.lang.String> backupTables(BackupType type, java.util.List<TableName> tableList, java.lang.String targetRootDir, int workers, long bandwidth) throws java.io.IOException
MasterServices
backupTables
in interface MasterServices
type
- whether the backup is full or incrementaltableList
- list of tables to backuptargetRootDir
- root dir for saving the backupworkers
- number of paralle workers. -1 - system definedbandwidth
- bandwidth per worker in MB per sec. -1 - unlimitedjava.io.IOException
public java.util.List<HTableDescriptor> listTableDescriptors(java.lang.String namespace, java.lang.String regex, java.util.List<TableName> tableNameList, boolean includeSysTables) throws java.io.IOException
namespace
- the namespace to query, or null if querying for allregex
- The regular expression to match against, or null if querying for alltableNameList
- the list of table names, or null if querying for allincludeSysTables
- False to match only against userspace tablesjava.io.IOException
public java.util.List<TableName> listTableNames(java.lang.String namespace, java.lang.String regex, boolean includeSysTables) throws java.io.IOException
regex
- The regular expression to match against, or null if querying for allnamespace
- the namespace to query, or null if querying for allincludeSysTables
- False to match only against userspace tablesjava.io.IOException
public long getLastMajorCompactionTimestamp(TableName table) throws java.io.IOException
getLastMajorCompactionTimestamp
in interface MasterServices
java.io.IOException
public long getLastMajorCompactionTimestampForRegion(byte[] regionName) throws java.io.IOException
getLastMajorCompactionTimestampForRegion
in interface MasterServices
java.io.IOException
public AdminProtos.GetRegionInfoResponse.CompactionState getMobCompactionState(TableName tableName)
tableName
- The current table name.public void reportMobCompactionStart(TableName tableName) throws java.io.IOException
java.io.IOException
public void reportMobCompactionEnd(TableName tableName) throws java.io.IOException
java.io.IOException
public void requestMobCompaction(TableName tableName, java.util.List<HColumnDescriptor> columns, boolean allFiles) throws java.io.IOException
tableName
- The table the compact.columns
- The compacted columns.allFiles
- Whether add all mob files into the compaction.java.io.IOException
public boolean isBalancerOn()
LoadBalancerTracker
. If the balancer is not initialized,
false is returned.public boolean isNormalizerOn()
RegionNormalizerTracker
. If it's not initialized,
false is returned.public boolean isSplitOrMergeEnabled(Admin.MasterSwitchType switchType)
SplitOrMergeTracker
. If it is not initialized,
false is returned. If switchType is illegal, false will return.switchType
- see Admin.MasterSwitchType
public java.lang.String getLoadBalancerClassName()
LoadBalancer
class name. If none is set, a default is returned.LoadBalancer
in use.public RegionNormalizerTracker getRegionNormalizerTracker()
public SplitOrMergeTracker getSplitOrMergeTracker()
public LoadBalancer getLoadBalancer()
getLoadBalancer
in interface MasterServices
public TableStateManager getTableStateManager()
getTableStateManager
in interface MasterServices
public QuotaObserverChore getQuotaObserverChore()
public SpaceQuotaSnapshotNotifier getSpaceQuotaSnapshotNotifier()