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

public class AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
extends AsyncRpcRetryingCallerFactory.BuilderBase

Field Summary

Fields

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

Fields inherited from class org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.BuilderBase

maxAttempts, pauseForCQTBENs, pauseNs, startLogErrorsCnt

Constructor Summary

Constructors

Constructor and Description
ScanSingleRegionCallerBuilder()

Method Summary

Modifier and Type	Method and Description
AsyncScanSingleRegionRpcRetryingCaller	build()
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	consumer(AdvancedScanResultConsumer consumer)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	id(long scannerId)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	location(HRegionLocation loc)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	maxAttempts(int maxAttempts)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	metrics(ScanMetrics scanMetrics)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	pause(long pause, TimeUnit unit)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	pauseForCQTBE(long pause, TimeUnit unit)
private void	preCheck()
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	remote(boolean isRegionServerRemote)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	resultCache(ScanResultCache resultCache)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	rpcTimeout(long rpcTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	scannerLeaseTimeoutPeriod(long scannerLeaseTimeoutPeriod, TimeUnit unit)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	scanTimeout(long scanTimeout, TimeUnit unit)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	setScan(Scan scan)
CompletableFuture<Boolean>	start(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen) Short cut for build().start(HBaseRpcController, ScanResponse).
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	startLogErrorsCnt(int startLogErrorsCnt)
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder	stub(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)

Methods inherited from class java.lang.Object

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

Field Detail

scannerId

private Long scannerId

scan

private Scan scan

scanMetrics

private ScanMetrics scanMetrics

resultCache

private ScanResultCache resultCache

consumer

private AdvancedScanResultConsumer consumer

stub

private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub

loc

private HRegionLocation loc

isRegionServerRemote

private boolean isRegionServerRemote

scannerLeaseTimeoutPeriodNs

private long scannerLeaseTimeoutPeriodNs

scanTimeoutNs

private long scanTimeoutNs

rpcTimeoutNs

private long rpcTimeoutNs

priority

private int priority

Constructor Detail

ScanSingleRegionCallerBuilder

public ScanSingleRegionCallerBuilder()

Method Detail

id

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder id(long scannerId)

setScan

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder setScan(Scan scan)

metrics

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder metrics(ScanMetrics scanMetrics)

remote

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder remote(boolean isRegionServerRemote)

resultCache

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder resultCache(ScanResultCache resultCache)

consumer

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder consumer(AdvancedScanResultConsumer consumer)

stub

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder stub(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)

location

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder location(HRegionLocation loc)

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

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder pause(long pause,
                                                                         TimeUnit unit)

pauseForCQTBE

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder pauseForCQTBE(long pause,
                                                                                 TimeUnit unit)

maxAttempts

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder maxAttempts(int maxAttempts)

startLogErrorsCnt

public AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder startLogErrorsCnt(int startLogErrorsCnt)

preCheck

private void preCheck()

build

public AsyncScanSingleRegionRpcRetryingCaller build()

start

public CompletableFuture<Boolean> start(HBaseRpcController controller,
                                        org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen)

Short cut for build().start(HBaseRpcController, ScanResponse).