Package org.apache.hadoop.hbase.client
Class AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
java.lang.Object
org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.BuilderBase
org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
- Enclosing class:
- AsyncRpcRetryingCallerFactory
-
Field Summary
Modifier and TypeFieldDescriptionprivate AdvancedScanResultConsumer
private boolean
private HRegionLocation
private int
private ScanResultCache
private long
private Scan
private ScanMetrics
private Long
private long
private long
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface
Fields inherited from class org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.BuilderBase
maxAttempts, pauseNs, pauseNsForServerOverloaded, startLogErrorsCnt
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionbuild()
consumer
(AdvancedScanResultConsumer consumer) id
(long scannerId) location
(HRegionLocation loc) maxAttempts
(int maxAttempts) metrics
(ScanMetrics scanMetrics) pauseForServerOverloaded
(long pause, TimeUnit unit) private void
preCheck()
remote
(boolean isRegionServerRemote) resultCache
(ScanResultCache resultCache) rpcTimeout
(long rpcTimeout, TimeUnit unit) scannerLeaseTimeoutPeriod
(long scannerLeaseTimeoutPeriod, TimeUnit unit) scanTimeout
(long scanTimeout, TimeUnit unit) setRequestAttributes
(Map<String, byte[]> requestAttributes) start
(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen) Short cut forbuild().start(HBaseRpcController, ScanResponse)
.startLogErrorsCnt
(int startLogErrorsCnt) stub
(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
-
Field Details
-
scannerId
-
scan
-
scanMetrics
-
resultCache
-
consumer
-
stub
-
loc
-
isRegionServerRemote
-
scannerLeaseTimeoutPeriodNs
-
scanTimeoutNs
-
rpcTimeoutNs
-
priority
-
requestAttributes
-
-
Constructor Details
-
ScanSingleRegionCallerBuilder
public ScanSingleRegionCallerBuilder()
-
-
Method Details
-
id
-
setScan
-
metrics
-
remote
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder remote(boolean isRegionServerRemote) -
resultCache
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder resultCache(ScanResultCache resultCache) -
consumer
-
stub
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder stub(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub) -
location
-
scannerLeaseTimeoutPeriod
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder scannerLeaseTimeoutPeriod(long scannerLeaseTimeoutPeriod, TimeUnit unit) -
scanTimeout
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder scanTimeout(long scanTimeout, TimeUnit unit) -
rpcTimeout
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder rpcTimeout(long rpcTimeout, TimeUnit unit) -
pause
-
pauseForServerOverloaded
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder pauseForServerOverloaded(long pause, TimeUnit unit) -
maxAttempts
-
startLogErrorsCnt
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder startLogErrorsCnt(int startLogErrorsCnt) -
setRequestAttributes
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder setRequestAttributes(Map<String, byte[]> requestAttributes) -
preCheck
-
build
-
start
public CompletableFuture<Boolean> start(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen) Short cut forbuild().start(HBaseRpcController, ScanResponse)
.
-