Package org.apache.hadoop.hbase.client

Class ClusterIdFetcher

java.lang.Object

org.apache.hadoop.hbase.client.ClusterIdFetcher

@Private
class ClusterIdFetcher
extends Object

Fetch cluster id through special preamble header.

An instance of this class should only be used once, like:

 new ClusterIdFetcher().fetchClusterId()
 

Calling the fetchClusterId multiple times will lead unexpected behavior.

See HBASE-25051 for more details.

Field Summary

Fields

Modifier and Type	Field	Description
private final List<ServerName>	bootstrapServers
private final CompletableFuture<String>	future
private static final org.slf4j.Logger	LOG
private final RpcClient	rpcClient
private final RpcControllerFactory	rpcControllerFactory
private final User	user

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
(package private) CompletableFuture<String>	fetchClusterId()
private void	getClusterId(int index)	Try get cluster id from the server with the given index in bootstrapServers.

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

bootstrapServers

private final List<ServerName> bootstrapServers

user

private final User user

rpcClient

private final RpcClient rpcClient

rpcControllerFactory

private final RpcControllerFactory rpcControllerFactory

future

private final CompletableFuture<String> future

Constructor Details

ClusterIdFetcher

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

Method Details

getClusterId

private void getClusterId(int index)

Try get cluster id from the server with the given index in bootstrapServers.

fetchClusterId

CompletableFuture<String> fetchClusterId()