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