org.apache.hadoop.hbase.rsgroup

Class VerifyingRSGroupAdmin

java.lang.Object

org.apache.hadoop.hbase.rsgroup.VerifyingRSGroupAdmin

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.Abortable, org.apache.hadoop.hbase.client.Admin

@InterfaceAudience.Private
public class VerifyingRSGroupAdmin
extends Object
implements org.apache.hadoop.hbase.client.Admin, Closeable

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.client.Admin	admin
private org.apache.hadoop.hbase.client.Connection	conn
private org.apache.hadoop.hbase.zookeeper.ZKWatcher	zkw

Constructor Summary

Constructors

Constructor and Description
VerifyingRSGroupAdmin(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	abort(String why, Throwable e)
Future<Boolean>	abortProcedureAsync(long procId, boolean mayInterruptIfRunning)
Future<Void>	addColumnFamilyAsync(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor columnFamily)
Future<Void>	addReplicationPeerAsync(String peerId, org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig, boolean enabled)
void	addRSGroup(String groupName)
void	assign(byte[] regionName)
org.apache.hadoop.hbase.client.BalanceResponse	balance(org.apache.hadoop.hbase.client.BalanceRequest request)
org.apache.hadoop.hbase.client.BalanceResponse	balanceRSGroup(String groupName, org.apache.hadoop.hbase.client.BalanceRequest request)
boolean	balancerSwitch(boolean onOrOff, boolean synchronous)
boolean	catalogJanitorSwitch(boolean onOrOff)
boolean	cleanerChoreSwitch(boolean onOrOff)
org.apache.hadoop.hbase.CacheEvictionStats	clearBlockCache(org.apache.hadoop.hbase.TableName tableName)
void	clearCompactionQueues(org.apache.hadoop.hbase.ServerName serverName, Set<String> queues)
List<org.apache.hadoop.hbase.ServerName>	clearDeadServers(List<org.apache.hadoop.hbase.ServerName> servers)
List<Boolean>	clearSlowLogResponses(Set<org.apache.hadoop.hbase.ServerName> serverNames)
Future<Void>	cloneSnapshotAsync(String snapshotName, org.apache.hadoop.hbase.TableName tableName, boolean restoreAcl, String customSFT)
void	cloneTableSchema(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.TableName newTableName, boolean preserveSplits)
void	close()
void	compact(org.apache.hadoop.hbase.TableName tableName)
void	compact(org.apache.hadoop.hbase.TableName tableName, byte[] columnFamily)
void	compact(org.apache.hadoop.hbase.TableName tableName, byte[] columnFamily, org.apache.hadoop.hbase.client.CompactType compactType)
void	compact(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.CompactType compactType)
Map<org.apache.hadoop.hbase.ServerName,Boolean>	compactionSwitch(boolean switchState, List<String> serverNamesList)
void	compactRegion(byte[] regionName)
void	compactRegion(byte[] regionName, byte[] columnFamily)
void	compactRegionServer(org.apache.hadoop.hbase.ServerName serverName)
org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel	coprocessorService()
org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel	coprocessorService(org.apache.hadoop.hbase.ServerName serverName)
Future<Void>	createNamespaceAsync(org.apache.hadoop.hbase.NamespaceDescriptor descriptor)
void	createTable(org.apache.hadoop.hbase.client.TableDescriptor desc, byte[] startKey, byte[] endKey, int numRegions)
Future<Void>	createTableAsync(org.apache.hadoop.hbase.client.TableDescriptor desc)
Future<Void>	createTableAsync(org.apache.hadoop.hbase.client.TableDescriptor desc, byte[][] splitKeys)
void	decommissionRegionServers(List<org.apache.hadoop.hbase.ServerName> servers, boolean offload)
Future<Void>	deleteColumnFamilyAsync(org.apache.hadoop.hbase.TableName tableName, byte[] columnFamily)
Future<Void>	deleteNamespaceAsync(String name)
void	deleteSnapshot(String snapshotName)
void	deleteSnapshots(Pattern pattern)
Future<Void>	deleteTableAsync(org.apache.hadoop.hbase.TableName tableName)
void	deleteTableSnapshots(Pattern tableNamePattern, Pattern snapshotNamePattern)
Future<Void>	disableReplicationPeerAsync(String peerId)
Future<Void>	disableTableAsync(org.apache.hadoop.hbase.TableName tableName)
void	disableTableReplication(org.apache.hadoop.hbase.TableName tableName)
Future<Void>	enableReplicationPeerAsync(String peerId)
Future<Void>	enableTableAsync(org.apache.hadoop.hbase.TableName tableName)
void	enableTableReplication(org.apache.hadoop.hbase.TableName tableName)
boolean	exceedThrottleQuotaSwitch(boolean enable)
void	execProcedure(String signature, String instance, Map<String,String> props)
byte[]	execProcedureWithReturn(String signature, String instance, Map<String,String> props)
void	flush(org.apache.hadoop.hbase.TableName tableName)
void	flush(org.apache.hadoop.hbase.TableName tableName, byte[] columnFamily)
void	flush(org.apache.hadoop.hbase.TableName tableName, List<byte[]> columnFamilies)
void	flushMasterStore()
void	flushRegion(byte[] regionName)
void	flushRegion(byte[] regionName, byte[] columnFamily)
void	flushRegionServer(org.apache.hadoop.hbase.ServerName serverName)
List<String>	getCachedFilesList(org.apache.hadoop.hbase.ServerName serverName)
org.apache.hadoop.hbase.ClusterMetrics	getClusterMetrics(EnumSet<org.apache.hadoop.hbase.ClusterMetrics.Option> options)
org.apache.hadoop.hbase.client.CompactionState	getCompactionState(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.client.CompactionState	getCompactionState(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.CompactType compactType)
org.apache.hadoop.hbase.client.CompactionState	getCompactionStateForRegion(byte[] regionName)
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.util.Pair<List<String>,List<org.apache.hadoop.hbase.TableName>>	getConfiguredNamespacesAndTablesInRSGroup(String groupName)
org.apache.hadoop.hbase.client.Connection	getConnection()
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotView	getCurrentSpaceQuotaSnapshot(String namespace)
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotView	getCurrentSpaceQuotaSnapshot(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.client.TableDescriptor	getDescriptor(org.apache.hadoop.hbase.TableName tableName)
long	getLastMajorCompactionTimestamp(org.apache.hadoop.hbase.TableName tableName)
long	getLastMajorCompactionTimestampForRegion(byte[] regionName)
String	getLocks()
List<org.apache.hadoop.hbase.client.LogEntry>	getLogEntries(Set<org.apache.hadoop.hbase.ServerName> serverNames, String logType, org.apache.hadoop.hbase.client.ServerType serverType, int limit, Map<String,Object> filterParams)
org.apache.hadoop.hbase.NamespaceDescriptor	getNamespaceDescriptor(String name)
int	getOperationTimeout()
String	getProcedures()
List<org.apache.hadoop.hbase.quotas.QuotaSettings>	getQuota(org.apache.hadoop.hbase.quotas.QuotaFilter filter)
List<org.apache.hadoop.hbase.RegionMetrics>	getRegionMetrics(org.apache.hadoop.hbase.ServerName serverName)
List<org.apache.hadoop.hbase.RegionMetrics>	getRegionMetrics(org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.TableName tableName)
List<org.apache.hadoop.hbase.client.RegionInfo>	getRegions(org.apache.hadoop.hbase.ServerName serverName)
List<org.apache.hadoop.hbase.client.RegionInfo>	getRegions(org.apache.hadoop.hbase.TableName tableName)
Map<org.apache.hadoop.hbase.TableName,? extends org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotView>	getRegionServerSpaceQuotaSnapshots(org.apache.hadoop.hbase.ServerName serverName)
org.apache.hadoop.hbase.replication.ReplicationPeerConfig	getReplicationPeerConfig(String peerId)
org.apache.hadoop.hbase.rsgroup.RSGroupInfo	getRSGroup(org.apache.hadoop.hbase.net.Address hostPort)
org.apache.hadoop.hbase.rsgroup.RSGroupInfo	getRSGroup(String groupName)
org.apache.hadoop.hbase.rsgroup.RSGroupInfo	getRSGroup(org.apache.hadoop.hbase.TableName tableName)
List<org.apache.hadoop.hbase.client.security.SecurityCapability>	getSecurityCapabilities()
Map<org.apache.hadoop.hbase.TableName,Long>	getSpaceQuotaTableSizes()
int	getSyncWaitTimeout()
List<org.apache.hadoop.hbase.security.access.UserPermission>	getUserPermissions(org.apache.hadoop.hbase.security.access.GetUserPermissionsRequest getUserPermissionsRequest)
void	grant(org.apache.hadoop.hbase.security.access.UserPermission userPermission, boolean mergeExistingPermissions)
List<Boolean>	hasUserPermissions(String userName, List<org.apache.hadoop.hbase.security.access.Permission> permissions)
boolean	isAborted()
boolean	isBalancerEnabled()
boolean	isCatalogJanitorEnabled()
boolean	isCleanerChoreEnabled()
boolean	isMasterInMaintenanceMode()
boolean	isMergeEnabled()
boolean	isNormalizerEnabled()
boolean	isProcedureFinished(String signature, String instance, Map<String,String> props)
boolean	isReplicationPeerEnabled(String peerId)
boolean	isReplicationPeerModificationEnabled()
boolean	isRpcThrottleEnabled()
boolean	isSnapshotCleanupEnabled()
boolean	isSnapshotFinished(org.apache.hadoop.hbase.client.SnapshotDescription snapshot)
boolean	isSplitEnabled()
boolean	isTableAvailable(org.apache.hadoop.hbase.TableName tableName)
boolean	isTableDisabled(org.apache.hadoop.hbase.TableName tableName)
boolean	isTableEnabled(org.apache.hadoop.hbase.TableName tableName)
List<org.apache.hadoop.hbase.ServerName>	listDecommissionedRegionServers()
org.apache.hadoop.hbase.NamespaceDescriptor[]	listNamespaceDescriptors()
String[]	listNamespaces()
List<org.apache.hadoop.hbase.client.replication.TableCFs>	listReplicatedTableCFs()
List<org.apache.hadoop.hbase.replication.ReplicationPeerDescription>	listReplicationPeers()
List<org.apache.hadoop.hbase.replication.ReplicationPeerDescription>	listReplicationPeers(Pattern pattern)
List<org.apache.hadoop.hbase.rsgroup.RSGroupInfo>	listRSGroups()
List<org.apache.hadoop.hbase.client.SnapshotDescription>	listSnapshots()
List<org.apache.hadoop.hbase.client.SnapshotDescription>	listSnapshots(Pattern pattern)
List<org.apache.hadoop.hbase.client.TableDescriptor>	listTableDescriptors()
List<org.apache.hadoop.hbase.client.TableDescriptor>	listTableDescriptors(boolean includeSysTables)
List<org.apache.hadoop.hbase.client.TableDescriptor>	listTableDescriptors(List<org.apache.hadoop.hbase.TableName> tableNames)
List<org.apache.hadoop.hbase.client.TableDescriptor>	listTableDescriptors(Pattern pattern, boolean includeSysTables)
List<org.apache.hadoop.hbase.client.TableDescriptor>	listTableDescriptorsByNamespace(byte[] name)
List<org.apache.hadoop.hbase.client.TableDescriptor>	listTableDescriptorsByState(boolean isEnabled)
org.apache.hadoop.hbase.TableName[]	listTableNames()
org.apache.hadoop.hbase.TableName[]	listTableNames(Pattern pattern, boolean includeSysTables)
org.apache.hadoop.hbase.TableName[]	listTableNamesByNamespace(String name)
List<org.apache.hadoop.hbase.TableName>	listTableNamesByState(boolean isEnabled)
List<org.apache.hadoop.hbase.TableName>	listTablesInRSGroup(String groupName)
List<org.apache.hadoop.hbase.client.SnapshotDescription>	listTableSnapshots(Pattern tableNamePattern, Pattern snapshotNamePattern)
void	majorCompact(org.apache.hadoop.hbase.TableName tableName)
void	majorCompact(org.apache.hadoop.hbase.TableName tableName, byte[] columnFamily)
void	majorCompact(org.apache.hadoop.hbase.TableName tableName, byte[] columnFamily, org.apache.hadoop.hbase.client.CompactType compactType)
void	majorCompact(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.CompactType compactType)
void	majorCompactRegion(byte[] regionName)
void	majorCompactRegion(byte[] regionName, byte[] columnFamily)
void	majorCompactRegionServer(org.apache.hadoop.hbase.ServerName serverName)
Future<Void>	mergeRegionsAsync(byte[][] nameofRegionsToMerge, boolean forcible)
boolean	mergeSwitch(boolean enabled, boolean synchronous)
Future<Void>	modifyColumnFamilyAsync(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor columnFamily)
Future<Void>	modifyColumnFamilyStoreFileTrackerAsync(org.apache.hadoop.hbase.TableName tableName, byte[] family, String dstSFT)
Future<Void>	modifyNamespaceAsync(org.apache.hadoop.hbase.NamespaceDescriptor descriptor)
Future<Void>	modifyTableAsync(org.apache.hadoop.hbase.client.TableDescriptor td)
Future<Void>	modifyTableAsync(org.apache.hadoop.hbase.client.TableDescriptor td, boolean reopenRegions)
Future<Void>	modifyTableStoreFileTrackerAsync(org.apache.hadoop.hbase.TableName tableName, String dstSFT)
void	move(byte[] encodedRegionName)
void	move(byte[] encodedRegionName, org.apache.hadoop.hbase.ServerName destServerName)
void	moveServersToRSGroup(Set<org.apache.hadoop.hbase.net.Address> servers, String targetGroup)
boolean	normalize(org.apache.hadoop.hbase.client.NormalizeTableFilterParams ntfp)
boolean	normalizerSwitch(boolean on)
void	offline(byte[] regionName)
void	recommissionRegionServer(org.apache.hadoop.hbase.ServerName server, List<byte[]> encodedRegionNames)
Future<Void>	removeReplicationPeerAsync(String peerId)
void	removeRSGroup(String groupName)
void	removeServersFromRSGroup(Set<org.apache.hadoop.hbase.net.Address> servers)
void	renameRSGroup(String oldName, String newName)
boolean	replicationPeerModificationSwitch(boolean on, boolean drainProcedures)
void	restoreSnapshot(String snapshotName)
void	restoreSnapshot(String snapshotName, boolean takeFailSafeSnapshot, boolean restoreAcl)
void	revoke(org.apache.hadoop.hbase.security.access.UserPermission userPermission)
void	rollWALWriter(org.apache.hadoop.hbase.ServerName serverName)
int	runCatalogJanitor()
boolean	runCleanerChore()
void	setQuota(org.apache.hadoop.hbase.quotas.QuotaSettings quota)
void	setRSGroup(Set<org.apache.hadoop.hbase.TableName> tables, String groupName)
void	shutdown()
void	snapshot(org.apache.hadoop.hbase.client.SnapshotDescription snapshot)
Future<Void>	snapshotAsync(org.apache.hadoop.hbase.client.SnapshotDescription snapshot)
boolean	snapshotCleanupSwitch(boolean on, boolean synchronous)
void	split(org.apache.hadoop.hbase.TableName tableName)
void	split(org.apache.hadoop.hbase.TableName tableName, byte[] splitPoint)
Future<Void>	splitRegionAsync(byte[] regionName)
Future<Void>	splitRegionAsync(byte[] regionName, byte[] splitPoint)
boolean	splitSwitch(boolean enabled, boolean synchronous)
void	stopMaster()
void	stopRegionServer(String hostnamePort)
boolean	switchRpcThrottle(boolean enable)
boolean	tableExists(org.apache.hadoop.hbase.TableName tableName)
Future<Void>	transitReplicationPeerSyncReplicationStateAsync(String peerId, org.apache.hadoop.hbase.replication.SyncReplicationState state)
void	truncateRegion(byte[] regionName)
Future<Void>	truncateRegionAsync(byte[] regionName)
Future<Void>	truncateTableAsync(org.apache.hadoop.hbase.TableName tableName, boolean preserveSplits)
void	unassign(byte[] regionName)
void	updateConfiguration()
void	updateConfiguration(org.apache.hadoop.hbase.ServerName server)
void	updateConfiguration(String groupName)
Future<Void>	updateReplicationPeerConfigAsync(String peerId, org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig)
void	updateRSGroupConfig(String groupName, Map<String,String> configuration)
private void	verify()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.client.Admin

abortProcedure, addColumnFamily, addReplicationPeer, addReplicationPeer, addReplicationPeerAsync, appendReplicationPeerTableCFs, balance, balance, balanceRSGroup, cloneSnapshot, cloneSnapshot, cloneSnapshot, cloneSnapshotAsync, cloneSnapshotAsync, createNamespace, createTable, createTable, deleteColumnFamily, deleteNamespace, deleteTable, disableReplicationPeer, disableTable, enableReplicationPeer, enableTable, getBackupMasters, getClusterMetrics, getMaster, getMasterCoprocessorNames, getMasterInfoPort, getRegionServers, getRegionServers, getReplicationPeerSyncReplicationState, getSlowLogResponses, hasUserPermissions, listDeadServers, listTableDescriptors, listTableNames, listUnknownServers, mergeRegionsAsync, modifyColumnFamily, modifyColumnFamilyStoreFileTracker, modifyNamespace, modifyTable, modifyTableStoreFileTracker, move, normalize, removeReplicationPeer, removeReplicationPeerTableCFs, replicationPeerModificationSwitch, restoreSnapshot, snapshot, snapshot, snapshot, snapshot, transitReplicationPeerSyncReplicationState, truncateTable, unassign, updateReplicationPeerConfig

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

abort

Field Detail

conn

private final org.apache.hadoop.hbase.client.Connection conn

admin

private final org.apache.hadoop.hbase.client.Admin admin

zkw

private final org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw

Constructor Detail

VerifyingRSGroupAdmin

public VerifyingRSGroupAdmin(org.apache.hadoop.conf.Configuration conf)
                      throws IOException

Throws:

IOException

Method Detail

getOperationTimeout

public int getOperationTimeout()

Specified by:

getOperationTimeout in interface org.apache.hadoop.hbase.client.Admin

getSyncWaitTimeout

public int getSyncWaitTimeout()

Specified by:

getSyncWaitTimeout in interface org.apache.hadoop.hbase.client.Admin

abort

public void abort(String why,
                  Throwable e)

Specified by:

abort in interface org.apache.hadoop.hbase.Abortable

Specified by:

abort in interface org.apache.hadoop.hbase.client.Admin

isAborted

public boolean isAborted()

Specified by:

isAborted in interface org.apache.hadoop.hbase.Abortable

Specified by:

isAborted in interface org.apache.hadoop.hbase.client.Admin

getConnection

public org.apache.hadoop.hbase.client.Connection getConnection()

Specified by:

getConnection in interface org.apache.hadoop.hbase.client.Admin

tableExists

public boolean tableExists(org.apache.hadoop.hbase.TableName tableName)
                    throws IOException

Specified by:

tableExists in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableDescriptors

public List<org.apache.hadoop.hbase.client.TableDescriptor> listTableDescriptors()
                                                                          throws IOException

Specified by:

listTableDescriptors in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableDescriptors

public List<org.apache.hadoop.hbase.client.TableDescriptor> listTableDescriptors(boolean includeSysTables)
                                                                          throws IOException

Specified by:

listTableDescriptors in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableDescriptors

public List<org.apache.hadoop.hbase.client.TableDescriptor> listTableDescriptors(Pattern pattern,
                                                                                 boolean includeSysTables)
                                                                          throws IOException

Specified by:

listTableDescriptors in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableDescriptorsByState

public List<org.apache.hadoop.hbase.client.TableDescriptor> listTableDescriptorsByState(boolean isEnabled)
                                                                                 throws IOException

Specified by:

listTableDescriptorsByState in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableNames

public org.apache.hadoop.hbase.TableName[] listTableNames()
                                                   throws IOException

Specified by:

listTableNames in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableNames

public org.apache.hadoop.hbase.TableName[] listTableNames(Pattern pattern,
                                                          boolean includeSysTables)
                                                   throws IOException

Specified by:

listTableNames in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableNamesByState

public List<org.apache.hadoop.hbase.TableName> listTableNamesByState(boolean isEnabled)
                                                              throws IOException

Specified by:

listTableNamesByState in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getDescriptor

public org.apache.hadoop.hbase.client.TableDescriptor getDescriptor(org.apache.hadoop.hbase.TableName tableName)
                                                             throws org.apache.hadoop.hbase.TableNotFoundException,
                                                                    IOException

Specified by:

getDescriptor in interface org.apache.hadoop.hbase.client.Admin

Throws:

org.apache.hadoop.hbase.TableNotFoundException

IOException

createTable

public void createTable(org.apache.hadoop.hbase.client.TableDescriptor desc,
                        byte[] startKey,
                        byte[] endKey,
                        int numRegions)
                 throws IOException

Specified by:

createTable in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

createTableAsync

public Future<Void> createTableAsync(org.apache.hadoop.hbase.client.TableDescriptor desc)
                              throws IOException

Specified by:

createTableAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

createTableAsync

public Future<Void> createTableAsync(org.apache.hadoop.hbase.client.TableDescriptor desc,
                                     byte[][] splitKeys)
                              throws IOException

Specified by:

createTableAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

deleteTableAsync

public Future<Void> deleteTableAsync(org.apache.hadoop.hbase.TableName tableName)
                              throws IOException

Specified by:

deleteTableAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

truncateTableAsync

public Future<Void> truncateTableAsync(org.apache.hadoop.hbase.TableName tableName,
                                       boolean preserveSplits)
                                throws IOException

Specified by:

truncateTableAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

enableTableAsync

public Future<Void> enableTableAsync(org.apache.hadoop.hbase.TableName tableName)
                              throws IOException

Specified by:

enableTableAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

disableTableAsync

public Future<Void> disableTableAsync(org.apache.hadoop.hbase.TableName tableName)
                               throws IOException

Specified by:

disableTableAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isTableEnabled

public boolean isTableEnabled(org.apache.hadoop.hbase.TableName tableName)
                       throws IOException

Specified by:

isTableEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isTableDisabled

public boolean isTableDisabled(org.apache.hadoop.hbase.TableName tableName)
                        throws IOException

Specified by:

isTableDisabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isTableAvailable

public boolean isTableAvailable(org.apache.hadoop.hbase.TableName tableName)
                         throws IOException

Specified by:

isTableAvailable in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

addColumnFamilyAsync

public Future<Void> addColumnFamilyAsync(org.apache.hadoop.hbase.TableName tableName,
                                         org.apache.hadoop.hbase.client.ColumnFamilyDescriptor columnFamily)
                                  throws IOException

Specified by:

addColumnFamilyAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

deleteColumnFamilyAsync

public Future<Void> deleteColumnFamilyAsync(org.apache.hadoop.hbase.TableName tableName,
                                            byte[] columnFamily)
                                     throws IOException

Specified by:

deleteColumnFamilyAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

modifyColumnFamilyAsync

public Future<Void> modifyColumnFamilyAsync(org.apache.hadoop.hbase.TableName tableName,
                                            org.apache.hadoop.hbase.client.ColumnFamilyDescriptor columnFamily)
                                     throws IOException

Specified by:

modifyColumnFamilyAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getRegions

public List<org.apache.hadoop.hbase.client.RegionInfo> getRegions(org.apache.hadoop.hbase.ServerName serverName)
                                                           throws IOException

Specified by:

getRegions in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

flush

public void flush(org.apache.hadoop.hbase.TableName tableName)
           throws IOException

Specified by:

flush in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

flush

public void flush(org.apache.hadoop.hbase.TableName tableName,
                  byte[] columnFamily)
           throws IOException

Specified by:

flush in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

flush

public void flush(org.apache.hadoop.hbase.TableName tableName,
                  List<byte[]> columnFamilies)
           throws IOException

Specified by:

flush in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

flushRegion

public void flushRegion(byte[] regionName)
                 throws IOException

Specified by:

flushRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

flushRegion

public void flushRegion(byte[] regionName,
                        byte[] columnFamily)
                 throws IOException

Specified by:

flushRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

flushRegionServer

public void flushRegionServer(org.apache.hadoop.hbase.ServerName serverName)
                       throws IOException

Specified by:

flushRegionServer in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

compact

public void compact(org.apache.hadoop.hbase.TableName tableName)
             throws IOException

Specified by:

compact in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

compactRegion

public void compactRegion(byte[] regionName)
                   throws IOException

Specified by:

compactRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

compact

public void compact(org.apache.hadoop.hbase.TableName tableName,
                    byte[] columnFamily)
             throws IOException

Specified by:

compact in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

compactRegion

public void compactRegion(byte[] regionName,
                          byte[] columnFamily)
                   throws IOException

Specified by:

compactRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

compact

public void compact(org.apache.hadoop.hbase.TableName tableName,
                    org.apache.hadoop.hbase.client.CompactType compactType)
             throws IOException,
                    InterruptedException

Specified by:

compact in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

InterruptedException

compact

public void compact(org.apache.hadoop.hbase.TableName tableName,
                    byte[] columnFamily,
                    org.apache.hadoop.hbase.client.CompactType compactType)
             throws IOException,
                    InterruptedException

Specified by:

compact in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

InterruptedException

majorCompact

public void majorCompact(org.apache.hadoop.hbase.TableName tableName)
                  throws IOException

Specified by:

majorCompact in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

majorCompactRegion

public void majorCompactRegion(byte[] regionName)
                        throws IOException

Specified by:

majorCompactRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

majorCompact

public void majorCompact(org.apache.hadoop.hbase.TableName tableName,
                         byte[] columnFamily)
                  throws IOException

Specified by:

majorCompact in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

majorCompactRegion

public void majorCompactRegion(byte[] regionName,
                               byte[] columnFamily)
                        throws IOException

Specified by:

majorCompactRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

majorCompact

public void majorCompact(org.apache.hadoop.hbase.TableName tableName,
                         org.apache.hadoop.hbase.client.CompactType compactType)
                  throws IOException,
                         InterruptedException

Specified by:

majorCompact in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

InterruptedException

majorCompact

public void majorCompact(org.apache.hadoop.hbase.TableName tableName,
                         byte[] columnFamily,
                         org.apache.hadoop.hbase.client.CompactType compactType)
                  throws IOException,
                         InterruptedException

Specified by:

majorCompact in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

InterruptedException

compactionSwitch

public Map<org.apache.hadoop.hbase.ServerName,Boolean> compactionSwitch(boolean switchState,
                                                                        List<String> serverNamesList)
                                                                 throws IOException

Specified by:

compactionSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

compactRegionServer

public void compactRegionServer(org.apache.hadoop.hbase.ServerName serverName)
                         throws IOException

Specified by:

compactRegionServer in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

majorCompactRegionServer

public void majorCompactRegionServer(org.apache.hadoop.hbase.ServerName serverName)
                              throws IOException

Specified by:

majorCompactRegionServer in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

move

public void move(byte[] encodedRegionName)
          throws IOException

Specified by:

move in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

move

public void move(byte[] encodedRegionName,
                 org.apache.hadoop.hbase.ServerName destServerName)
          throws IOException

Specified by:

move in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

assign

public void assign(byte[] regionName)
            throws IOException

Specified by:

assign in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

unassign

public void unassign(byte[] regionName)
              throws IOException

Specified by:

unassign in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

offline

public void offline(byte[] regionName)
             throws IOException

Specified by:

offline in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

balancerSwitch

public boolean balancerSwitch(boolean onOrOff,
                              boolean synchronous)
                       throws IOException

Specified by:

balancerSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

balance

public org.apache.hadoop.hbase.client.BalanceResponse balance(org.apache.hadoop.hbase.client.BalanceRequest request)
                                                       throws IOException

Specified by:

balance in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isBalancerEnabled

public boolean isBalancerEnabled()
                          throws IOException

Specified by:

isBalancerEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

clearBlockCache

public org.apache.hadoop.hbase.CacheEvictionStats clearBlockCache(org.apache.hadoop.hbase.TableName tableName)
                                                           throws IOException

Specified by:

clearBlockCache in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

normalize

public boolean normalize(org.apache.hadoop.hbase.client.NormalizeTableFilterParams ntfp)
                  throws IOException

Specified by:

normalize in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isNormalizerEnabled

public boolean isNormalizerEnabled()
                            throws IOException

Specified by:

isNormalizerEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

normalizerSwitch

public boolean normalizerSwitch(boolean on)
                         throws IOException

Specified by:

normalizerSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

catalogJanitorSwitch

public boolean catalogJanitorSwitch(boolean onOrOff)
                             throws IOException

Specified by:

catalogJanitorSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

runCatalogJanitor

public int runCatalogJanitor()
                      throws IOException

Specified by:

runCatalogJanitor in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isCatalogJanitorEnabled

public boolean isCatalogJanitorEnabled()
                                throws IOException

Specified by:

isCatalogJanitorEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

cleanerChoreSwitch

public boolean cleanerChoreSwitch(boolean onOrOff)
                           throws IOException

Specified by:

cleanerChoreSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

runCleanerChore

public boolean runCleanerChore()
                        throws IOException

Specified by:

runCleanerChore in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isCleanerChoreEnabled

public boolean isCleanerChoreEnabled()
                              throws IOException

Specified by:

isCleanerChoreEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

mergeRegionsAsync

public Future<Void> mergeRegionsAsync(byte[][] nameofRegionsToMerge,
                                      boolean forcible)
                               throws IOException

Specified by:

mergeRegionsAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

split

public void split(org.apache.hadoop.hbase.TableName tableName)
           throws IOException

Specified by:

split in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

split

public void split(org.apache.hadoop.hbase.TableName tableName,
                  byte[] splitPoint)
           throws IOException

Specified by:

split in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

splitRegionAsync

public Future<Void> splitRegionAsync(byte[] regionName)
                              throws IOException

Specified by:

splitRegionAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

splitRegionAsync

public Future<Void> splitRegionAsync(byte[] regionName,
                                     byte[] splitPoint)
                              throws IOException

Specified by:

splitRegionAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

truncateRegion

public void truncateRegion(byte[] regionName)
                    throws IOException

Specified by:

truncateRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

truncateRegionAsync

public Future<Void> truncateRegionAsync(byte[] regionName)
                                 throws IOException

Specified by:

truncateRegionAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

modifyTableAsync

public Future<Void> modifyTableAsync(org.apache.hadoop.hbase.client.TableDescriptor td)
                              throws IOException

Specified by:

modifyTableAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

modifyTableAsync

public Future<Void> modifyTableAsync(org.apache.hadoop.hbase.client.TableDescriptor td,
                                     boolean reopenRegions)
                              throws IOException

Specified by:

modifyTableAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

shutdown

public void shutdown()
              throws IOException

Specified by:

shutdown in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

stopMaster

public void stopMaster()
                throws IOException

Specified by:

stopMaster in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isMasterInMaintenanceMode

public boolean isMasterInMaintenanceMode()
                                  throws IOException

Specified by:

isMasterInMaintenanceMode in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

stopRegionServer

public void stopRegionServer(String hostnamePort)
                      throws IOException

Specified by:

stopRegionServer in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getClusterMetrics

public org.apache.hadoop.hbase.ClusterMetrics getClusterMetrics(EnumSet<org.apache.hadoop.hbase.ClusterMetrics.Option> options)
                                                         throws IOException

Specified by:

getClusterMetrics in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getRegionMetrics

public List<org.apache.hadoop.hbase.RegionMetrics> getRegionMetrics(org.apache.hadoop.hbase.ServerName serverName)
                                                             throws IOException

Specified by:

getRegionMetrics in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getRegionMetrics

public List<org.apache.hadoop.hbase.RegionMetrics> getRegionMetrics(org.apache.hadoop.hbase.ServerName serverName,
                                                                    org.apache.hadoop.hbase.TableName tableName)
                                                             throws IOException

Specified by:

getRegionMetrics in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Specified by:

getConfiguration in interface org.apache.hadoop.hbase.client.Admin

createNamespaceAsync

public Future<Void> createNamespaceAsync(org.apache.hadoop.hbase.NamespaceDescriptor descriptor)
                                  throws IOException

Specified by:

createNamespaceAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

modifyNamespaceAsync

public Future<Void> modifyNamespaceAsync(org.apache.hadoop.hbase.NamespaceDescriptor descriptor)
                                  throws IOException

Specified by:

modifyNamespaceAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

deleteNamespaceAsync

public Future<Void> deleteNamespaceAsync(String name)
                                  throws IOException

Specified by:

deleteNamespaceAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getNamespaceDescriptor

public org.apache.hadoop.hbase.NamespaceDescriptor getNamespaceDescriptor(String name)
                                                                   throws org.apache.hadoop.hbase.NamespaceNotFoundException,
                                                                          IOException

Specified by:

getNamespaceDescriptor in interface org.apache.hadoop.hbase.client.Admin

Throws:

org.apache.hadoop.hbase.NamespaceNotFoundException

IOException

listNamespaces

public String[] listNamespaces()
                        throws IOException

Specified by:

listNamespaces in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listNamespaceDescriptors

public org.apache.hadoop.hbase.NamespaceDescriptor[] listNamespaceDescriptors()
                                                                       throws IOException

Specified by:

listNamespaceDescriptors in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableDescriptorsByNamespace

public List<org.apache.hadoop.hbase.client.TableDescriptor> listTableDescriptorsByNamespace(byte[] name)
                                                                                     throws IOException

Specified by:

listTableDescriptorsByNamespace in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableNamesByNamespace

public org.apache.hadoop.hbase.TableName[] listTableNamesByNamespace(String name)
                                                              throws IOException

Specified by:

listTableNamesByNamespace in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getRegions

public List<org.apache.hadoop.hbase.client.RegionInfo> getRegions(org.apache.hadoop.hbase.TableName tableName)
                                                           throws IOException

Specified by:

getRegions in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.hbase.client.Admin

listTableDescriptors

public List<org.apache.hadoop.hbase.client.TableDescriptor> listTableDescriptors(List<org.apache.hadoop.hbase.TableName> tableNames)
                                                                          throws IOException

Specified by:

listTableDescriptors in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

abortProcedureAsync

public Future<Boolean> abortProcedureAsync(long procId,
                                           boolean mayInterruptIfRunning)
                                    throws IOException

Specified by:

abortProcedureAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getProcedures

public String getProcedures()
                     throws IOException

Specified by:

getProcedures in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getLocks

public String getLocks()
                throws IOException

Specified by:

getLocks in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

rollWALWriter

public void rollWALWriter(org.apache.hadoop.hbase.ServerName serverName)
                   throws IOException,
                          org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException

Specified by:

rollWALWriter in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

org.apache.hadoop.hbase.regionserver.wal.FailedLogCloseException

getCompactionState

public org.apache.hadoop.hbase.client.CompactionState getCompactionState(org.apache.hadoop.hbase.TableName tableName)
                                                                  throws IOException

Specified by:

getCompactionState in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getCompactionState

public org.apache.hadoop.hbase.client.CompactionState getCompactionState(org.apache.hadoop.hbase.TableName tableName,
                                                                         org.apache.hadoop.hbase.client.CompactType compactType)
                                                                  throws IOException

Specified by:

getCompactionState in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getCompactionStateForRegion

public org.apache.hadoop.hbase.client.CompactionState getCompactionStateForRegion(byte[] regionName)
                                                                           throws IOException

Specified by:

getCompactionStateForRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getLastMajorCompactionTimestamp

public long getLastMajorCompactionTimestamp(org.apache.hadoop.hbase.TableName tableName)
                                     throws IOException

Specified by:

getLastMajorCompactionTimestamp in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getLastMajorCompactionTimestampForRegion

public long getLastMajorCompactionTimestampForRegion(byte[] regionName)
                                              throws IOException

Specified by:

getLastMajorCompactionTimestampForRegion in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

snapshot

public void snapshot(org.apache.hadoop.hbase.client.SnapshotDescription snapshot)
              throws IOException,
                     org.apache.hadoop.hbase.snapshot.SnapshotCreationException,
                     IllegalArgumentException

Specified by:

snapshot in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

org.apache.hadoop.hbase.snapshot.SnapshotCreationException

IllegalArgumentException

snapshotAsync

public Future<Void> snapshotAsync(org.apache.hadoop.hbase.client.SnapshotDescription snapshot)
                           throws IOException,
                                  org.apache.hadoop.hbase.snapshot.SnapshotCreationException

Specified by:

snapshotAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

org.apache.hadoop.hbase.snapshot.SnapshotCreationException

isSnapshotFinished

public boolean isSnapshotFinished(org.apache.hadoop.hbase.client.SnapshotDescription snapshot)
                           throws IOException,
                                  org.apache.hadoop.hbase.snapshot.HBaseSnapshotException,
                                  org.apache.hadoop.hbase.snapshot.UnknownSnapshotException

Specified by:

isSnapshotFinished in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

org.apache.hadoop.hbase.snapshot.HBaseSnapshotException

org.apache.hadoop.hbase.snapshot.UnknownSnapshotException

restoreSnapshot

public void restoreSnapshot(String snapshotName)
                     throws IOException,
                            org.apache.hadoop.hbase.snapshot.RestoreSnapshotException

Specified by:

restoreSnapshot in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

org.apache.hadoop.hbase.snapshot.RestoreSnapshotException

restoreSnapshot

public void restoreSnapshot(String snapshotName,
                            boolean takeFailSafeSnapshot,
                            boolean restoreAcl)
                     throws IOException,
                            org.apache.hadoop.hbase.snapshot.RestoreSnapshotException

Specified by:

restoreSnapshot in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

org.apache.hadoop.hbase.snapshot.RestoreSnapshotException

cloneSnapshotAsync

public Future<Void> cloneSnapshotAsync(String snapshotName,
                                       org.apache.hadoop.hbase.TableName tableName,
                                       boolean restoreAcl,
                                       String customSFT)
                                throws IOException,
                                       org.apache.hadoop.hbase.TableExistsException,
                                       org.apache.hadoop.hbase.snapshot.RestoreSnapshotException

Specified by:

cloneSnapshotAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

org.apache.hadoop.hbase.TableExistsException

org.apache.hadoop.hbase.snapshot.RestoreSnapshotException

execProcedure

public void execProcedure(String signature,
                          String instance,
                          Map<String,String> props)
                   throws IOException

Specified by:

execProcedure in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

execProcedureWithReturn

public byte[] execProcedureWithReturn(String signature,
                                      String instance,
                                      Map<String,String> props)
                               throws IOException

Specified by:

execProcedureWithReturn in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isProcedureFinished

public boolean isProcedureFinished(String signature,
                                   String instance,
                                   Map<String,String> props)
                            throws IOException

Specified by:

isProcedureFinished in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listSnapshots

public List<org.apache.hadoop.hbase.client.SnapshotDescription> listSnapshots()
                                                                       throws IOException

Specified by:

listSnapshots in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listSnapshots

public List<org.apache.hadoop.hbase.client.SnapshotDescription> listSnapshots(Pattern pattern)
                                                                       throws IOException

Specified by:

listSnapshots in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTableSnapshots

public List<org.apache.hadoop.hbase.client.SnapshotDescription> listTableSnapshots(Pattern tableNamePattern,
                                                                                   Pattern snapshotNamePattern)
                                                                            throws IOException

Specified by:

listTableSnapshots in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

deleteSnapshot

public void deleteSnapshot(String snapshotName)
                    throws IOException

Specified by:

deleteSnapshot in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

deleteSnapshots

public void deleteSnapshots(Pattern pattern)
                     throws IOException

Specified by:

deleteSnapshots in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

deleteTableSnapshots

public void deleteTableSnapshots(Pattern tableNamePattern,
                                 Pattern snapshotNamePattern)
                          throws IOException

Specified by:

deleteTableSnapshots in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

setQuota

public void setQuota(org.apache.hadoop.hbase.quotas.QuotaSettings quota)
              throws IOException

Specified by:

setQuota in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getQuota

public List<org.apache.hadoop.hbase.quotas.QuotaSettings> getQuota(org.apache.hadoop.hbase.quotas.QuotaFilter filter)
                                                            throws IOException

Specified by:

getQuota in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

coprocessorService

public org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel coprocessorService()

Specified by:

coprocessorService in interface org.apache.hadoop.hbase.client.Admin

coprocessorService

public org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel coprocessorService(org.apache.hadoop.hbase.ServerName serverName)

Specified by:

coprocessorService in interface org.apache.hadoop.hbase.client.Admin

updateConfiguration

public void updateConfiguration(org.apache.hadoop.hbase.ServerName server)
                         throws IOException

Specified by:

updateConfiguration in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

updateConfiguration

public void updateConfiguration()
                         throws IOException

Specified by:

updateConfiguration in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

updateConfiguration

public void updateConfiguration(String groupName)
                         throws IOException

Specified by:

updateConfiguration in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getSecurityCapabilities

public List<org.apache.hadoop.hbase.client.security.SecurityCapability> getSecurityCapabilities()
                                                                                         throws IOException

Specified by:

getSecurityCapabilities in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

splitSwitch

public boolean splitSwitch(boolean enabled,
                           boolean synchronous)
                    throws IOException

Specified by:

splitSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

mergeSwitch

public boolean mergeSwitch(boolean enabled,
                           boolean synchronous)
                    throws IOException

Specified by:

mergeSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isSplitEnabled

public boolean isSplitEnabled()
                       throws IOException

Specified by:

isSplitEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isMergeEnabled

public boolean isMergeEnabled()
                       throws IOException

Specified by:

isMergeEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

addReplicationPeerAsync

public Future<Void> addReplicationPeerAsync(String peerId,
                                            org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig,
                                            boolean enabled)
                                     throws IOException

Specified by:

addReplicationPeerAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

removeReplicationPeerAsync

public Future<Void> removeReplicationPeerAsync(String peerId)
                                        throws IOException

Specified by:

removeReplicationPeerAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

enableReplicationPeerAsync

public Future<Void> enableReplicationPeerAsync(String peerId)
                                        throws IOException

Specified by:

enableReplicationPeerAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

disableReplicationPeerAsync

public Future<Void> disableReplicationPeerAsync(String peerId)
                                         throws IOException

Specified by:

disableReplicationPeerAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getReplicationPeerConfig

public org.apache.hadoop.hbase.replication.ReplicationPeerConfig getReplicationPeerConfig(String peerId)
                                                                                   throws IOException

Specified by:

getReplicationPeerConfig in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

updateReplicationPeerConfigAsync

public Future<Void> updateReplicationPeerConfigAsync(String peerId,
                                                     org.apache.hadoop.hbase.replication.ReplicationPeerConfig peerConfig)
                                              throws IOException

Specified by:

updateReplicationPeerConfigAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listReplicationPeers

public List<org.apache.hadoop.hbase.replication.ReplicationPeerDescription> listReplicationPeers()
                                                                                          throws IOException

Specified by:

listReplicationPeers in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listReplicationPeers

public List<org.apache.hadoop.hbase.replication.ReplicationPeerDescription> listReplicationPeers(Pattern pattern)
                                                                                          throws IOException

Specified by:

listReplicationPeers in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

transitReplicationPeerSyncReplicationStateAsync

public Future<Void> transitReplicationPeerSyncReplicationStateAsync(String peerId,
                                                                    org.apache.hadoop.hbase.replication.SyncReplicationState state)
                                                             throws IOException

Specified by:

transitReplicationPeerSyncReplicationStateAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isReplicationPeerEnabled

public boolean isReplicationPeerEnabled(String peerId)
                                 throws IOException

Specified by:

isReplicationPeerEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

decommissionRegionServers

public void decommissionRegionServers(List<org.apache.hadoop.hbase.ServerName> servers,
                                      boolean offload)
                               throws IOException

Specified by:

decommissionRegionServers in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listDecommissionedRegionServers

public List<org.apache.hadoop.hbase.ServerName> listDecommissionedRegionServers()
                                                                         throws IOException

Specified by:

listDecommissionedRegionServers in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

recommissionRegionServer

public void recommissionRegionServer(org.apache.hadoop.hbase.ServerName server,
                                     List<byte[]> encodedRegionNames)
                              throws IOException

Specified by:

recommissionRegionServer in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listReplicatedTableCFs

public List<org.apache.hadoop.hbase.client.replication.TableCFs> listReplicatedTableCFs()
                                                                                 throws IOException

Specified by:

listReplicatedTableCFs in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

enableTableReplication

public void enableTableReplication(org.apache.hadoop.hbase.TableName tableName)
                            throws IOException

Specified by:

enableTableReplication in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

disableTableReplication

public void disableTableReplication(org.apache.hadoop.hbase.TableName tableName)
                             throws IOException

Specified by:

disableTableReplication in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

clearCompactionQueues

public void clearCompactionQueues(org.apache.hadoop.hbase.ServerName serverName,
                                  Set<String> queues)
                           throws IOException,
                                  InterruptedException

Specified by:

clearCompactionQueues in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

InterruptedException

clearDeadServers

public List<org.apache.hadoop.hbase.ServerName> clearDeadServers(List<org.apache.hadoop.hbase.ServerName> servers)
                                                          throws IOException

Specified by:

clearDeadServers in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

cloneTableSchema

public void cloneTableSchema(org.apache.hadoop.hbase.TableName tableName,
                             org.apache.hadoop.hbase.TableName newTableName,
                             boolean preserveSplits)
                      throws IOException

Specified by:

cloneTableSchema in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

switchRpcThrottle

public boolean switchRpcThrottle(boolean enable)
                          throws IOException

Specified by:

switchRpcThrottle in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isRpcThrottleEnabled

public boolean isRpcThrottleEnabled()
                             throws IOException

Specified by:

isRpcThrottleEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

exceedThrottleQuotaSwitch

public boolean exceedThrottleQuotaSwitch(boolean enable)
                                  throws IOException

Specified by:

exceedThrottleQuotaSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getSpaceQuotaTableSizes

public Map<org.apache.hadoop.hbase.TableName,Long> getSpaceQuotaTableSizes()
                                                                    throws IOException

Specified by:

getSpaceQuotaTableSizes in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getRegionServerSpaceQuotaSnapshots

public Map<org.apache.hadoop.hbase.TableName,? extends org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotView> getRegionServerSpaceQuotaSnapshots(org.apache.hadoop.hbase.ServerName serverName)
                                                                                                                                          throws IOException

Specified by:

getRegionServerSpaceQuotaSnapshots in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getCurrentSpaceQuotaSnapshot

public org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotView getCurrentSpaceQuotaSnapshot(String namespace)
                                                                                   throws IOException

Specified by:

getCurrentSpaceQuotaSnapshot in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getCurrentSpaceQuotaSnapshot

public org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotView getCurrentSpaceQuotaSnapshot(org.apache.hadoop.hbase.TableName tableName)
                                                                                   throws IOException

Specified by:

getCurrentSpaceQuotaSnapshot in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

grant

public void grant(org.apache.hadoop.hbase.security.access.UserPermission userPermission,
                  boolean mergeExistingPermissions)
           throws IOException

Specified by:

grant in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

revoke

public void revoke(org.apache.hadoop.hbase.security.access.UserPermission userPermission)
            throws IOException

Specified by:

revoke in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getUserPermissions

public List<org.apache.hadoop.hbase.security.access.UserPermission> getUserPermissions(org.apache.hadoop.hbase.security.access.GetUserPermissionsRequest getUserPermissionsRequest)
                                                                                throws IOException

Specified by:

getUserPermissions in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

hasUserPermissions

public List<Boolean> hasUserPermissions(String userName,
                                        List<org.apache.hadoop.hbase.security.access.Permission> permissions)
                                 throws IOException

Specified by:

hasUserPermissions in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

snapshotCleanupSwitch

public boolean snapshotCleanupSwitch(boolean on,
                                     boolean synchronous)
                              throws IOException

Specified by:

snapshotCleanupSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isSnapshotCleanupEnabled

public boolean isSnapshotCleanupEnabled()
                                 throws IOException

Specified by:

isSnapshotCleanupEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

addRSGroup

public void addRSGroup(String groupName)
                throws IOException

Specified by:

addRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getRSGroup

public org.apache.hadoop.hbase.rsgroup.RSGroupInfo getRSGroup(String groupName)
                                                       throws IOException

Specified by:

getRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getRSGroup

public org.apache.hadoop.hbase.rsgroup.RSGroupInfo getRSGroup(org.apache.hadoop.hbase.net.Address hostPort)
                                                       throws IOException

Specified by:

getRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getRSGroup

public org.apache.hadoop.hbase.rsgroup.RSGroupInfo getRSGroup(org.apache.hadoop.hbase.TableName tableName)
                                                       throws IOException

Specified by:

getRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listRSGroups

public List<org.apache.hadoop.hbase.rsgroup.RSGroupInfo> listRSGroups()
                                                               throws IOException

Specified by:

listRSGroups in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

listTablesInRSGroup

public List<org.apache.hadoop.hbase.TableName> listTablesInRSGroup(String groupName)
                                                            throws IOException

Specified by:

listTablesInRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getConfiguredNamespacesAndTablesInRSGroup

public org.apache.hadoop.hbase.util.Pair<List<String>,List<org.apache.hadoop.hbase.TableName>> getConfiguredNamespacesAndTablesInRSGroup(String groupName)
                                                                                                                                  throws IOException

Specified by:

getConfiguredNamespacesAndTablesInRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

removeRSGroup

public void removeRSGroup(String groupName)
                   throws IOException

Specified by:

removeRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

removeServersFromRSGroup

public void removeServersFromRSGroup(Set<org.apache.hadoop.hbase.net.Address> servers)
                              throws IOException

Specified by:

removeServersFromRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

moveServersToRSGroup

public void moveServersToRSGroup(Set<org.apache.hadoop.hbase.net.Address> servers,
                                 String targetGroup)
                          throws IOException

Specified by:

moveServersToRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

setRSGroup

public void setRSGroup(Set<org.apache.hadoop.hbase.TableName> tables,
                       String groupName)
                throws IOException

Specified by:

setRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

balanceRSGroup

public org.apache.hadoop.hbase.client.BalanceResponse balanceRSGroup(String groupName,
                                                                     org.apache.hadoop.hbase.client.BalanceRequest request)
                                                              throws IOException

Specified by:

balanceRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

renameRSGroup

public void renameRSGroup(String oldName,
                          String newName)
                   throws IOException

Specified by:

renameRSGroup in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

updateRSGroupConfig

public void updateRSGroupConfig(String groupName,
                                Map<String,String> configuration)
                         throws IOException

Specified by:

updateRSGroupConfig in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getLogEntries

public List<org.apache.hadoop.hbase.client.LogEntry> getLogEntries(Set<org.apache.hadoop.hbase.ServerName> serverNames,
                                                                   String logType,
                                                                   org.apache.hadoop.hbase.client.ServerType serverType,
                                                                   int limit,
                                                                   Map<String,Object> filterParams)
                                                            throws IOException

Specified by:

getLogEntries in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

verify

private void verify()
             throws IOException

Throws:

IOException

clearSlowLogResponses

public List<Boolean> clearSlowLogResponses(Set<org.apache.hadoop.hbase.ServerName> serverNames)
                                    throws IOException

Specified by:

clearSlowLogResponses in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

modifyColumnFamilyStoreFileTrackerAsync

public Future<Void> modifyColumnFamilyStoreFileTrackerAsync(org.apache.hadoop.hbase.TableName tableName,
                                                            byte[] family,
                                                            String dstSFT)
                                                     throws IOException

Specified by:

modifyColumnFamilyStoreFileTrackerAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

modifyTableStoreFileTrackerAsync

public Future<Void> modifyTableStoreFileTrackerAsync(org.apache.hadoop.hbase.TableName tableName,
                                                     String dstSFT)
                                              throws IOException

Specified by:

modifyTableStoreFileTrackerAsync in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

flushMasterStore

public void flushMasterStore()
                      throws IOException

Specified by:

flushMasterStore in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

getCachedFilesList

public List<String> getCachedFilesList(org.apache.hadoop.hbase.ServerName serverName)
                                throws IOException

Specified by:

getCachedFilesList in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

replicationPeerModificationSwitch

public boolean replicationPeerModificationSwitch(boolean on,
                                                 boolean drainProcedures)
                                          throws IOException

Specified by:

replicationPeerModificationSwitch in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException

isReplicationPeerModificationEnabled

public boolean isReplicationPeerModificationEnabled()
                                             throws IOException

Specified by:

isReplicationPeerModificationEnabled in interface org.apache.hadoop.hbase.client.Admin

Throws:

IOException