org.apache.hadoop.hbase.client

Class TestClientScannerRPCTimeout.RSRpcServicesWithScanTimeout

java.lang.Object

org.apache.hadoop.hbase.regionserver.RSRpcServices

org.apache.hadoop.hbase.client.TestClientScannerRPCTimeout.RSRpcServicesWithScanTimeout

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.ClientProtos.ClientService.BlockingInterface

Enclosing class:

TestClientScannerRPCTimeout

private static class TestClientScannerRPCTimeout.RSRpcServicesWithScanTimeout
extends org.apache.hadoop.hbase.regionserver.RSRpcServices

Field Summary

Fields

Modifier and Type	Field and Description
private static long	seqNoToSleepOn
private static boolean	sleepAlways
private boolean	slept
private long	tableScannerId
private static int	tryNumber

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

accessChecker, LOG, REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS, REGIONSERVER_ADMIN_SERVICE_CONFIG, REGIONSERVER_CLIENT_SERVICE_CONFIG, RESERVOIR_ENABLED_KEY

Constructor Summary

Constructors

Constructor and Description
RSRpcServicesWithScanTimeout(org.apache.hadoop.hbase.regionserver.HRegionServer rs)

Method Summary

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)

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

bulkLoadHFile, checkOOME, checkOpen, cleanupBulkLoad, clearCompactionQueues, clearRegionBlockCache, closeRegion, compactRegion, createPriority, createRpcServer, execRegionServerService, execService, executeProcedures, exitIfOOME, flushRegion, get, getConfiguration, getDeadline, getHostname, getOnlineRegion, getPriority, getPriority, getRegion, getRegionInfo, getRegionLoad, getScanDetailsWithId, getScanner, getScannersCount, getServerInfo, getServices, getSocketAddress, getSpaceQuotaSnapshots, getStoreFile, multi, mutate, onConfigurationChange, openRegion, prepareBulkLoad, replay, replicateWALEntry, requirePermission, rollWALWriter, stopServer, updateConfiguration, updateFavoredNodes, warmupRegion

Methods inherited from class java.lang.Object

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

Field Detail

tableScannerId

private long tableScannerId

slept

private boolean slept

seqNoToSleepOn

private static long seqNoToSleepOn

sleepAlways

private static boolean sleepAlways

tryNumber

private static int tryNumber

Constructor Detail

RSRpcServicesWithScanTimeout

public RSRpcServicesWithScanTimeout(org.apache.hadoop.hbase.regionserver.HRegionServer rs)
                             throws IOException

Throws:

IOException

Method Detail

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