@InterfaceAudience.Private class RawAsyncHBaseAdmin extends Object implements AsyncAdmin
The word 'Raw' means that this is a low level class. The returned CompletableFuture will
be finished inside the rpc framework thread, which means that the callbacks registered to the
CompletableFuture will also be executed inside the rpc framework thread. So users who use
this class should not try to do time consuming tasks in the callbacks.
AsyncHBaseAdmin,
AsyncConnection.getAdmin(),
AsyncConnection.getAdminBuilder()| Modifier and Type | Field and Description |
|---|---|
private AsyncConnectionImpl |
connection |
static String |
FLUSH_TABLE_PROCEDURE_SIGNATURE |
private static org.slf4j.Logger |
LOG |
private int |
maxAttempts |
private AsyncTable<AdvancedScanResultConsumer> |
metaTable |
private NonceGenerator |
ng |
private long |
operationTimeoutNs |
private long |
pauseNs |
private org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer |
retryTimer |
private long |
rpcTimeoutNs |
private int |
startLogErrorsCnt |
| Constructor and Description |
|---|
RawAsyncHBaseAdmin(AsyncConnectionImpl connection,
org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer,
AsyncAdminBuilderBase builder) |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Boolean> |
abortProcedure(long procId,
boolean mayInterruptIfRunning)
Abort a procedure
Do not use.
|
CompletableFuture<Void> |
addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Add a column family to an existing table.
|
CompletableFuture<Void> |
addReplicationPeer(String peerId,
ReplicationPeerConfig peerConfig,
boolean enabled)
Add a new replication peer for replicating data to slave cluster
|
private <PREQ,PRESP,RESP> |
adminCall(HBaseRpcController controller,
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface stub,
PREQ preq,
RawAsyncHBaseAdmin.AdminRpcCall<PRESP,PREQ> rpcCall,
RawAsyncHBaseAdmin.Converter<RESP,PRESP> respConverter) |
CompletableFuture<Void> |
appendReplicationPeerTableCFs(String id,
Map<TableName,List<String>> tableCfs)
Append the replicable table-cf config of the specified peer
|
CompletableFuture<Void> |
assign(byte[] regionName) |
CompletableFuture<Boolean> |
balance(boolean forcible)
Invoke the balancer.
|
CompletableFuture<Boolean> |
balancerSwitch(boolean on)
Turn the load balancer on or off.
|
private <PREQ,PRESP,RESP> |
call(HBaseRpcController controller,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface stub,
PREQ preq,
RawAsyncHBaseAdmin.MasterRpcCall<PRESP,PREQ> rpcCall,
RawAsyncHBaseAdmin.Converter<RESP,PRESP> respConverter) |
CompletableFuture<Boolean> |
catalogJanitorSwitch(boolean enabled)
Turn the catalog janitor on/off.
|
private void |
checkAndGetTableName(byte[] encodeRegionName,
AtomicReference<TableName> tableName,
CompletableFuture<TableName> result) |
private CompletableFuture<Void> |
checkAndSyncTableToPeerClusters(TableName tableName,
byte[][] splits)
Connect to peer and check the table descriptor on peer:
Create the same table on peer when not exist.
Throw an exception if the table already has replication enabled on any of the column
families.
Throw an exception if the table exists on peer cluster but descriptors are not same.
|
private CompletableFuture<TableName> |
checkRegionsAndGetTableName(byte[] encodeRegionNameA,
byte[] encodeRegionNameB) |
CompletableFuture<Boolean> |
cleanerChoreSwitch(boolean enabled)
Turn the cleaner chore on/off.
|
private CompletableFuture<CacheEvictionStats> |
clearBlockCache(ServerName serverName,
List<RegionInfo> hris) |
CompletableFuture<CacheEvictionStats> |
clearBlockCache(TableName tableName)
Clear all the blocks corresponding to this table from BlockCache.
|
CompletableFuture<Void> |
clearCompactionQueues(ServerName serverName,
Set<String> queues)
Clear compacting queues on a region server.
|
CompletableFuture<List<ServerName>> |
clearDeadServers(List<ServerName> servers)
Clear dead region servers from master.
|
CompletableFuture<Void> |
cloneSnapshot(String snapshotName,
TableName tableName)
Create a new table by cloning the snapshot content.
|
CompletableFuture<Void> |
cloneTableSchema(TableName tableName,
TableName newTableName,
boolean preserveSplits)
Create a new table by cloning the existent table schema.
|
private CompletableFuture<Void> |
compact(ServerName sn,
RegionInfo hri,
boolean major,
byte[] columnFamily)
Compact the region at specific region server.
|
private CompletableFuture<Void> |
compact(TableName tableName,
byte[] columnFamily,
boolean major,
CompactType compactType)
Compact column family of a table, Asynchronous operation even if CompletableFuture.get()
|
CompletableFuture<Void> |
compact(TableName tableName,
byte[] columnFamily,
CompactType compactType)
Compact a column family within a table.
|
CompletableFuture<Void> |
compact(TableName tableName,
CompactType compactType)
Compact a table.
|
CompletableFuture<Void> |
compactRegion(byte[] regionName)
Compact an individual region.
|
CompletableFuture<Void> |
compactRegion(byte[] regionName,
byte[] columnFamily)
Compact a column family within a region.
|
private CompletableFuture<Void> |
compactRegion(byte[] regionName,
byte[] columnFamily,
boolean major) |
CompletableFuture<Void> |
compactRegionServer(ServerName sn)
Compact all regions on the region server.
|
private CompletableFuture<Void> |
compactRegionServer(ServerName sn,
boolean major) |
private boolean |
compareRegionsWithSplitKeys(List<HRegionLocation> locations,
byte[][] splitKeys) |
private CompletableFuture<Void> |
compareTableWithPeerCluster(TableName tableName,
TableDescriptor tableDesc,
ReplicationPeerDescription peer,
AsyncAdmin peerAdmin) |
private <T> void |
completeConditionalOnFuture(CompletableFuture<T> dependentFuture,
CompletableFuture<T> parentFuture) |
private <T> boolean |
completeExceptionally(CompletableFuture<T> future,
Throwable error) |
<S,R> CompletableFuture<R> |
coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker,
ServiceCaller<S,R> callable)
Execute the given coprocessor call on the master.
|
<S,R> CompletableFuture<R> |
coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker,
ServiceCaller<S,R> callable,
ServerName serverName)
Execute the given coprocessor call on the given region server.
|
CompletableFuture<Void> |
createNamespace(NamespaceDescriptor descriptor)
Create a new namespace.
|
CompletableFuture<Void> |
createTable(TableDescriptor desc)
Creates a new table.
|
CompletableFuture<Void> |
createTable(TableDescriptor desc,
byte[][] splitKeys)
Creates a new table with an initial set of empty regions defined by the specified split keys.
|
CompletableFuture<Void> |
createTable(TableDescriptor desc,
byte[] startKey,
byte[] endKey,
int numRegions)
Creates a new table with the specified number of regions.
|
private CompletableFuture<Void> |
createTable(TableName tableName,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateTableRequest request) |
CompletableFuture<Void> |
decommissionRegionServers(List<ServerName> servers,
boolean offload)
Mark region server(s) as decommissioned to prevent additional regions from getting
assigned to them.
|
CompletableFuture<Void> |
deleteColumnFamily(TableName tableName,
byte[] columnFamily)
Delete a column family from a table.
|
CompletableFuture<Void> |
deleteNamespace(String name)
Delete an existing namespace.
|
CompletableFuture<Void> |
deleteSnapshot(String snapshotName)
Delete an existing snapshot.
|
CompletableFuture<Void> |
deleteSnapshots()
Delete all existing snapshots.
|
CompletableFuture<Void> |
deleteSnapshots(Pattern snapshotNamePattern)
Delete existing snapshots whose names match the pattern passed.
|
CompletableFuture<Void> |
deleteTable(TableName tableName)
Deletes a table.
|
CompletableFuture<Void> |
deleteTableSnapshots(Pattern tableNamePattern)
Delete all existing snapshots matching the given table name pattern.
|
CompletableFuture<Void> |
deleteTableSnapshots(Pattern tableNamePattern,
Pattern snapshotNamePattern)
Delete all existing snapshots matching the given table name regular expression and snapshot
name regular expression.
|
CompletableFuture<Void> |
disableReplicationPeer(String peerId)
Stop the replication stream to the specified peer
|
CompletableFuture<Void> |
disableTable(TableName tableName)
Disable a table.
|
CompletableFuture<Void> |
disableTableReplication(TableName tableName)
Disable a table's replication switch.
|
CompletableFuture<Void> |
enableReplicationPeer(String peerId)
Restart the replication stream to the specified peer
|
CompletableFuture<Void> |
enableTable(TableName tableName)
Enable a table.
|
CompletableFuture<Void> |
enableTableReplication(TableName tableName)
Enable a table's replication switch.
|
CompletableFuture<Void> |
execProcedure(String signature,
String instance,
Map<String,String> props)
Execute a distributed procedure on a cluster.
|
CompletableFuture<byte[]> |
execProcedureWithReturn(String signature,
String instance,
Map<String,String> props)
Execute a distributed procedure on a cluster.
|
private <T> CompletableFuture<T> |
failedFuture(Throwable error) |
private CompletableFuture<Void> |
flush(ServerName serverName,
RegionInfo regionInfo) |
CompletableFuture<Void> |
flush(TableName tableName)
Flush a table.
|
CompletableFuture<Void> |
flushRegion(byte[] regionName)
Flush an individual region.
|
CompletableFuture<Void> |
flushRegionServer(ServerName sn)
Flush all region on the region server.
|
CompletableFuture<ClusterMetrics> |
getClusterMetrics() |
CompletableFuture<ClusterMetrics> |
getClusterMetrics(EnumSet<ClusterMetrics.Option> options) |
CompletableFuture<CompactionState> |
getCompactionState(TableName tableName,
CompactType compactType)
Get the current compaction state of a table.
|
CompletableFuture<CompactionState> |
getCompactionStateForRegion(byte[] regionName)
Get the current compaction state of region.
|
private CompletableFuture<List<SnapshotDescription>> |
getCompletedSnapshots(Pattern pattern) |
private CompletableFuture<List<SnapshotDescription>> |
getCompletedSnapshots(Pattern tableNamePattern,
Pattern snapshotNamePattern) |
CompletableFuture<TableDescriptor> |
getDescriptor(TableName tableName)
Method for getting the tableDescriptor
|
CompletableFuture<Optional<Long>> |
getLastMajorCompactionTimestamp(TableName tableName)
Get the timestamp of the last major compaction for the passed table.
|
CompletableFuture<Optional<Long>> |
getLastMajorCompactionTimestampForRegion(byte[] regionName)
Get the timestamp of the last major compaction for the passed region.
|
CompletableFuture<String> |
getLocks()
List locks.
|
CompletableFuture<NamespaceDescriptor> |
getNamespaceDescriptor(String name)
Get a namespace descriptor by name
|
private void |
getProcedureResult(long procId,
CompletableFuture<Void> future,
int retries) |
CompletableFuture<String> |
getProcedures()
List procedures
|
CompletableFuture<List<QuotaSettings>> |
getQuota(QuotaFilter filter)
List the quotas based on the filter.
|
private CompletableFuture<RegionInfo> |
getRegionInfo(byte[] regionNameOrEncodedRegionName)
Get the region info for the passed region name.
|
(package private) CompletableFuture<HRegionLocation> |
getRegionLocation(byte[] regionNameOrEncodedRegionName)
Get the region location for the passed region name.
|
private CompletableFuture<List<RegionMetrics>> |
getRegionMetrics(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request,
ServerName serverName) |
CompletableFuture<List<RegionMetrics>> |
getRegionMetrics(ServerName serverName)
Get a list of
RegionMetrics of all regions hosted on a region seerver. |
CompletableFuture<List<RegionMetrics>> |
getRegionMetrics(ServerName serverName,
TableName tableName)
Get a list of
RegionMetrics of all regions hosted on a region seerver for a table. |
CompletableFuture<List<RegionInfo>> |
getRegions(ServerName serverName)
Get all the online regions on a region server.
|
CompletableFuture<List<RegionInfo>> |
getRegions(TableName tableName)
Get the regions of a given table.
|
CompletableFuture<ReplicationPeerConfig> |
getReplicationPeerConfig(String peerId)
Returns the configured ReplicationPeerConfig for the specified peer
|
CompletableFuture<List<SecurityCapability>> |
getSecurityCapabilities() |
private byte[][] |
getSplitKeys(byte[] startKey,
byte[] endKey,
int numRegions) |
private CompletableFuture<List<TableDescriptor>> |
getTableDescriptors(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableDescriptorsRequest request) |
private CompletableFuture<List<HRegionLocation>> |
getTableHRegionLocations(TableName tableName)
List all region locations for the specific table.
|
private CompletableFuture<List<TableName>> |
getTableNames(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableNamesRequest request) |
private CompletableFuture<byte[][]> |
getTableSplits(TableName tableName) |
private CompletableFuture<Void> |
internalDeleteSnapshot(SnapshotDescription snapshot) |
private CompletableFuture<Void> |
internalDeleteSnapshots(Pattern tableNamePattern,
Pattern snapshotNamePattern) |
private CompletableFuture<Void> |
internalRestoreSnapshot(String snapshotName,
TableName tableName) |
CompletableFuture<Boolean> |
isBalancerEnabled()
Query the current state of the balancer.
|
CompletableFuture<Boolean> |
isCatalogJanitorEnabled()
Query on the catalog janitor state.
|
CompletableFuture<Boolean> |
isCleanerChoreEnabled()
Query the current state of the cleaner chore.
|
CompletableFuture<Boolean> |
isMasterInMaintenanceMode()
Check whether master is in maintenance mode
|
CompletableFuture<Boolean> |
isMergeEnabled()
Query the current state of the Merge switch.
|
CompletableFuture<Boolean> |
isNormalizerEnabled()
Query the current state of the region normalizer
|
CompletableFuture<Boolean> |
isProcedureFinished(String signature,
String instance,
Map<String,String> props)
Check the current state of the specified procedure.
|
CompletableFuture<Boolean> |
isSnapshotFinished(SnapshotDescription snapshot)
Check the current state of the passed snapshot.
|
CompletableFuture<Boolean> |
isSplitEnabled()
Query the current state of the Split switch.
|
private CompletableFuture<Boolean> |
isSplitOrMergeOn(MasterSwitchType switchType) |
CompletableFuture<Boolean> |
isTableAvailable(TableName tableName) |
CompletableFuture<Boolean> |
isTableAvailable(TableName tableName,
byte[][] splitKeys)
Use this api to check if the table has been created with the specified number of splitkeys
which was used while creating the given table.
|
private CompletableFuture<Boolean> |
isTableAvailable(TableName tableName,
Optional<byte[][]> splitKeys) |
CompletableFuture<Boolean> |
isTableDisabled(TableName tableName) |
CompletableFuture<Boolean> |
isTableEnabled(TableName tableName) |
CompletableFuture<List<ServerName>> |
listDecommissionedRegionServers()
List region servers marked as decommissioned, which can not be assigned regions.
|
CompletableFuture<List<NamespaceDescriptor>> |
listNamespaceDescriptors()
List available namespace descriptors
|
CompletableFuture<List<TableCFs>> |
listReplicatedTableCFs()
Find all table and column families that are replicated from this cluster
|
CompletableFuture<List<ReplicationPeerDescription>> |
listReplicationPeers()
Return a list of replication peers.
|
CompletableFuture<List<ReplicationPeerDescription>> |
listReplicationPeers(Pattern pattern)
Return a list of replication peers.
|
private CompletableFuture<List<ReplicationPeerDescription>> |
listReplicationPeers(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ListReplicationPeersRequest request) |
CompletableFuture<List<SnapshotDescription>> |
listSnapshots()
List completed snapshots.
|
CompletableFuture<List<SnapshotDescription>> |
listSnapshots(Pattern pattern)
List all the completed snapshots matching the given pattern.
|
CompletableFuture<List<TableDescriptor>> |
listTableDescriptors(boolean includeSysTables)
List all the tables.
|
CompletableFuture<List<TableDescriptor>> |
listTableDescriptors(Pattern pattern,
boolean includeSysTables)
|
CompletableFuture<List<TableDescriptor>> |
listTableDescriptorsByNamespace(String name)
Get list of table descriptors by namespace.
|
CompletableFuture<List<TableName>> |
listTableNames(boolean includeSysTables)
List all of the names of tables.
|
CompletableFuture<List<TableName>> |
listTableNames(Pattern pattern,
boolean includeSysTables)
List all of the names of userspace tables.
|
CompletableFuture<List<TableName>> |
listTableNamesByNamespace(String name)
Get list of table names by namespace.
|
CompletableFuture<List<SnapshotDescription>> |
listTableSnapshots(Pattern tableNamePattern)
List all the completed snapshots matching the given table name pattern.
|
CompletableFuture<List<SnapshotDescription>> |
listTableSnapshots(Pattern tableNamePattern,
Pattern snapshotNamePattern)
List all the completed snapshots matching the given table name regular expression and snapshot
name regular expression.
|
CompletableFuture<Void> |
majorCompact(TableName tableName,
byte[] columnFamily,
CompactType compactType)
Major compact a column family within a table.
|
CompletableFuture<Void> |
majorCompact(TableName tableName,
CompactType compactType)
Major compact a table.
|
CompletableFuture<Void> |
majorCompactRegion(byte[] regionName)
Major compact a region.
|
CompletableFuture<Void> |
majorCompactRegion(byte[] regionName,
byte[] columnFamily)
Major compact a column family within region.
|
CompletableFuture<Void> |
majorCompactRegionServer(ServerName sn)
Compact all regions on the region server.
|
CompletableFuture<Void> |
mergeRegions(byte[] nameOfRegionA,
byte[] nameOfRegionB,
boolean forcible)
Merge two regions.
|
CompletableFuture<Boolean> |
mergeSwitch(boolean on)
Turn the Merge switch on or off.
|
CompletableFuture<Void> |
modifyColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Modify an existing column family on a table.
|
CompletableFuture<Void> |
modifyNamespace(NamespaceDescriptor descriptor)
Modify an existing namespace.
|
CompletableFuture<Void> |
modifyTable(TableDescriptor desc)
Modify an existing table, more IRB friendly version.
|
CompletableFuture<Void> |
move(byte[] regionName)
Move the region
r to a random server. |
CompletableFuture<Void> |
move(byte[] regionName,
ServerName destServerName)
Move the region
r to dest. |
private CompletableFuture<Void> |
moveRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MoveRegionRequest request) |
private <T> AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder<T> |
newAdminCaller() |
private <T> AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> |
newMasterCaller() |
private <T> AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T> |
newServerCaller() |
CompletableFuture<Boolean> |
normalize()
Invoke region normalizer.
|
CompletableFuture<Boolean> |
normalizerSwitch(boolean on)
Set region normalizer on/off.
|
CompletableFuture<Void> |
offline(byte[] regionName)
Offline specified region from master's in-memory state.
|
private <PREQ,PRESP> |
procedureCall(PREQ preq,
RawAsyncHBaseAdmin.MasterRpcCall<PRESP,PREQ> rpcCall,
RawAsyncHBaseAdmin.Converter<Long,PRESP> respConverter,
RawAsyncHBaseAdmin.ProcedureBiConsumer consumer) |
CompletableFuture<Void> |
recommissionRegionServer(ServerName server,
List<byte[]> encodedRegionNames)
Remove decommission marker from a region server to allow regions assignments.
|
CompletableFuture<Void> |
removeReplicationPeer(String peerId)
Remove a peer and stop the replication
|
CompletableFuture<Void> |
removeReplicationPeerTableCFs(String id,
Map<TableName,List<String>> tableCfs)
Remove some table-cfs from config of the specified peer
|
CompletableFuture<Void> |
restoreSnapshot(String snapshotName)
Restore the specified snapshot on the original table.
|
CompletableFuture<Void> |
restoreSnapshot(String snapshotName,
boolean takeFailSafeSnapshot)
Restore the specified snapshot on the original table.
|
private CompletableFuture<Void> |
restoreSnapshot(String snapshotName,
TableName tableName,
boolean takeFailSafeSnapshot) |
CompletableFuture<Void> |
rollWALWriter(ServerName serverName)
Roll the log writer.
|
CompletableFuture<Integer> |
runCatalogJanitor()
Ask for a scan of the catalog table.
|
CompletableFuture<Boolean> |
runCleanerChore()
Ask for cleaner chore to run.
|
CompletableFuture<Void> |
setQuota(QuotaSettings quota)
Apply the new quota settings.
|
private CompletableFuture<Boolean> |
setSplitOrMergeOn(boolean on,
MasterSwitchType switchType) |
private CompletableFuture<Void> |
setTableReplication(TableName tableName,
boolean enableRep)
Set the table's replication switch if the table's replication switch is already not set.
|
CompletableFuture<Void> |
shutdown()
Shuts down the HBase cluster.
|
CompletableFuture<Void> |
snapshot(SnapshotDescription snapshotDesc)
Take a snapshot and wait for the server to complete that snapshot asynchronously.
|
private CompletableFuture<Void> |
split(RegionInfo hri,
byte[] splitPoint) |
CompletableFuture<Void> |
split(TableName tableName)
Split a table.
|
CompletableFuture<Void> |
split(TableName tableName,
byte[] splitPoint)
Split a table.
|
CompletableFuture<Void> |
splitRegion(byte[] regionName)
Split an individual region.
|
CompletableFuture<Void> |
splitRegion(byte[] regionName,
byte[] splitPoint)
Split an individual region.
|
CompletableFuture<Boolean> |
splitSwitch(boolean on)
Turn the Split switch on or off.
|
CompletableFuture<Void> |
stopMaster()
Shuts down the current HBase master only.
|
CompletableFuture<Void> |
stopRegionServer(ServerName serverName)
Stop the designated regionserver.
|
CompletableFuture<Boolean> |
tableExists(TableName tableName) |
private byte[] |
toEncodeRegionName(byte[] regionName) |
CompletableFuture<Void> |
truncateTable(TableName tableName,
boolean preserveSplits)
Truncate a table.
|
private CompletableFuture<Void> |
trySyncTableToPeerCluster(TableName tableName,
byte[][] splits,
ReplicationPeerDescription peer) |
CompletableFuture<Void> |
unassign(byte[] regionName,
boolean forcible)
Unassign a region from current hosting regionserver.
|
CompletableFuture<Void> |
updateConfiguration()
Update the configuration and trigger an online config change on all the masters and
regionservers.
|
CompletableFuture<Void> |
updateConfiguration(ServerName serverName)
Update the configuration and trigger an online config change on the regionserver.
|
CompletableFuture<Void> |
updateReplicationPeerConfig(String peerId,
ReplicationPeerConfig peerConfig)
Update the peerConfig for the specified peer
|
private void |
verifySplitKeys(byte[][] splitKeys) |
private CompletableFuture<Void> |
waitProcedureResult(CompletableFuture<Long> procFuture) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddReplicationPeer, balance, compact, compact, getBackupMasters, getCompactionState, getMaster, getMasterCoprocessorNames, getMasterInfoPort, getRegionServers, listDeadServers, listTableDescriptors, listTableNames, majorCompact, majorCompact, snapshot, snapshotpublic static final String FLUSH_TABLE_PROCEDURE_SIGNATURE
private static final org.slf4j.Logger LOG
private final AsyncConnectionImpl connection
private final org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer
private final AsyncTable<AdvancedScanResultConsumer> metaTable
private final long rpcTimeoutNs
private final long operationTimeoutNs
private final long pauseNs
private final int maxAttempts
private final int startLogErrorsCnt
private final NonceGenerator ng
RawAsyncHBaseAdmin(AsyncConnectionImpl connection, org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer, AsyncAdminBuilderBase builder)
private <T> AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder<T> newMasterCaller()
private <T> AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder<T> newAdminCaller()
private <PREQ,PRESP,RESP> CompletableFuture<RESP> call(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface stub, PREQ preq, RawAsyncHBaseAdmin.MasterRpcCall<PRESP,PREQ> rpcCall, RawAsyncHBaseAdmin.Converter<RESP,PRESP> respConverter)
private <PREQ,PRESP,RESP> CompletableFuture<RESP> adminCall(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface stub, PREQ preq, RawAsyncHBaseAdmin.AdminRpcCall<PRESP,PREQ> rpcCall, RawAsyncHBaseAdmin.Converter<RESP,PRESP> respConverter)
private <PREQ,PRESP> CompletableFuture<Void> procedureCall(PREQ preq, RawAsyncHBaseAdmin.MasterRpcCall<PRESP,PREQ> rpcCall, RawAsyncHBaseAdmin.Converter<Long,PRESP> respConverter, RawAsyncHBaseAdmin.ProcedureBiConsumer consumer)
public CompletableFuture<Boolean> tableExists(TableName tableName)
tableExists in interface AsyncAdmintableName - Table to check.CompletableFuture.public CompletableFuture<List<TableDescriptor>> listTableDescriptors(boolean includeSysTables)
AsyncAdminlistTableDescriptors in interface AsyncAdminincludeSysTables - False to match only against userspace tablesCompletableFuture.public CompletableFuture<List<TableDescriptor>> listTableDescriptors(Pattern pattern, boolean includeSysTables)
listTableDescriptors in interface AsyncAdminpattern - The compiled regular expression to match againstincludeSysTables - False to match only against userspace tablesCompletableFuture.private CompletableFuture<List<TableDescriptor>> getTableDescriptors(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableDescriptorsRequest request)
public CompletableFuture<List<TableName>> listTableNames(boolean includeSysTables)
AsyncAdminlistTableNames in interface AsyncAdminincludeSysTables - False to match only against userspace tablesCompletableFuture.public CompletableFuture<List<TableName>> listTableNames(Pattern pattern, boolean includeSysTables)
AsyncAdminlistTableNames in interface AsyncAdminpattern - The regular expression to match againstincludeSysTables - False to match only against userspace tablesCompletableFuture.private CompletableFuture<List<TableName>> getTableNames(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableNamesRequest request)
public CompletableFuture<List<TableDescriptor>> listTableDescriptorsByNamespace(String name)
AsyncAdminlistTableDescriptorsByNamespace in interface AsyncAdminname - namespace nameCompletableFuture.public CompletableFuture<List<TableName>> listTableNamesByNamespace(String name)
AsyncAdminlistTableNamesByNamespace in interface AsyncAdminname - namespace nameCompletableFuture.public CompletableFuture<TableDescriptor> getDescriptor(TableName tableName)
AsyncAdmingetDescriptor in interface AsyncAdmintableName - as a TableNameCompletableFuture.public CompletableFuture<Void> createTable(TableDescriptor desc)
AsyncAdmincreateTable in interface AsyncAdmindesc - table descriptor for tablepublic CompletableFuture<Void> createTable(TableDescriptor desc, byte[] startKey, byte[] endKey, int numRegions)
AsyncAdmincreateTable in interface AsyncAdmindesc - table descriptor for tablestartKey - beginning of key rangeendKey - end of key rangenumRegions - the total number of regions to createpublic CompletableFuture<Void> createTable(TableDescriptor desc, byte[][] splitKeys)
AsyncAdmincreateTable in interface AsyncAdmindesc - table descriptor for tablesplitKeys - array of split keys for the initial regions of the tableprivate CompletableFuture<Void> createTable(TableName tableName, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateTableRequest request)
public CompletableFuture<Void> modifyTable(TableDescriptor desc)
AsyncAdminmodifyTable in interface AsyncAdmindesc - modified description of the tablepublic CompletableFuture<Void> deleteTable(TableName tableName)
AsyncAdmindeleteTable in interface AsyncAdmintableName - name of table to deletepublic CompletableFuture<Void> truncateTable(TableName tableName, boolean preserveSplits)
AsyncAdmintruncateTable in interface AsyncAdmintableName - name of table to truncatepreserveSplits - True if the splits should be preservedpublic CompletableFuture<Void> enableTable(TableName tableName)
AsyncAdminenableTable in interface AsyncAdmintableName - name of the tablepublic CompletableFuture<Void> disableTable(TableName tableName)
AsyncAdmindisableTable in interface AsyncAdminpublic CompletableFuture<Boolean> isTableEnabled(TableName tableName)
isTableEnabled in interface AsyncAdmintableName - name of table to checkCompletableFuture.public CompletableFuture<Boolean> isTableDisabled(TableName tableName)
isTableDisabled in interface AsyncAdmintableName - name of table to checkCompletableFuture.public CompletableFuture<Boolean> isTableAvailable(TableName tableName)
isTableAvailable in interface AsyncAdmintableName - name of table to checkCompletableFuture.public CompletableFuture<Boolean> isTableAvailable(TableName tableName, byte[][] splitKeys)
AsyncAdminCompletableFuture.isTableAvailable in interface AsyncAdmintableName - name of table to checksplitKeys - keys to check if the table has been created with all split keysprivate CompletableFuture<Boolean> isTableAvailable(TableName tableName, Optional<byte[][]> splitKeys)
private boolean compareRegionsWithSplitKeys(List<HRegionLocation> locations, byte[][] splitKeys)
public CompletableFuture<Void> addColumnFamily(TableName tableName, ColumnFamilyDescriptor columnFamily)
AsyncAdminaddColumnFamily in interface AsyncAdmintableName - name of the table to add column family tocolumnFamily - column family descriptor of column family to be addedpublic CompletableFuture<Void> deleteColumnFamily(TableName tableName, byte[] columnFamily)
AsyncAdmindeleteColumnFamily in interface AsyncAdmintableName - name of tablecolumnFamily - name of column family to be deletedpublic CompletableFuture<Void> modifyColumnFamily(TableName tableName, ColumnFamilyDescriptor columnFamily)
AsyncAdminmodifyColumnFamily in interface AsyncAdmintableName - name of tablecolumnFamily - new column family descriptor to usepublic CompletableFuture<Void> createNamespace(NamespaceDescriptor descriptor)
AsyncAdmincreateNamespace in interface AsyncAdmindescriptor - descriptor which describes the new namespacepublic CompletableFuture<Void> modifyNamespace(NamespaceDescriptor descriptor)
AsyncAdminmodifyNamespace in interface AsyncAdmindescriptor - descriptor which describes the new namespacepublic CompletableFuture<Void> deleteNamespace(String name)
AsyncAdmindeleteNamespace in interface AsyncAdminname - namespace namepublic CompletableFuture<NamespaceDescriptor> getNamespaceDescriptor(String name)
AsyncAdmingetNamespaceDescriptor in interface AsyncAdminname - name of namespace descriptorCompletableFuture.public CompletableFuture<List<NamespaceDescriptor>> listNamespaceDescriptors()
AsyncAdminlistNamespaceDescriptors in interface AsyncAdminCompletableFuture.public CompletableFuture<List<RegionInfo>> getRegions(ServerName serverName)
AsyncAdmingetRegions in interface AsyncAdminpublic CompletableFuture<List<RegionInfo>> getRegions(TableName tableName)
AsyncAdmingetRegions in interface AsyncAdminpublic CompletableFuture<Void> flush(TableName tableName)
AsyncAdminflush in interface AsyncAdmintableName - table to flushpublic CompletableFuture<Void> flushRegion(byte[] regionName)
AsyncAdminflushRegion in interface AsyncAdminregionName - region to flushprivate CompletableFuture<Void> flush(ServerName serverName, RegionInfo regionInfo)
public CompletableFuture<Void> flushRegionServer(ServerName sn)
AsyncAdminflushRegionServer in interface AsyncAdminsn - server to flushpublic CompletableFuture<Void> compact(TableName tableName, CompactType compactType)
AsyncAdminTableNotFoundException if table not found for
normal compaction type.compact in interface AsyncAdmintableName - table to compactcompactType - CompactTypepublic CompletableFuture<Void> compact(TableName tableName, byte[] columnFamily, CompactType compactType)
AsyncAdminTableNotFoundException if table not found for
normal compaction type.compact in interface AsyncAdmintableName - table to compactcolumnFamily - column family within a tablecompactType - CompactTypepublic CompletableFuture<Void> compactRegion(byte[] regionName)
AsyncAdmincompactRegion in interface AsyncAdminregionName - region to compactpublic CompletableFuture<Void> compactRegion(byte[] regionName, byte[] columnFamily)
AsyncAdmincompactRegion in interface AsyncAdminregionName - region to compactcolumnFamily - column family within a region. If not present, compact the region's all
column families.public CompletableFuture<Void> majorCompact(TableName tableName, CompactType compactType)
AsyncAdminTableNotFoundException if table not found for
normal compaction type.majorCompact in interface AsyncAdmintableName - table to major compactcompactType - CompactTypepublic CompletableFuture<Void> majorCompact(TableName tableName, byte[] columnFamily, CompactType compactType)
AsyncAdminTableNotFoundException if table not found.majorCompact in interface AsyncAdmintableName - table to major compactcolumnFamily - column family within a table. If not present, major compact the table's all
column families.compactType - CompactTypepublic CompletableFuture<Void> majorCompactRegion(byte[] regionName)
AsyncAdminmajorCompactRegion in interface AsyncAdminregionName - region to major compactpublic CompletableFuture<Void> majorCompactRegion(byte[] regionName, byte[] columnFamily)
AsyncAdminmajorCompactRegion in interface AsyncAdminregionName - region to major compactcolumnFamily - column family within a region. If not present, major compact the region's
all column families.public CompletableFuture<Void> compactRegionServer(ServerName sn)
AsyncAdmincompactRegionServer in interface AsyncAdminsn - the region server namepublic CompletableFuture<Void> majorCompactRegionServer(ServerName sn)
AsyncAdminmajorCompactRegionServer in interface AsyncAdminsn - the region server nameprivate CompletableFuture<Void> compactRegionServer(ServerName sn, boolean major)
private CompletableFuture<Void> compactRegion(byte[] regionName, byte[] columnFamily, boolean major)
private CompletableFuture<List<HRegionLocation>> getTableHRegionLocations(TableName tableName)
private CompletableFuture<Void> compact(TableName tableName, byte[] columnFamily, boolean major, CompactType compactType)
private CompletableFuture<Void> compact(ServerName sn, RegionInfo hri, boolean major, byte[] columnFamily)
private byte[] toEncodeRegionName(byte[] regionName)
private void checkAndGetTableName(byte[] encodeRegionName, AtomicReference<TableName> tableName, CompletableFuture<TableName> result)
private CompletableFuture<TableName> checkRegionsAndGetTableName(byte[] encodeRegionNameA, byte[] encodeRegionNameB)
public CompletableFuture<Boolean> mergeSwitch(boolean on)
AsyncAdminmergeSwitch in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> isMergeEnabled()
AsyncAdminisMergeEnabled in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> splitSwitch(boolean on)
AsyncAdminsplitSwitch in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> isSplitEnabled()
AsyncAdminisSplitEnabled in interface AsyncAdminCompletableFutureprivate CompletableFuture<Boolean> setSplitOrMergeOn(boolean on, MasterSwitchType switchType)
private CompletableFuture<Boolean> isSplitOrMergeOn(MasterSwitchType switchType)
public CompletableFuture<Void> mergeRegions(byte[] nameOfRegionA, byte[] nameOfRegionB, boolean forcible)
AsyncAdminmergeRegions in interface AsyncAdminnameOfRegionA - encoded or full name of region anameOfRegionB - encoded or full name of region bforcible - true if do a compulsory merge, otherwise we will only merge two adjacent
regionspublic CompletableFuture<Void> split(TableName tableName)
AsyncAdminsplit in interface AsyncAdmintableName - table to splitpublic CompletableFuture<Void> split(TableName tableName, byte[] splitPoint)
AsyncAdminsplit in interface AsyncAdmintableName - table to splitsplitPoint - the explicit position to split onpublic CompletableFuture<Void> splitRegion(byte[] regionName)
AsyncAdminsplitRegion in interface AsyncAdminregionName - region to splitpublic CompletableFuture<Void> splitRegion(byte[] regionName, byte[] splitPoint)
AsyncAdminsplitRegion in interface AsyncAdminregionName - region to splitsplitPoint - the explicit position to split on. If not present, it will decide by region
server.private CompletableFuture<Void> split(RegionInfo hri, byte[] splitPoint)
public CompletableFuture<Void> assign(byte[] regionName)
assign in interface AsyncAdminregionName - Encoded or full name of region to assign.public CompletableFuture<Void> unassign(byte[] regionName, boolean forcible)
AsyncAdminAsyncAdmin.move(byte[], ServerName) if you want to control the region movement.unassign in interface AsyncAdminregionName - Encoded or full name of region to unassign. Will clear any existing
RegionPlan if one found.forcible - If true, force unassign (Will remove region from regions-in-transition too if
present. If results in double assignment use hbck -fix to resolve. To be used by
experts).public CompletableFuture<Void> offline(byte[] regionName)
AsyncAdminoffline in interface AsyncAdminregionName - Encoded or full name of region to offlinepublic CompletableFuture<Void> move(byte[] regionName)
AsyncAdminr to a random server.move in interface AsyncAdminregionName - Encoded or full name of region to move.public CompletableFuture<Void> move(byte[] regionName, ServerName destServerName)
AsyncAdminr to dest.move in interface AsyncAdminregionName - Encoded or full name of region to move.destServerName - The servername of the destination regionserver. If not present, we'll
assign to a random server. A server name is made of host, port and startcode. Here is
an example: host187.example.com,60020,1289493121758private CompletableFuture<Void> moveRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MoveRegionRequest request)
public CompletableFuture<Void> setQuota(QuotaSettings quota)
AsyncAdminsetQuota in interface AsyncAdminquota - the quota settingspublic CompletableFuture<List<QuotaSettings>> getQuota(QuotaFilter filter)
AsyncAdmingetQuota in interface AsyncAdminfilter - the quota settings filterpublic CompletableFuture<Void> addReplicationPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled)
AsyncAdminaddReplicationPeer in interface AsyncAdminpeerId - a short name that identifies the peerpeerConfig - configuration for the replication slave clusterenabled - peer state, true if ENABLED and false if DISABLEDpublic CompletableFuture<Void> removeReplicationPeer(String peerId)
AsyncAdminremoveReplicationPeer in interface AsyncAdminpeerId - a short name that identifies the peerpublic CompletableFuture<Void> enableReplicationPeer(String peerId)
AsyncAdminenableReplicationPeer in interface AsyncAdminpeerId - a short name that identifies the peerpublic CompletableFuture<Void> disableReplicationPeer(String peerId)
AsyncAdmindisableReplicationPeer in interface AsyncAdminpeerId - a short name that identifies the peerpublic CompletableFuture<ReplicationPeerConfig> getReplicationPeerConfig(String peerId)
AsyncAdmingetReplicationPeerConfig in interface AsyncAdminpeerId - a short name that identifies the peerCompletableFuture.public CompletableFuture<Void> updateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig)
AsyncAdminupdateReplicationPeerConfig in interface AsyncAdminpeerId - a short name that identifies the peerpeerConfig - new config for the peerpublic CompletableFuture<Void> appendReplicationPeerTableCFs(String id, Map<TableName,List<String>> tableCfs)
AsyncAdminappendReplicationPeerTableCFs in interface AsyncAdminid - a short that identifies the clustertableCfs - A map from tableName to column family namespublic CompletableFuture<Void> removeReplicationPeerTableCFs(String id, Map<TableName,List<String>> tableCfs)
AsyncAdminremoveReplicationPeerTableCFs in interface AsyncAdminid - a short name that identifies the clustertableCfs - A map from tableName to column family namespublic CompletableFuture<List<ReplicationPeerDescription>> listReplicationPeers()
AsyncAdminlistReplicationPeers in interface AsyncAdminCompletableFuture.public CompletableFuture<List<ReplicationPeerDescription>> listReplicationPeers(Pattern pattern)
AsyncAdminlistReplicationPeers in interface AsyncAdminpattern - The compiled regular expression to match peer idCompletableFuture.private CompletableFuture<List<ReplicationPeerDescription>> listReplicationPeers(org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ListReplicationPeersRequest request)
public CompletableFuture<List<TableCFs>> listReplicatedTableCFs()
AsyncAdminlistReplicatedTableCFs in interface AsyncAdminCompletableFuture.public CompletableFuture<Void> snapshot(SnapshotDescription snapshotDesc)
AsyncAdminSnapshotCreationException
indicating the duplicate naming. Snapshot names follow the same naming constraints as tables in
HBase. See TableName.isLegalFullyQualifiedTableName(byte[]).
You should probably use AsyncAdmin.snapshot(String, org.apache.hadoop.hbase.TableName) unless you
are sure about the type of snapshot that you want to take.snapshot in interface AsyncAdminsnapshotDesc - snapshot to takepublic CompletableFuture<Boolean> isSnapshotFinished(SnapshotDescription snapshot)
AsyncAdminUnknownSnapshotException.isSnapshotFinished in interface AsyncAdminsnapshot - description of the snapshot to checkpublic CompletableFuture<Void> restoreSnapshot(String snapshotName)
AsyncAdminrestoreSnapshot in interface AsyncAdminsnapshotName - name of the snapshot to restorepublic CompletableFuture<Void> restoreSnapshot(String snapshotName, boolean takeFailSafeSnapshot)
AsyncAdminrestoreSnapshot in interface AsyncAdminsnapshotName - name of the snapshot to restoretakeFailSafeSnapshot - true if the failsafe snapshot should be takenprivate CompletableFuture<Void> restoreSnapshot(String snapshotName, TableName tableName, boolean takeFailSafeSnapshot)
private <T> void completeConditionalOnFuture(CompletableFuture<T> dependentFuture, CompletableFuture<T> parentFuture)
public CompletableFuture<Void> cloneSnapshot(String snapshotName, TableName tableName)
AsyncAdmincloneSnapshot in interface AsyncAdminsnapshotName - name of the snapshot to be clonedtableName - name of the table where the snapshot will be restoredprivate CompletableFuture<Void> internalRestoreSnapshot(String snapshotName, TableName tableName)
public CompletableFuture<List<SnapshotDescription>> listSnapshots()
AsyncAdminlistSnapshots in interface AsyncAdminCompletableFuturepublic CompletableFuture<List<SnapshotDescription>> listSnapshots(Pattern pattern)
AsyncAdminlistSnapshots in interface AsyncAdminpattern - The compiled regular expression to match againstCompletableFutureprivate CompletableFuture<List<SnapshotDescription>> getCompletedSnapshots(Pattern pattern)
public CompletableFuture<List<SnapshotDescription>> listTableSnapshots(Pattern tableNamePattern)
AsyncAdminlistTableSnapshots in interface AsyncAdmintableNamePattern - The compiled table name regular expression to match againstCompletableFuturepublic CompletableFuture<List<SnapshotDescription>> listTableSnapshots(Pattern tableNamePattern, Pattern snapshotNamePattern)
AsyncAdminlistTableSnapshots in interface AsyncAdmintableNamePattern - The compiled table name regular expression to match againstsnapshotNamePattern - The compiled snapshot name regular expression to match againstCompletableFutureprivate CompletableFuture<List<SnapshotDescription>> getCompletedSnapshots(Pattern tableNamePattern, Pattern snapshotNamePattern)
public CompletableFuture<Void> deleteSnapshot(String snapshotName)
AsyncAdmindeleteSnapshot in interface AsyncAdminsnapshotName - name of the snapshotpublic CompletableFuture<Void> deleteSnapshots()
AsyncAdmindeleteSnapshots in interface AsyncAdminpublic CompletableFuture<Void> deleteSnapshots(Pattern snapshotNamePattern)
AsyncAdmindeleteSnapshots in interface AsyncAdminsnapshotNamePattern - pattern for names of the snapshot to matchpublic CompletableFuture<Void> deleteTableSnapshots(Pattern tableNamePattern)
AsyncAdmindeleteTableSnapshots in interface AsyncAdmintableNamePattern - The compiled table name regular expression to match againstpublic CompletableFuture<Void> deleteTableSnapshots(Pattern tableNamePattern, Pattern snapshotNamePattern)
AsyncAdmindeleteTableSnapshots in interface AsyncAdmintableNamePattern - The compiled table name regular expression to match againstsnapshotNamePattern - The compiled snapshot name regular expression to match againstprivate CompletableFuture<Void> internalDeleteSnapshots(Pattern tableNamePattern, Pattern snapshotNamePattern)
private CompletableFuture<Void> internalDeleteSnapshot(SnapshotDescription snapshot)
public CompletableFuture<Void> execProcedure(String signature, String instance, Map<String,String> props)
AsyncAdminexecProcedure in interface AsyncAdminsignature - A distributed procedure is uniquely identified by its signature (default the
root ZK node name of the procedure).instance - The instance name of the procedure. For some procedures, this parameter is
optional.props - Property/Value pairs of properties passing to the procedurepublic CompletableFuture<byte[]> execProcedureWithReturn(String signature, String instance, Map<String,String> props)
AsyncAdminexecProcedureWithReturn in interface AsyncAdminsignature - A distributed procedure is uniquely identified by its signature (default the
root ZK node name of the procedure).instance - The instance name of the procedure. For some procedures, this parameter is
optional.props - Property/Value pairs of properties passing to the procedurepublic CompletableFuture<Boolean> isProcedureFinished(String signature, String instance, Map<String,String> props)
AsyncAdminisProcedureFinished in interface AsyncAdminsignature - The signature that uniquely identifies a procedureinstance - The instance name of the procedureprops - Property/Value pairs of properties passing to the procedureCompletableFuturepublic CompletableFuture<Boolean> abortProcedure(long procId, boolean mayInterruptIfRunning)
AsyncAdminabortProcedure in interface AsyncAdminprocId - ID of the procedure to abortmayInterruptIfRunning - if the proc completed at least one step, should it be aborted?CompletableFuturepublic CompletableFuture<String> getProcedures()
AsyncAdmingetProcedures in interface AsyncAdminCompletableFuturepublic CompletableFuture<String> getLocks()
AsyncAdmingetLocks in interface AsyncAdminCompletableFuturepublic CompletableFuture<Void> decommissionRegionServers(List<ServerName> servers, boolean offload)
AsyncAdmindecommissionRegionServers in interface AsyncAdminservers - The list of servers to decommission.offload - True to offload the regions from the decommissioned serverspublic CompletableFuture<List<ServerName>> listDecommissionedRegionServers()
AsyncAdminlistDecommissionedRegionServers in interface AsyncAdminCompletableFuturepublic CompletableFuture<Void> recommissionRegionServer(ServerName server, List<byte[]> encodedRegionNames)
AsyncAdminrecommissionRegionServer in interface AsyncAdminserver - The server to recommission.encodedRegionNames - Regions to load onto the server.CompletableFuture<HRegionLocation> getRegionLocation(byte[] regionNameOrEncodedRegionName)
CompletableFutureregionNameOrEncodedRegionName - CompletableFutureprivate CompletableFuture<RegionInfo> getRegionInfo(byte[] regionNameOrEncodedRegionName)
CompletableFutureregionNameOrEncodedRegionName - CompletableFutureprivate byte[][] getSplitKeys(byte[] startKey, byte[] endKey, int numRegions)
private void verifySplitKeys(byte[][] splitKeys)
private CompletableFuture<Void> waitProcedureResult(CompletableFuture<Long> procFuture)
private void getProcedureResult(long procId, CompletableFuture<Void> future, int retries)
private <T> CompletableFuture<T> failedFuture(Throwable error)
private <T> boolean completeExceptionally(CompletableFuture<T> future, Throwable error)
public CompletableFuture<ClusterMetrics> getClusterMetrics()
getClusterMetrics in interface AsyncAdminCompletableFuturepublic CompletableFuture<ClusterMetrics> getClusterMetrics(EnumSet<ClusterMetrics.Option> options)
getClusterMetrics in interface AsyncAdminCompletableFuturepublic CompletableFuture<Void> shutdown()
AsyncAdminshutdown in interface AsyncAdminpublic CompletableFuture<Void> stopMaster()
AsyncAdminstopMaster in interface AsyncAdminpublic CompletableFuture<Void> stopRegionServer(ServerName serverName)
AsyncAdminstopRegionServer in interface AsyncAdminpublic CompletableFuture<Void> updateConfiguration(ServerName serverName)
AsyncAdminupdateConfiguration in interface AsyncAdminserverName - : The server whose config needs to be updated.public CompletableFuture<Void> updateConfiguration()
AsyncAdminupdateConfiguration in interface AsyncAdminpublic CompletableFuture<Void> rollWALWriter(ServerName serverName)
AsyncAdminWhen the returned CompletableFuture is done, it only means the rollWALWriter request was sent to the region server and may need some time to finish the rollWALWriter operation. As a side effect of this call, the named region server may schedule store flushes at the request of the wal.
rollWALWriter in interface AsyncAdminserverName - The servername of the region server.public CompletableFuture<Void> clearCompactionQueues(ServerName serverName, Set<String> queues)
AsyncAdminclearCompactionQueues in interface AsyncAdminqueues - the set of queue namepublic CompletableFuture<List<SecurityCapability>> getSecurityCapabilities()
getSecurityCapabilities in interface AsyncAdminCompletableFuture.public CompletableFuture<List<RegionMetrics>> getRegionMetrics(ServerName serverName)
AsyncAdminRegionMetrics of all regions hosted on a region seerver.getRegionMetrics in interface AsyncAdminRegionMetrics wrapped by CompletableFuturepublic CompletableFuture<List<RegionMetrics>> getRegionMetrics(ServerName serverName, TableName tableName)
AsyncAdminRegionMetrics of all regions hosted on a region seerver for a table.getRegionMetrics in interface AsyncAdminRegionMetrics wrapped by CompletableFutureprivate CompletableFuture<List<RegionMetrics>> getRegionMetrics(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request, ServerName serverName)
public CompletableFuture<Boolean> isMasterInMaintenanceMode()
AsyncAdminisMasterInMaintenanceMode in interface AsyncAdminCompletableFuturepublic CompletableFuture<CompactionState> getCompactionState(TableName tableName, CompactType compactType)
AsyncAdmingetCompactionState in interface AsyncAdmintableName - table to examinecompactType - CompactTypeCompletableFuturepublic CompletableFuture<CompactionState> getCompactionStateForRegion(byte[] regionName)
AsyncAdmingetCompactionStateForRegion in interface AsyncAdminregionName - region to examineCompletableFuturepublic CompletableFuture<Optional<Long>> getLastMajorCompactionTimestamp(TableName tableName)
AsyncAdminThe timestamp of the oldest HFile resulting from a major compaction of that table, or not present if no such HFile could be found.
getLastMajorCompactionTimestamp in interface AsyncAdmintableName - table to examineCompletableFuturepublic CompletableFuture<Optional<Long>> getLastMajorCompactionTimestampForRegion(byte[] regionName)
AsyncAdminThe timestamp of the oldest HFile resulting from a major compaction of that region, or not present if no such HFile could be found.
getLastMajorCompactionTimestampForRegion in interface AsyncAdminregionName - region to examineCompletableFuturepublic CompletableFuture<Boolean> balancerSwitch(boolean on)
AsyncAdminbalancerSwitch in interface AsyncAdminCompletableFuture.public CompletableFuture<Boolean> balance(boolean forcible)
AsyncAdminbalance in interface AsyncAdminforcible - whether we should force balance even if there is region in transition.CompletableFuture.public CompletableFuture<Boolean> isBalancerEnabled()
AsyncAdminisBalancerEnabled in interface AsyncAdminCompletableFuture.public CompletableFuture<Boolean> normalizerSwitch(boolean on)
AsyncAdminnormalizerSwitch in interface AsyncAdminon - whether normalizer should be on or offCompletableFuturepublic CompletableFuture<Boolean> isNormalizerEnabled()
AsyncAdminisNormalizerEnabled in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> normalize()
AsyncAdminnormalize in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> cleanerChoreSwitch(boolean enabled)
AsyncAdmincleanerChoreSwitch in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> isCleanerChoreEnabled()
AsyncAdminisCleanerChoreEnabled in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> runCleanerChore()
AsyncAdminrunCleanerChore in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> catalogJanitorSwitch(boolean enabled)
AsyncAdmincatalogJanitorSwitch in interface AsyncAdminCompletableFuturepublic CompletableFuture<Boolean> isCatalogJanitorEnabled()
AsyncAdminisCatalogJanitorEnabled in interface AsyncAdminCompletableFuturepublic CompletableFuture<Integer> runCatalogJanitor()
AsyncAdminrunCatalogJanitor in interface AsyncAdminCompletableFuturepublic <S,R> CompletableFuture<R> coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker, ServiceCaller<S,R> callable)
AsyncAdmin
The stubMaker is just a delegation to the newStub call. Usually it is only a
one line lambda expression, like:
channel -> xxxService.newStub(channel)
coprocessorService in interface AsyncAdminS - the type of the asynchronous stubR - the type of the return valuestubMaker - a delegation to the actual newStub call.callable - a delegation to the actual protobuf rpc call. See the comment of
ServiceCaller for more details.CompletableFuture.ServiceCallerpublic <S,R> CompletableFuture<R> coprocessorService(Function<com.google.protobuf.RpcChannel,S> stubMaker, ServiceCaller<S,R> callable, ServerName serverName)
AsyncAdmin
The stubMaker is just a delegation to the newStub call. Usually it is only a
one line lambda expression, like:
channel -> xxxService.newStub(channel)
coprocessorService in interface AsyncAdminS - the type of the asynchronous stubR - the type of the return valuestubMaker - a delegation to the actual newStub call.callable - a delegation to the actual protobuf rpc call. See the comment of
ServiceCaller for more details.serverName - the given region serverCompletableFuture.ServiceCallerpublic CompletableFuture<List<ServerName>> clearDeadServers(List<ServerName> servers)
AsyncAdminclearDeadServers in interface AsyncAdminservers - list of dead region servers.CompletableFuture.private <T> AsyncRpcRetryingCallerFactory.ServerRequestCallerBuilder<T> newServerCaller()
public CompletableFuture<Void> enableTableReplication(TableName tableName)
AsyncAdminenableTableReplication in interface AsyncAdmintableName - name of the tablepublic CompletableFuture<Void> disableTableReplication(TableName tableName)
AsyncAdmindisableTableReplication in interface AsyncAdmintableName - name of the tableprivate CompletableFuture<byte[][]> getTableSplits(TableName tableName)
private CompletableFuture<Void> checkAndSyncTableToPeerClusters(TableName tableName, byte[][] splits)
tableName - name of the table to sync to the peersplits - table split keysprivate CompletableFuture<Void> trySyncTableToPeerCluster(TableName tableName, byte[][] splits, ReplicationPeerDescription peer)
private CompletableFuture<Void> compareTableWithPeerCluster(TableName tableName, TableDescriptor tableDesc, ReplicationPeerDescription peer, AsyncAdmin peerAdmin)
private CompletableFuture<Void> setTableReplication(TableName tableName, boolean enableRep)
tableName - name of the tableenableRep - is replication switch enable or disablepublic CompletableFuture<CacheEvictionStats> clearBlockCache(TableName tableName)
AsyncAdminclearBlockCache in interface AsyncAdmintableName - table to clear block cacheCompletableFuture.public CompletableFuture<Void> cloneTableSchema(TableName tableName, TableName newTableName, boolean preserveSplits)
AsyncAdmincloneTableSchema in interface AsyncAdmintableName - name of the table to be clonednewTableName - name of the new table where the table will be createdpreserveSplits - True if the splits should be preservedprivate CompletableFuture<CacheEvictionStats> clearBlockCache(ServerName serverName, List<RegionInfo> hris)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.