Package | Description |
---|---|
org.apache.hadoop.hbase.master.replication | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Method and Description |
---|---|
private ReplicationQueueData |
ReplicationPeerManager.convert(ZKReplicationQueueStorageForMigration.ZkReplicationQueueData zkData) |
Modifier and Type | Method and Description |
---|---|
List<ReplicationQueueData> |
OfflineTableReplicationQueueStorage.listAllQueues() |
Modifier and Type | Method and Description |
---|---|
void |
OfflineTableReplicationQueueStorage.batchUpdateQueues(ServerName serverName,
List<ReplicationQueueData> datas) |
Modifier and Type | Method and Description |
---|---|
List<ReplicationQueueData> |
ReplicationQueueStorage.listAllQueues()
Get a list of all queues and the offsets.
|
List<ReplicationQueueData> |
TableReplicationQueueStorage.listAllQueues() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationQueueStorage.batchUpdateQueues(ServerName serverName,
List<ReplicationQueueData> datas)
Update the replication queue datas for a given region server.
|
void |
TableReplicationQueueStorage.batchUpdateQueues(ServerName serverName,
List<ReplicationQueueData> datas) |
Modifier and Type | Method and Description |
---|---|
private ReplicationSourceInterface |
ReplicationSourceManager.createSource(ReplicationQueueData queueData,
ReplicationPeer replicationPeer) |
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
|
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
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.