private static class TestScannerTimeoutHandling.RSRpcServicesWithScanTimeout extends org.apache.hadoop.hbase.regionserver.RSRpcServices
Modifier and Type | Field and Description |
---|---|
private static boolean |
caughtTimeoutException |
private static Lock |
lock |
private static int |
scannerCount |
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
Constructor and Description |
---|
RSRpcServicesWithScanTimeout(org.apache.hadoop.hbase.regionserver.HRegionServer rs) |
Modifier and Type | Method and 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) |
addSize, bulkLoadHFile, checkOpen, 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
checkOOME, clearSlowLogsResponses, getAccessChecker, getActiveMaster, getBootstrapNodes, getClusterId, getConfiguration, getDeadline, getLogEntries, getMasters, getMetaRegionLocations, getPriority, getRpcScheduler, getRpcServer, getServer, getSocketAddress, getZkPermissionWatcher, internalStart, internalStop, requirePermission, updateConfiguration
private static boolean caughtTimeoutException
private static int scannerCount
public RSRpcServicesWithScanTimeout(org.apache.hadoop.hbase.regionserver.HRegionServer rs) throws IOException
IOException
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
scan
in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface
scan
in class org.apache.hadoop.hbase.regionserver.RSRpcServices
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.