Uses of Interface
org.apache.hadoop.hbase.ipc.HBaseRpcController

Packages that use HBaseRpcController

Package	Description
org.apache.hadoop.hbase.client	Provides HBase Client
org.apache.hadoop.hbase.ipc	Tools to help define network clients and servers.
org.apache.hadoop.hbase.regionserver

Uses of HBaseRpcController in org.apache.hadoop.hbase.client

Fields in org.apache.hadoop.hbase.client declared as HBaseRpcController

Modifier and Type	Field	Description
final HBaseRpcController	AsyncClientScanner.OpenScannerResponse.controller
protected final HBaseRpcController	AsyncRpcRetryingCaller.controller
private final HBaseRpcController	AsyncScanSingleRegionRpcRetryingCaller.controller

Methods in org.apache.hadoop.hbase.client with parameters of type HBaseRpcController

Modifier and Type	Method	Description
private <PREQ, PRESP, RESP> CompletableFuture<RESP>	RawAsyncHBaseAdmin.adminCall(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface stub, PREQ preq, RawAsyncHBaseAdmin.AdminRpcCall<PRESP,PREQ> rpcCall, RawAsyncHBaseAdmin.Converter<RESP,PRESP> respConverter)
void	AbstractRpcBasedConnectionRegistry.Callable.call(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface stub, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<T> done)
CompletableFuture<T>	AsyncAdminRequestRetryingCaller.Callable.call(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface stub)
CompletableFuture<T>	AsyncMasterRequestRpcRetryingCaller.Callable.call(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface stub)
void	AsyncRegionServerAdmin.RpcCall.call(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface stub, HBaseRpcController controller, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<RESP> done)
CompletableFuture<T>	AsyncServerRequestRpcRetryingCaller.Callable.call(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
CompletableFuture<T>	AsyncSingleRequestRpcRetryingCaller.Callable.call(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
(package private) static <REQ, PREQ, PRESP, RESP> CompletableFuture<RESP>	ConnectionUtils.call(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, REQ req, ConnectionUtils.Converter<PREQ,byte[],REQ> reqConvert, ConnectionUtils.RpcCall<PRESP,PREQ> rpcCall, ConnectionUtils.Converter<RESP,HBaseRpcController,PRESP> respConverter)
void	ConnectionUtils.RpcCall.call(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, HBaseRpcController controller, REQ req, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<RESP> done)
void	RawAsyncHBaseAdmin.AdminRpcCall.call(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface stub, HBaseRpcController controller, REQ req, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<RESP> done)
private <PREQ, PRESP, RESP> CompletableFuture<RESP>	RawAsyncHBaseAdmin.call(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface stub, PREQ preq, RawAsyncHBaseAdmin.MasterRpcCall<PRESP,PREQ> rpcCall, RawAsyncHBaseAdmin.Converter<RESP,PRESP> respConverter)
void	RawAsyncHBaseAdmin.MasterRpcCall.call(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface stub, HBaseRpcController controller, REQ req, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<RESP> done)
private CompletableFuture<AsyncClientScanner.OpenScannerResponse>	AsyncClientScanner.callOpenScanner(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
private static <REQ, RESP> CompletableFuture<RESP>	RawAsyncTableImpl.mutate(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, REQ req, ConnectionUtils.Converter<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest,byte[],REQ> reqConvert, ConnectionUtils.Converter<RESP,HBaseRpcController,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse> respConverter)
private <RES, RESP> CompletableFuture<RESP>	RawAsyncTableImpl.mutateRow(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, RowMutations mutation, ConnectionUtils.Converter<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest,byte[],RowMutations> reqConvert, Function<RES,RESP> respConverter)
private <REQ, RESP> CompletableFuture<RESP>	RawAsyncTableImpl.noncedMutate(long nonceGroup, long nonce, HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, REQ req, RawAsyncTableImpl.NoncedConverter<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest,byte[],REQ> reqConvert, ConnectionUtils.Converter<RESP,HBaseRpcController,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse> respConverter)
private void	AsyncScanSingleRegionRpcRetryingCaller.onComplete(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp)
(package private) static void	ConnectionUtils.resetController(HBaseRpcController controller, long timeoutNs, int priority, TableName tableName)
private CompletableFuture<org.apache.hbase.thirdparty.com.google.protobuf.Message>	MasterCoprocessorRpcChannelImpl.rpcCall(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor method, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message responsePrototype, HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface stub)
private CompletableFuture<org.apache.hbase.thirdparty.com.google.protobuf.Message>	RegionCoprocessorRpcChannelImpl.rpcCall(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor method, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message responsePrototype, HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
private CompletableFuture<org.apache.hbase.thirdparty.com.google.protobuf.Message>	RegionServerCoprocessorRpcChannelImpl.rpcCall(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor method, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message responsePrototype, HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
CompletableFuture<Boolean>	AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.start(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen)	Short cut for build().start(HBaseRpcController, ScanResponse).
CompletableFuture<Boolean>	AsyncScanSingleRegionRpcRetryingCaller.start(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen)	Now we will also fetch some cells along with the scanner id when opening a scanner, so we also need to process the ScanResponse for the open scanner request.
private static Result	RawAsyncTableImpl.toResult(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse resp)
private static <REQ> CompletableFuture<Void>	RawAsyncTableImpl.voidMutate(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, REQ req, ConnectionUtils.Converter<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest,byte[],REQ> reqConvert)

Method parameters in org.apache.hadoop.hbase.client with type arguments of type HBaseRpcController

Modifier and Type	Method	Description
private <REQ, RESP> CompletableFuture<RESP>	RawAsyncTableImpl.noncedMutate(long nonceGroup, long nonce, HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, REQ req, RawAsyncTableImpl.NoncedConverter<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest,byte[],REQ> reqConvert, ConnectionUtils.Converter<RESP,HBaseRpcController,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse> respConverter)

Constructors in org.apache.hadoop.hbase.client with parameters of type HBaseRpcController

Modifier	Constructor	Description
	OpenScannerResponse(HRegionLocation loc, boolean isRegionServerRemote, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse resp)

Uses of HBaseRpcController in org.apache.hadoop.hbase.ipc

Classes in org.apache.hadoop.hbase.ipc that implement HBaseRpcController

Modifier and Type	Class	Description
class	DelegatingHBaseRpcController	Simple delegating controller for use with the RpcControllerFactory to help override standard behavior of a HBaseRpcController.
class	HBaseRpcControllerImpl	Get instances via RpcControllerFactory on client-side.

Fields in org.apache.hadoop.hbase.ipc declared as HBaseRpcController

Modifier and Type	Field	Description
private final HBaseRpcController	DelegatingHBaseRpcController.delegate

Methods in org.apache.hadoop.hbase.ipc that return HBaseRpcController

Modifier and Type	Method	Description
(package private) static HBaseRpcController	AbstractRpcClient.configureHBaseRpcController(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, int channelOperationTimeout)	Configure an hbase rpccontroller
protected HBaseRpcController	AbstractRpcClient.AbstractRpcChannel.configureRpcController(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller)	Configure an rpc controller
HBaseRpcController	RpcControllerFactory.newController()
HBaseRpcController	RpcControllerFactory.newController(List<ExtendedCellScannable> cellIterables)
HBaseRpcController	RpcControllerFactory.newController(RegionInfo regionInfo, List<ExtendedCellScannable> cellIterables)
HBaseRpcController	RpcControllerFactory.newController(RegionInfo regionInfo, ExtendedCellScanner cellScanner)
HBaseRpcController	RpcControllerFactory.newController(ExtendedCellScanner cellScanner)

Methods in org.apache.hadoop.hbase.ipc with parameters of type HBaseRpcController

Modifier and Type	Method	Description
private org.apache.hbase.thirdparty.com.google.protobuf.Message	AbstractRpcClient.callBlockingMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, HBaseRpcController hrc, org.apache.hbase.thirdparty.com.google.protobuf.Message param, org.apache.hbase.thirdparty.com.google.protobuf.Message returnType, User ticket, Address isa)	Make a blocking call.
private Call	AbstractRpcClient.callMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, HBaseRpcController hrc, org.apache.hbase.thirdparty.com.google.protobuf.Message param, org.apache.hbase.thirdparty.com.google.protobuf.Message returnType, User ticket, Address addr, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hbase.thirdparty.com.google.protobuf.Message> callback)
private void	AbstractRpcClient.onCallFinished(Call call, HBaseRpcController hrc, Address addr, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hbase.thirdparty.com.google.protobuf.Message> callback)
void	BlockingRpcConnection.sendRequest(Call call, HBaseRpcController pcrc)
void	NettyRpcConnection.sendRequest(Call call, HBaseRpcController hrc)
abstract void	RpcConnection.sendRequest(Call call, HBaseRpcController hrc)
private void	NettyRpcConnection.sendRequest0(Call call, HBaseRpcController hrc)

Constructors in org.apache.hadoop.hbase.ipc with parameters of type HBaseRpcController

Modifier	Constructor	Description
	DelegatingHBaseRpcController(HBaseRpcController delegate)

Uses of HBaseRpcController in org.apache.hadoop.hbase.regionserver

Methods in org.apache.hadoop.hbase.regionserver with parameters of type HBaseRpcController

Modifier and Type	Method	Description
private void	RSRpcServices.addResult(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse.Builder builder, Result result, HBaseRpcController rpcc, boolean clientCellBlockSupported)
private void	RSRpcServices.addResults(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder, List<Result> results, HBaseRpcController controller, boolean isDefaultRegion, boolean clientCellBlockSupported)
private long	RSRpcServices.getRemainingRpcTimeout(RpcCall call, HBaseRpcController controller, long now)
(package private) long	RSRpcServices.getTimeLimit(RpcCall rpcCall, HBaseRpcController controller, boolean allowHeartbeatMessages)
private void	RSRpcServices.scan(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request, RSRpcServices.RegionScannerHolder rsh, long maxQuotaResultSize, int maxResults, int limitOfRows, List<Result> results, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder, RpcCall rpcCall)