Package org.apache.hadoop.hbase.client

Class ConnectionRegistryRpcStubHolder

java.lang.Object

org.apache.hadoop.hbase.client.ConnectionRegistryRpcStubHolder

All Implemented Interfaces:

Closeable, AutoCloseable

@Private
class ConnectionRegistryRpcStubHolder
extends Object
implements Closeable

A class for creating RpcClient and related stubs used by AbstractRpcBasedConnectionRegistry. We need to connect to bootstrap nodes to get the cluster id first, before creating the final RpcClient and related stubs.

See HBASE-25051 for more details.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface>	addr2Stub
private CompletableFuture<org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface>>	addr2StubFuture
private final Set<ServerName>	bootstrapNodes
private final org.apache.hadoop.conf.Configuration	conf
private static final org.slf4j.Logger	LOG
private final org.apache.hadoop.conf.Configuration	noAuthConf
private RpcClient	rpcClient
private final RpcControllerFactory	rpcControllerFactory
private final int	rpcTimeoutMs
private final User	user

Constructor Summary

Constructors

Constructor	Description
ConnectionRegistryRpcStubHolder(org.apache.hadoop.conf.Configuration conf, User user, RpcControllerFactory rpcControllerFactory, Set<ServerName> bootstrapNodes)

Method Summary

Modifier and Type	Method	Description
void	close()
private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface>	createStubs(RpcClient rpcClient, Collection<ServerName> addrs)
private CompletableFuture<org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface>>	fetchClusterIdAndCreateStubs()
(package private) CompletableFuture<org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface>>	getStubs()
(package private) void	refreshStubs(IOExceptionSupplier<Collection<ServerName>> fetchEndpoints)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

conf

private final org.apache.hadoop.conf.Configuration conf

noAuthConf

private final org.apache.hadoop.conf.Configuration noAuthConf

user

private final User user

rpcControllerFactory

private final RpcControllerFactory rpcControllerFactory

bootstrapNodes

private final Set<ServerName> bootstrapNodes

rpcTimeoutMs

private final int rpcTimeoutMs

addr2Stub

private volatile org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface> addr2Stub

rpcClient

private volatile RpcClient rpcClient

addr2StubFuture

private CompletableFuture<org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface>> addr2StubFuture

Constructor Details

ConnectionRegistryRpcStubHolder

ConnectionRegistryRpcStubHolder(org.apache.hadoop.conf.Configuration conf,
 User user,
 RpcControllerFactory rpcControllerFactory,
 Set<ServerName> bootstrapNodes)

Method Details

createStubs

private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface> createStubs(RpcClient rpcClient,
 Collection<ServerName> addrs)

fetchClusterIdAndCreateStubs

private CompletableFuture<org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface>> fetchClusterIdAndCreateStubs()

getStubs

CompletableFuture<org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<ServerName,org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.Interface>> getStubs()

refreshStubs

void refreshStubs(IOExceptionSupplier<Collection<ServerName>> fetchEndpoints)
           throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable