Package | Description |
---|---|
org.apache.hadoop.hbase.master.replication | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.replication.master | |
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.util.hbck |
Modifier and Type | Class and Description |
---|---|
class |
OfflineTableReplicationQueueStorage |
Modifier and Type | Field and Description |
---|---|
private ReplicationQueueStorage |
ReplicationPeerManager.queueStorage |
Modifier and Type | Method and Description |
---|---|
ReplicationQueueStorage |
ReplicationPeerManager.getQueueStorage() |
Modifier and Type | Method and Description |
---|---|
private static Pair<ReplicationQueueStorage,ReplicationPeerManager.ReplicationQueueStorageInitializer> |
ReplicationPeerManager.createReplicationQueueStorage(MasterServices services) |
Modifier and Type | Method and Description |
---|---|
private void |
UpdatePeerConfigProcedure.addToList(List<String> encodedRegionNames,
String encodedRegionName,
ReplicationQueueStorage queueStorage) |
private void |
AbstractPeerProcedure.addToMap(Map<String,Long> lastSeqIds,
String encodedRegionName,
long barrier,
ReplicationQueueStorage queueStorage) |
Constructor and Description |
---|
ReplicationPeerManager(org.apache.hadoop.fs.FileSystem fs,
ZKWatcher zk,
ReplicationPeerStorage peerStorage,
ReplicationQueueStorage queueStorage,
ConcurrentMap<String,ReplicationPeerDescription> peers,
org.apache.hadoop.conf.Configuration conf,
String clusterId,
ReplicationPeerManager.ReplicationQueueStorageInitializer queueStorageInitializer) |
Modifier and Type | Class and Description |
---|---|
class |
TableReplicationQueueStorage
HBase table based replication queue storage.
|
Modifier and Type | Method and Description |
---|---|
static ReplicationQueueStorage |
ReplicationStorageFactory.getReplicationQueueStorage(Connection conn,
org.apache.hadoop.conf.Configuration conf)
Create a new
ReplicationQueueStorage . |
static ReplicationQueueStorage |
ReplicationStorageFactory.getReplicationQueueStorage(Connection conn,
org.apache.hadoop.conf.Configuration conf,
TableName tableName)
Create a new
ReplicationQueueStorage . |
Modifier and Type | Field and Description |
---|---|
private ReplicationQueueStorage |
ReplicationHFileCleaner.rqs |
Modifier and Type | Field and Description |
---|---|
private ReplicationQueueStorage |
ReplicationSourceManager.queueStorage
Storage for queues that need persistance; e.g.
|
protected ReplicationQueueStorage |
ReplicationSource.queueStorage |
private ReplicationQueueStorage |
Replication.queueStorage |
private ReplicationQueueStorage |
SerialReplicationChecker.storage |
Modifier and Type | Method and Description |
---|---|
(package private) ReplicationQueueStorage |
ReplicationSourceManager.getQueueStorage() |
ReplicationQueueStorage |
ReplicationSourceInterface.getReplicationQueueStorage()
Returns The instance of queueStorage used by this ReplicationSource.
|
ReplicationQueueStorage |
ReplicationSource.getReplicationQueueStorage() |
Modifier and Type | Method and Description |
---|---|
private void |
ReplicationSyncUp.addMissingReplicationQueues(ReplicationQueueStorage storage,
ServerName regionServer,
Set<String> peerIds) |
private void |
ReplicationSyncUp.addMissingReplicationQueues(ReplicationQueueStorage storage,
Set<ServerName> regionServers,
Set<String> peerIds) |
void |
ReplicationSourceInterface.init(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueueStorage queueStorage,
ReplicationPeer replicationPeer,
Server server,
ReplicationQueueData queueData,
UUID clusterId,
WALFileLengthProvider walFileLengthProvider,
MetricsSource metrics)
Initializer for the source
|
void |
ReplicationSource.init(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueueStorage queueStorage,
ReplicationPeer replicationPeer,
Server server,
ReplicationQueueData queueData,
UUID clusterId,
WALFileLengthProvider walFileLengthProvider,
MetricsSource metrics)
Instantiation method used by region servers
|
Constructor and Description |
---|
RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf,
String walGroupId,
RecoveredReplicationSource source,
ReplicationSourceWALReader walReader,
ReplicationQueueStorage queueStorage,
Runnable tryFinish) |
ReplicationSourceManager(ReplicationQueueStorage queueStorage,
ReplicationPeers replicationPeers,
org.apache.hadoop.conf.Configuration conf,
Server server,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path logDir,
org.apache.hadoop.fs.Path oldLogDir,
UUID clusterId,
WALFactory walFactory,
SyncReplicationPeerMappingManager syncReplicationPeerMappingManager,
MetricsReplicationGlobalSourceSource globalMetrics)
Creates a replication manager and sets the watch on all the other registered region servers
|
Modifier and Type | Field and Description |
---|---|
private ReplicationQueueStorage |
ReplicationChecker.queueStorage |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.