Package org.apache.hadoop.hbase.client

Class AsyncRegionServerAdmin

java.lang.Object
org.apache.hadoop.hbase.client.AsyncRegionServerAdmin
@Private public class AsyncRegionServerAdmin extends Object
A simple wrapper of the 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.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    private static interface 
    AsyncRegionServerAdmin.RpcCall<RESP>
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final AsyncConnectionImpl
    conn
     
    private final ServerName
    server
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AsyncRegionServerAdmin(ServerName server, AsyncConnectionImpl conn)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    private <RESP> CompletableFuture<RESP>
    call(AsyncRegionServerAdmin.RpcCall<RESP> rpcCall)
     
    private <RESP> CompletableFuture<RESP>
    call(AsyncRegionServerAdmin.RpcCall<RESP> rpcCall, ExtendedCellScanner 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, ExtendedCellScanner cellScanner)
     
    CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>
    replicateWALEntry(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request, ExtendedCellScanner 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)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

  • Method Details

    • call

      private <RESP> CompletableFuture<RESP> call(AsyncRegionServerAdmin.RpcCall<RESP> rpcCall, ExtendedCellScanner cellScanner)

    • call

      private <RESP> CompletableFuture<RESP> call(AsyncRegionServerAdmin.RpcCall<RESP> rpcCall)

    • getRegionInfo

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse> getRegionInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoRequest request)

    • getStoreFile

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileResponse> getStoreFile(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetStoreFileRequest request)

    • getOnlineRegion

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionResponse> getOnlineRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetOnlineRegionRequest request)

    • openRegion

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse> openRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest request)

    • warmupRegion

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionResponse> warmupRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WarmupRegionRequest request)

    • closeRegion

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse> closeRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest request)

    • flushRegion

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse> flushRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest request)

    • compactionSwitch

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactionSwitchResponse> compactionSwitch(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactionSwitchRequest request)

    • compactRegion

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse> compactRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest request)

    • replicateWALEntry

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse> replicateWALEntry(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request, ExtendedCellScanner cellScanner, int timeout)

    • replay

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse> replay(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryRequest request, ExtendedCellScanner cellScanner)

    • rollWALWriter

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterResponse> rollWALWriter(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.RollWALWriterRequest request)

    • getServerInfo

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoResponse> getServerInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetServerInfoRequest request)

    • stopServer

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerResponse> stopServer(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.StopServerRequest request)

    • updateFavoredNodes

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesResponse> updateFavoredNodes(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateFavoredNodesRequest request)

    • updateConfiguration

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse> updateConfiguration(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest request)

    • getRegionLoad

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse> getRegionLoad(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request)

    • clearCompactionQueues

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse> clearCompactionQueues(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest request)

    • clearRegionBlockCache

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheResponse> clearRegionBlockCache(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearRegionBlockCacheRequest request)

    • getSpaceQuotaSnapshots

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse> getSpaceQuotaSnapshots(org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request)

    • executeProcedures

      public CompletableFuture<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse> executeProcedures(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest request)