@InterfaceAudience.Private public class AsyncRegionServerAdmin extends Object
AdminProtos.AdminService
for a region server, which returns a
CompletableFuture
. This is easier to use, as if you use the raw protobuf interface, you
need to get the result from the RpcCallback
, and if there is an exception, you need to
get it from the RpcController
passed in.
Notice that there is no retry, and this is intentional. We have different retry for different
usage for now, if later we want to unify them, we can move the retry logic into this class.Modifier and Type | Class and Description |
---|---|
private static interface |
AsyncRegionServerAdmin.RpcCall<RESP> |
Modifier and Type | Field and Description |
---|---|
private AsyncConnectionImpl |
conn |
private ServerName |
server |
Constructor and Description |
---|
AsyncRegionServerAdmin(ServerName server,
AsyncConnectionImpl conn) |
Modifier and Type | Method and Description |
---|---|
private <RESP> CompletableFuture<RESP> |
call(AsyncRegionServerAdmin.RpcCall<RESP> rpcCall) |
private <RESP> CompletableFuture<RESP> |
call(AsyncRegionServerAdmin.RpcCall<RESP> rpcCall,
CellScanner cellScanner) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse> |
clearCompactionQueues(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheResponse> |
clearRegionBlockCache(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse> |
closeRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactionSwitchResponse> |
compactionSwitch(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactionSwitchRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse> |
compactRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse> |
executeProcedures(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse> |
flushRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionResponse> |
getOnlineRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse> |
getRegionInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse> |
getRegionLoad(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoResponse> |
getServerInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse> |
getSpaceQuotaSnapshots(org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileResponse> |
getStoreFile(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse> |
openRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse> |
replay(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request,
CellScanner cellScanner) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse> |
replicateWALEntry(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request,
CellScanner cellScanner,
int timeout) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterResponse> |
rollWALWriter(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerResponse> |
stopServer(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse> |
updateConfiguration(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesResponse> |
updateFavoredNodes(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest request) |
CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionResponse> |
warmupRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionRequest request) |
private final ServerName server
private final AsyncConnectionImpl conn
AsyncRegionServerAdmin(ServerName server, AsyncConnectionImpl conn)
private <RESP> CompletableFuture<RESP> call(AsyncRegionServerAdmin.RpcCall<RESP> rpcCall, CellScanner cellScanner)
private <RESP> CompletableFuture<RESP> call(AsyncRegionServerAdmin.RpcCall<RESP> rpcCall)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse> getRegionInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileResponse> getStoreFile(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionResponse> getOnlineRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse> openRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionResponse> warmupRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse> closeRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse> flushRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactionSwitchResponse> compactionSwitch(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactionSwitchRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse> compactRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse> replicateWALEntry(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request, CellScanner cellScanner, int timeout)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse> replay(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request, CellScanner cellScanner)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterResponse> rollWALWriter(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoResponse> getServerInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerResponse> stopServer(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesResponse> updateFavoredNodes(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse> updateConfiguration(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse> getRegionLoad(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse> clearCompactionQueues(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheResponse> clearRegionBlockCache(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse> getSpaceQuotaSnapshots(org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request)
public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse> executeProcedures(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.