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 |
Modifier and Type | Field and Description |
---|---|
protected AsyncClusterConnection |
HBaseServerBase.asyncClusterConnection
The asynchronous cluster connection to be shared by services.
|
Modifier and Type | Field and Description |
---|---|
private AtomicReference<AsyncClusterConnection> |
HBaseTestingUtility.asyncConnection
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
AsyncClusterConnection |
Server.getAsyncClusterConnection()
Returns a reference to the servers' async cluster connection.
|
AsyncClusterConnection |
HBaseServerBase.getAsyncClusterConnection() |
AsyncClusterConnection |
HBaseTestingUtility.getAsyncConnection()
Deprecated.
Get a shared AsyncClusterConnection to the cluster.
|
AsyncClusterConnection |
HBaseTestingUtility.getAsyncConnection(User user)
Deprecated.
Get a assigned AsyncClusterConnection to the cluster.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
AsyncClusterConnectionImpl
The implementation of AsyncClusterConnection.
|
Modifier and Type | Method and Description |
---|---|
private static AsyncClusterConnection |
ClusterConnectionFactory.createAsyncClusterConnection(org.apache.hadoop.conf.Configuration conf,
ConnectionRegistry registry,
SocketAddress localAddress,
User user) |
static AsyncClusterConnection |
ClusterConnectionFactory.createAsyncClusterConnection(org.apache.hadoop.conf.Configuration conf,
SocketAddress localAddress,
User user)
Create a new
AsyncClusterConnection instance. |
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 . |
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
RegionPlacementMaintainer.connection |
Modifier and Type | Method and Description |
---|---|
private AsyncClusterConnection |
RegionPlacementMaintainer.getConnection() |
Modifier and Type | Method and 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.
|
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
BootstrapNodeManager.conn |
Constructor and Description |
---|
BootstrapNodeManager(AsyncClusterConnection conn,
MasterAddressTracker masterAddrTracker) |
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
RegionReplicaFlushHandler.connection |
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
RegionReplicationSink.conn |
Constructor and Description |
---|
RegionReplicationSink(org.apache.hadoop.conf.Configuration conf,
RegionInfo primary,
TableDescriptor td,
RegionReplicationBufferManager manager,
Runnable flushRequester,
AsyncClusterConnection conn) |
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
HBaseReplicationEndpoint.conn |
Modifier and Type | Method and Description |
---|---|
protected AsyncClusterConnection |
HBaseReplicationEndpoint.createConnection(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
HFileReplicator.connection |
private AsyncClusterConnection |
ReplicationSink.sharedConn |
Modifier and Type | Method and Description |
---|---|
AsyncClusterConnection |
ReplicationSyncUp.DummyServer.getAsyncClusterConnection() |
private AsyncClusterConnection |
ReplicationSink.getConnection() |
Constructor and 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) |
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
RSGroupInfoManagerImpl.conn |
Modifier and Type | Method and 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(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. |
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. |
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.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.