Package org.apache.hadoop.hbase.regionserver

Class TestScannerHeartbeatMessages.HeartbeatRPCServices

java.lang.Object
org.apache.hadoop.hbase.HBaseRpcServicesBase<org.apache.hadoop.hbase.regionserver.HRegionServer>
org.apache.hadoop.hbase.regionserver.RSRpcServices
org.apache.hadoop.hbase.regionserver.TestScannerHeartbeatMessages.HeartbeatRPCServices
All Implemented Interfaces:
org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler, org.apache.hadoop.hbase.ipc.PriorityFunction, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.BootstrapNodeProtos.BootstrapNodeService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface
Enclosing class:
TestScannerHeartbeatMessages
private static class TestScannerHeartbeatMessages.HeartbeatRPCServices extends org.apache.hadoop.hbase.regionserver.RSRpcServices
Custom RSRpcServices instance that allows heartbeat support to be toggled

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.RSRpcServices

    org.apache.hadoop.hbase.regionserver.RSRpcServices.RegionScannerContext, org.apache.hadoop.hbase.regionserver.RSRpcServices.RegionScannerHolder, org.apache.hadoop.hbase.regionserver.RSRpcServices.RegionScannersCloseCallBack

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private static boolean
    heartbeatsEnabled
     

    Fields inherited from class org.apache.hadoop.hbase.regionserver.RSRpcServices

    clearCompactionQueues, DEFAULT_REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA, REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS, REGIONSERVER_ADMIN_SERVICE_CONFIG, REGIONSERVER_BOOTSTRAP_NODES_SERVICE_CONFIG, REGIONSERVER_CLIENT_META_SERVICE_CONFIG, REGIONSERVER_CLIENT_SERVICE_CONFIG, requestCount, rpcFullScanRequestCount, rpcGetRequestCount, rpcMultiRequestCount, rpcMutateRequestCount, rpcScanRequestCount

    Fields inherited from class org.apache.hadoop.hbase.HBaseRpcServicesBase

    CLIENT_BOOTSTRAP_NODE_LIMIT, DEFAULT_CLIENT_BOOTSTRAP_NODE_LIMIT, priority, rpcServer, server

  • Constructor Summary

    Constructors
    Constructor
    Description
    HeartbeatRPCServices(org.apache.hadoop.hbase.regionserver.HRegionServer rs)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse
    scan(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request)
     

    Methods inherited from class org.apache.hadoop.hbase.regionserver.RSRpcServices

    addSize, bulkLoadHFile, checkOpen, checkQuotaAndGetRegionScannerContext, cleanupBulkLoad, clearCompactionQueues, clearRegionBlockCache, closeRegion, compactionSwitch, compactRegion, createPriority, createRpcServer, defaultReservoirEnabled, execRegionServerService, execService, executeProcedures, flushRegion, get, getAllBootstrapNodes, getCachedFilesList, getDefaultPort, getDNSServerType, getHostname, getOnlineRegion, getPortConfigName, getPriority, getRegion, getRegionInfo, getRegionLoad, getRemoteClientIpAndPort, getRpcSchedulerFactoryClass, getRpcSchedulerFactoryClass, getScanDetailsWithId, getScanDetailsWithRequest, getScanner, getScannersCount, getScannerVirtualTime, getServerInfo, getServices, getSpaceQuotaSnapshots, getStoreFile, getTimeLimit, getUserName, multi, mutate, onConfigurationChange, openRegion, prepareBulkLoad, replay, replicateToReplica, replicateWALEntry, rollWALWriter, start, stop, stopServer, updateFavoredNodes, warmupRegion

    Methods inherited from class org.apache.hadoop.hbase.HBaseRpcServicesBase

    checkOOME, clearSlowLogsResponses, getAccessChecker, getActiveMaster, getBootstrapNodes, getClusterId, getConfiguration, getDeadline, getLogEntries, getMasters, getMetaRegionLocations, getPriority, getRpcScheduler, getRpcServer, getServer, getSocketAddress, getZkPermissionWatcher, internalStart, internalStop, requirePermission, updateConfiguration

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

  • Method Details

    • scan

      public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse scan(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request) throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
      Specified by:
      scan in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface
      Overrides:
      scan in class org.apache.hadoop.hbase.regionserver.RSRpcServices
      Throws:
      org.apache.hbase.thirdparty.com.google.protobuf.ServiceException