Uses of Interface
org.apache.hadoop.hbase.client.AsyncClusterConnection

Packages that use AsyncClusterConnection

Package	Description
org.apache.hadoop.hbase
org.apache.hadoop.hbase.client	Provides HBase Client
org.apache.hadoop.hbase.master
org.apache.hadoop.hbase.regionserver
org.apache.hadoop.hbase.regionserver.handler
org.apache.hadoop.hbase.regionserver.regionreplication
org.apache.hadoop.hbase.replication	Multi Cluster Replication
org.apache.hadoop.hbase.replication.regionserver
org.apache.hadoop.hbase.rsgroup
org.apache.hadoop.hbase.tool

Uses of AsyncClusterConnection in org.apache.hadoop.hbase

Fields in org.apache.hadoop.hbase declared as AsyncClusterConnection

Modifier and Type	Field	Description
protected AsyncClusterConnection	HBaseServerBase.asyncClusterConnection	The asynchronous cluster connection to be shared by services.

Fields in org.apache.hadoop.hbase with type parameters of type AsyncClusterConnection

Modifier and Type	Field	Description
private final AtomicReference<AsyncClusterConnection>	HBaseTestingUtility.asyncConnection	Deprecated.

Methods in org.apache.hadoop.hbase that return AsyncClusterConnection

Modifier and Type	Method	Description
AsyncClusterConnection	HBaseServerBase.getAsyncClusterConnection()
AsyncClusterConnection	Server.getAsyncClusterConnection()	Returns a reference to the servers' async cluster connection.
AsyncClusterConnection	HBaseTestingUtility.getAsyncConnection()	Deprecated. Get a shared AsyncClusterConnection to the cluster.
AsyncClusterConnection	HBaseTestingUtility.getAsyncConnection(User user)	Deprecated. Get a assigned AsyncClusterConnection to the cluster.

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

Classes in org.apache.hadoop.hbase.client that implement AsyncClusterConnection

Modifier and Type	Class	Description
(package private) class	AsyncClusterConnectionImpl	The implementation of AsyncClusterConnection.

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

Modifier and Type	Method	Description
static AsyncClusterConnection	ClusterConnectionFactory.createAsyncClusterConnection(URI uri, org.apache.hadoop.conf.Configuration conf, SocketAddress localAddress, User user)	Create a new AsyncClusterConnection instance.
static AsyncClusterConnection	ClusterConnectionFactory.createAsyncClusterConnection(org.apache.hadoop.conf.Configuration conf, SocketAddress localAddress, User user)	Create a new AsyncClusterConnection instance.
private static AsyncClusterConnection	ClusterConnectionFactory.createAsyncClusterConnection(org.apache.hadoop.conf.Configuration conf, ConnectionRegistry registry, SocketAddress localAddress, User user)
static AsyncClusterConnection	ClusterConnectionFactory.createAsyncClusterConnection(ConnectionRegistryEndpoint endpoint, org.apache.hadoop.conf.Configuration conf, SocketAddress localAddress, User user)	Create a new AsyncClusterConnection instance to be used at server side where we have a ConnectionRegistryEndpoint.

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

Fields in org.apache.hadoop.hbase.master declared as AsyncClusterConnection

Modifier and Type	Field	Description
private AsyncClusterConnection	RegionPlacementMaintainer.connection

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

Modifier and Type	Method	Description
private AsyncClusterConnection	RegionPlacementMaintainer.getConnection()

Methods in org.apache.hadoop.hbase.master with parameters of type AsyncClusterConnection

Modifier and Type	Method	Description
static void	ServerManager.closeRegionSilentlyAndWait(AsyncClusterConnection connection, ServerName server, RegionInfo region, long timeout)	Contacts a region server and waits up to timeout ms to close the region.

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

Fields in org.apache.hadoop.hbase.regionserver declared as AsyncClusterConnection

Modifier and Type	Field	Description
private final AsyncClusterConnection	BootstrapNodeManager.conn

Constructors in org.apache.hadoop.hbase.regionserver with parameters of type AsyncClusterConnection

Modifier	Constructor	Description
	BootstrapNodeManager(AsyncClusterConnection conn, MasterAddressTracker masterAddrTracker)

Uses of AsyncClusterConnection in org.apache.hadoop.hbase.regionserver.handler

Fields in org.apache.hadoop.hbase.regionserver.handler declared as AsyncClusterConnection

Modifier and Type	Field	Description
private final AsyncClusterConnection	RegionReplicaFlushHandler.connection

Uses of AsyncClusterConnection in org.apache.hadoop.hbase.regionserver.regionreplication

Fields in org.apache.hadoop.hbase.regionserver.regionreplication declared as AsyncClusterConnection

Modifier and Type	Field	Description
private final AsyncClusterConnection	RegionReplicationSink.conn

Constructors in org.apache.hadoop.hbase.regionserver.regionreplication with parameters of type AsyncClusterConnection

Modifier	Constructor	Description
	RegionReplicationSink(org.apache.hadoop.conf.Configuration conf, RegionInfo primary, TableDescriptor td, RegionReplicationBufferManager manager, Runnable flushRequester, AsyncClusterConnection conn)

Uses of AsyncClusterConnection in org.apache.hadoop.hbase.replication

Fields in org.apache.hadoop.hbase.replication declared as AsyncClusterConnection

Modifier and Type	Field	Description
private AsyncClusterConnection	HBaseReplicationEndpoint.conn

Methods in org.apache.hadoop.hbase.replication that return AsyncClusterConnection

Modifier and Type	Method	Description
private AsyncClusterConnection	HBaseReplicationEndpoint.connect()
protected AsyncClusterConnection	HBaseReplicationEndpoint.createConnection(URI clusterURI, org.apache.hadoop.conf.Configuration conf)	Some implementations of HBaseInterClusterReplicationEndpoint may require instantiate different Connection implementations, or initialize it in a different way, so defining createConnection as protected for possible overridings.

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

Fields in org.apache.hadoop.hbase.replication.regionserver declared as AsyncClusterConnection

Modifier and Type	Field	Description
private AsyncClusterConnection	HFileReplicator.connection
private AsyncClusterConnection	ReplicationSink.sharedConn

Methods in org.apache.hadoop.hbase.replication.regionserver that return AsyncClusterConnection

Modifier and Type	Method	Description
AsyncClusterConnection	ReplicationSyncUp.DummyServer.getAsyncClusterConnection()
private AsyncClusterConnection	ReplicationSink.getConnection()

Constructors in org.apache.hadoop.hbase.replication.regionserver with parameters of type AsyncClusterConnection

Modifier	Constructor	Description
	HFileReplicator(org.apache.hadoop.conf.Configuration sourceClusterConf, String sourceBaseNamespaceDirPath, String sourceHFileArchiveDirPath, Map<String,List<Pair<byte[],List<String>>>> tableQueueMap, org.apache.hadoop.conf.Configuration conf, AsyncClusterConnection connection, List<String> sourceClusterIds)

Uses of AsyncClusterConnection in org.apache.hadoop.hbase.rsgroup

Fields in org.apache.hadoop.hbase.rsgroup declared as AsyncClusterConnection

Modifier and Type	Field	Description
private final AsyncClusterConnection	RSGroupInfoManagerImpl.conn

Uses of AsyncClusterConnection in org.apache.hadoop.hbase.tool

Methods in org.apache.hadoop.hbase.tool with parameters of type AsyncClusterConnection

Modifier and Type	Method	Description
protected void	BulkLoadHFilesTool.bulkLoadPhase(AsyncClusterConnection conn, TableName tableName, Deque<BulkLoadHFiles.LoadQueueItem> queue, org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,BulkLoadHFiles.LoadQueueItem> regionGroups, boolean copyFiles, Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer> item2RegionMap)	This takes the LQI's grouped by likely regions and attempts to bulk load them.
private void	BulkLoadHFilesTool.cleanup(AsyncClusterConnection conn, TableName tableName, Deque<BulkLoadHFiles.LoadQueueItem> queue, ExecutorService pool)
private Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer>	BulkLoadHFilesTool.doBulkLoad(AsyncClusterConnection conn, TableName tableName, Map<byte[],List<org.apache.hadoop.fs.Path>> map, boolean silence, boolean copyFile)	Perform a bulk load of the given map of families to hfiles into the given pre-existing table.
private Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer>	BulkLoadHFilesTool.doBulkLoad(AsyncClusterConnection conn, TableName tableName, org.apache.hadoop.fs.Path hfofDir, boolean silence, boolean copyFile)	Perform a bulk load of the given directory into the given pre-existing table.
protected Pair<List<BulkLoadHFiles.LoadQueueItem>,String>	BulkLoadHFilesTool.groupOrSplit(AsyncClusterConnection conn, TableName tableName, org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,BulkLoadHFiles.LoadQueueItem> regionGroups, BulkLoadHFiles.LoadQueueItem item, List<Pair<byte[],byte[]>> startEndKeys)	Attempt to assign the given load queue item into its target region group.
private Pair<org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,BulkLoadHFiles.LoadQueueItem>,Set<String>>	BulkLoadHFilesTool.groupOrSplitPhase(AsyncClusterConnection conn, TableName tableName, ExecutorService pool, Deque<BulkLoadHFiles.LoadQueueItem> queue, List<Pair<byte[],byte[]>> startEndKeys)
void	BulkLoadHFilesTool.loadHFileQueue(AsyncClusterConnection conn, TableName tableName, Deque<BulkLoadHFiles.LoadQueueItem> queue, boolean copyFiles)	Used by the replication sink to load the hfiles from the source cluster.
private Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer>	BulkLoadHFilesTool.performBulkLoad(AsyncClusterConnection conn, TableName tableName, Deque<BulkLoadHFiles.LoadQueueItem> queue, ExecutorService pool, boolean copyFile)
static void	BulkLoadHFilesTool.prepareHFileQueue(org.apache.hadoop.conf.Configuration conf, AsyncClusterConnection conn, TableName tableName, org.apache.hadoop.fs.Path hfilesDir, Deque<BulkLoadHFiles.LoadQueueItem> queue, boolean validateHFile, boolean silence)	Prepare a collection of LoadQueueItem from list of source hfiles contained in the passed directory and validates whether the prepared queue has all the valid table column families in it.
static void	BulkLoadHFilesTool.prepareHFileQueue(AsyncClusterConnection conn, TableName tableName, Map<byte[],List<org.apache.hadoop.fs.Path>> map, Deque<BulkLoadHFiles.LoadQueueItem> queue, boolean silence)	Prepare a collection of LoadQueueItem from list of source hfiles contained in the passed directory and validates whether the prepared queue has all the valid table column families in it.
private void	BulkLoadHFilesTool.tableExists(AsyncClusterConnection conn, TableName tableName)
protected CompletableFuture<Collection<BulkLoadHFiles.LoadQueueItem>>	BulkLoadHFilesTool.tryAtomicRegionLoad(AsyncClusterConnection conn, TableName tableName, boolean copyFiles, byte[] first, Collection<BulkLoadHFiles.LoadQueueItem> lqis)	Attempts to do an atomic load of many hfiles into a region.