public class AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder extends AsyncRpcRetryingCallerFactory.BuilderBase
Modifier and Type | Field and Description |
---|---|
private AdvancedScanResultConsumer |
consumer |
private boolean |
isRegionServerRemote |
private HRegionLocation |
loc |
private int |
priority |
private ScanResultCache |
resultCache |
private long |
rpcTimeoutNs |
private Scan |
scan |
private ScanMetrics |
scanMetrics |
private Long |
scannerId |
private long |
scannerLeaseTimeoutPeriodNs |
private long |
scanTimeoutNs |
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface |
stub |
maxAttempts, pauseNs, pauseNsForServerOverloaded, startLogErrorsCnt
Constructor and Description |
---|
ScanSingleRegionCallerBuilder() |
private ScanMetrics scanMetrics
private ScanResultCache resultCache
private AdvancedScanResultConsumer consumer
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub
private HRegionLocation loc
private boolean isRegionServerRemote
private long scannerLeaseTimeoutPeriodNs
private long scanTimeoutNs
private long rpcTimeoutNs
private int priority
public ScanSingleRegionCallerBuilder()
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder id(long scannerId)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder setScan(Scan scan)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder metrics(ScanMetrics scanMetrics)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder remote(boolean isRegionServerRemote)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder resultCache(ScanResultCache resultCache)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder consumer(AdvancedScanResultConsumer consumer)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder stub(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder location(HRegionLocation loc)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder scannerLeaseTimeoutPeriod(long scannerLeaseTimeoutPeriod, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder scanTimeout(long scanTimeout, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder rpcTimeout(long rpcTimeout, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder pause(long pause, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder pauseForServerOverloaded(long pause, TimeUnit unit)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder maxAttempts(int maxAttempts)
public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder startLogErrorsCnt(int startLogErrorsCnt)
private void preCheck()
public AsyncScanSingleRegionRpcRetryingCaller build()
public CompletableFuture<Boolean> start(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen)
build().start(HBaseRpcController, ScanResponse)
.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.