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.master
org.apache.hadoop.hbase.regionserver
org.apache.hadoop.hbase.replication.regionserver

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

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

Modifier and Type	Field and Description
HBaseRpcController	AsyncClientScanner.OpenScannerResponse.controller
protected HBaseRpcController	AsyncRpcRetryingCaller.controller
private HBaseRpcController	AsyncScanSingleRegionRpcRetryingCaller.controller
private HBaseRpcController	RegionAdminServiceCallable.controller
private HBaseRpcController	MasterCallable.rpcController

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

Modifier and Type	Method and Description
(package private) HBaseRpcController	RegionAdminServiceCallable.getCurrentPayloadCarryingRpcController()
(package private) HBaseRpcController	MasterCallable.getRpcController()

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

Modifier and Type	Method and 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	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)
void	RawAsyncTableImpl.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)
protected org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse	FlushRegionCallable.call(HBaseRpcController controller)
protected abstract T	RegionAdminServiceCallable.call(HBaseRpcController rpcController) Run RPC call.
CompletableFuture<T>	AsyncAdminRequestRetryingCaller.Callable.call(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interface stub)
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)
private static <REQ,PREQ,PRESP,RESP> CompletableFuture<RESP>	RawAsyncTableImpl.call(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, REQ req, RawAsyncTableImpl.Converter<PREQ,byte[],REQ> reqConvert, RawAsyncTableImpl.RpcCall<PRESP,PREQ> rpcCall, RawAsyncTableImpl.Converter<RESP,HBaseRpcController,PRESP> respConverter)
CompletableFuture<T>	AsyncMasterRequestRpcRetryingCaller.Callable.call(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface stub)
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	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)
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, RawAsyncTableImpl.Converter<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest,byte[],REQ> reqConvert, RawAsyncTableImpl.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, RawAsyncTableImpl.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, RawAsyncTableImpl.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)
private CompletableFuture<com.google.protobuf.Message>	RegionServerCoprocessorRpcChannelImpl.rpcCall(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype, HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
private CompletableFuture<com.google.protobuf.Message>	RegionCoprocessorRpcChannelImpl.rpcCall(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype, HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub)
private CompletableFuture<com.google.protobuf.Message>	MasterCoprocessorRpcChannelImpl.rpcCall(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, com.google.protobuf.Message responsePrototype, HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.Interface stub)
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.
CompletableFuture<Boolean>	AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.start(HBaseRpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse respWhenOpen) Short cut for build().start(HBaseRpcController, ScanResponse).
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, RawAsyncTableImpl.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 and Description
private static <REQ,PREQ,PRESP,RESP> CompletableFuture<RESP>	RawAsyncTableImpl.call(HBaseRpcController controller, HRegionLocation loc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub, REQ req, RawAsyncTableImpl.Converter<PREQ,byte[],REQ> reqConvert, RawAsyncTableImpl.RpcCall<PRESP,PREQ> rpcCall, RawAsyncTableImpl.Converter<RESP,HBaseRpcController,PRESP> respConverter)
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, RawAsyncTableImpl.Converter<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest,byte[],REQ> reqConvert, RawAsyncTableImpl.Converter<RESP,HBaseRpcController,org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse> 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, RawAsyncTableImpl.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

Constructor and Description
NoncedRegionServerCallable(Connection connection, TableName tableName, byte[] row, HBaseRpcController rpcController, int priority)
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 and 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 and Description
private HBaseRpcController	DelegatingHBaseRpcController.delegate

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

Modifier and Type	Method and 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(CellScanner cellScanner)
HBaseRpcController	RpcControllerFactory.newController(List<CellScannable> cellIterables)
HBaseRpcController	RpcControllerFactory.newController(RegionInfo regionInfo, CellScanner cellScanner)
HBaseRpcController	RpcControllerFactory.newController(RegionInfo regionInfo, List<CellScannable> cellIterables)

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

Modifier and Type	Method and 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)
abstract void	RpcConnection.sendRequest(Call call, HBaseRpcController hrc)
void	BlockingRpcConnection.sendRequest(Call call, HBaseRpcController pcrc)
void	NettyRpcConnection.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

Constructor and Description
DelegatingHBaseRpcController(HBaseRpcController delegate)

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

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

Modifier and Type	Method and Description
private HBaseRpcController	ServerManager.newRpcController()

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 and 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, org.apache.commons.lang3.mutable.MutableObject<Object> lastBlock, RpcCall rpcCall)

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

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

Modifier and Type	Method and Description
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse	RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable.call(HBaseRpcController controller)