Package org.apache.hadoop.hbase.master

Interface MasterServices

All Superinterfaces:

Abortable, Server, Stoppable

All Known Implementing Classes:

HMaster, HMasterCommandLine.LocalHMaster

@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

Modifier and Type	Method	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
long	flushTable(TableName tableName, List<byte[]> columnFamilies, long nonceGroup, long nonce)	Flush an existing table
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
HbckChore	getHbckChore()	Returns Master's instance of HbckChore
ProcedureEvent<?>	getInitializedEvent()	Returns Tripped when Master has finished initialization.
long	getLastMajorCompactionTimestamp(TableName table)
long	getLastMajorCompactionTimestampForRegion(byte[] regionName)	Returns the timestamp of the last successful major compaction for the passed region or 0 if no HFile resulting from a major compaction exists
LoadBalancer	getLoadBalancer()	Returns load balancer
LockManager	getLockManager()	Returns LockManager to lock namespaces/tables/regions.
List<LockedResource>	getLocks()	Get locks
long	getMasterActiveTime()	Returns timestamp in millis when this master became the active one.
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)
ReplicationLogCleanerBarrier	getReplicationLogCleanerBarrier()	Returns the ReplicationLogCleanerBarrier.
ReplicationPeerConfig	getReplicationPeerConfig(String peerId)	Returns the configured ReplicationPeerConfig for the specified peer
ReplicationPeerManager	getReplicationPeerManager()	Returns the ReplicationPeerManager.
RSGroupInfoManager	getRSGroupInfoManager()	Returns the RSGroupInfoManager
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
Semaphore	getSyncReplicationPeerLock()	Returns the SyncReplicationPeerLock.
SyncReplicationReplayWALManager	getSyncReplicationReplayWALManager()	Returns the SyncReplicationReplayWALManager.
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	isBalancerOn()	Queries the state of the LoadBalancerStateStore.
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	isReplicationPeerModificationEnabled()
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
default long	modifyTable(TableName tableName, TableDescriptor descriptor, long nonceGroup, long nonce)	Modify the descriptor of an existing table
long	modifyTable(TableName tableName, TableDescriptor descriptor, long nonceGroup, long nonce, boolean reopenRegions)	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(org.apache.hbase.thirdparty.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
boolean	replicationPeerModificationSwitch(boolean on)
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	transitReplicationPeerSyncReplicationState(String peerId, SyncReplicationState clusterState)	Set current cluster state for a synchronous replication peer.
long	truncateRegion(RegionInfo regionInfo, long nonceGroup, long nonce)	Truncate 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.Abortable

abort, abort, isAborted

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

createConnection, getAsyncClusterConnection, getAsyncConnection, getChoreService, getConfiguration, getConnection, getCoordinatedStateManager, getFileSystem, getServerName, getZooKeeper, isStopping

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

isStopped, stop

Method Details

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

getHbckChore

HbckChore getHbckChore()

Returns Master's instance of HbckChore

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.

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

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

Throws:

IOException

modifyTable

default 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

Throws:

IOException

modifyTable

long modifyTable(TableName tableName,
 TableDescriptor descriptor,
 long nonceGroup,
 long nonce,
 boolean reopenRegions)
          throws IOException

Modify the descriptor of an existing table

Parameters:

tableName - The table name

descriptor - The updated table descriptor

reopenRegions - Whether to reopen regions after modifying the table descriptor

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

Throws:

IOException

disableTable

long disableTable(TableName tableName,
 long nonceGroup,
 long nonce)
           throws IOException

Disable an existing table

Parameters:

tableName - The table name

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

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

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

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

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

Throws:

IOException

getTableDescriptors

TableDescriptors getTableDescriptors()

Returns Return table descriptors implementation.

registerService

boolean registerService(org.apache.hbase.thirdparty.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

getMasterActiveTime

long getMasterActiveTime()

Returns timestamp in millis when this master became 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

Throws:

IOException

getProcedures

List<Procedure<?>> getProcedures()
                          throws IOException

Get procedures

Returns:

procedure list

Throws:

IOException

getLocks

List<LockedResource> getLocks()
                       throws IOException

Get locks

Returns:

lock list

Throws:

IOException

listTableDescriptorsByNamespace

List<TableDescriptor> listTableDescriptorsByNamespace(String name)
                                               throws IOException

Get list of table descriptors by namespace

Parameters:

name - namespace name

Throws:

IOException

listTableNamesByNamespace

List<TableName> listTableNamesByNamespace(String name)
                                   throws IOException

Get list of table names by namespace

Parameters:

name - namespace name

Returns:

table names

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

Throws:

IOException

getLastMajorCompactionTimestampForRegion

long getLastMajorCompactionTimestampForRegion(byte[] regionName)
                                       throws IOException

Returns the timestamp of the last successful major compaction for the passed region or 0 if no HFile resulting from a major compaction exists

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.

getReplicationLogCleanerBarrier

ReplicationLogCleanerBarrier getReplicationLogCleanerBarrier()

Returns the ReplicationLogCleanerBarrier. It will be used at multiple places so we put it in MasterServices directly.

getSyncReplicationPeerLock

Semaphore getSyncReplicationPeerLock()

Returns the SyncReplicationPeerLock.

getSyncReplicationReplayWALManager

SyncReplicationReplayWALManager getSyncReplicationReplayWALManager()

Returns the SyncReplicationReplayWALManager.

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

transitReplicationPeerSyncReplicationState

long transitReplicationPeerSyncReplicationState(String peerId,
 SyncReplicationState clusterState)
                                         throws ReplicationException,
IOException

Set current cluster state for a synchronous replication peer.

Parameters:

peerId - a short name that identifies the peer

clusterState - state of current cluster

Throws:

ReplicationException

IOException

replicationPeerModificationSwitch

boolean replicationPeerModificationSwitch(boolean on)
                                   throws IOException

Throws:

IOException

isReplicationPeerModificationEnabled

boolean isReplicationPeerModificationEnabled()

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.

getRSGroupInfoManager

RSGroupInfoManager getRSGroupInfoManager()

Returns the RSGroupInfoManager

isBalancerOn

boolean isBalancerOn()

Queries the state of the LoadBalancerStateStore. If the balancer is not initialized, false is returned.

Returns:

The state of the load balancer, or false if the load balancer isn't defined.

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

flushTable

long flushTable(TableName tableName,
 List<byte[]> columnFamilies,
 long nonceGroup,
 long nonce)
         throws IOException

Flush an existing table

Parameters:

tableName - The table name

columnFamilies - The column families to flush

nonceGroup - the nonce group

nonce - the nonce

Returns:

the flush procedure id

Throws:

IOException

truncateRegion

long truncateRegion(RegionInfo regionInfo,
 long nonceGroup,
 long nonce)
             throws IOException

Truncate region

Parameters:

regionInfo - region to be truncated

nonceGroup - the nonce group

nonce - the nonce

Returns:

procedure Id

Throws:

IOException