Package | Description |
---|---|
org.apache.hadoop.hbase.master.replication | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.util.hbck |
Modifier and Type | Field and Description |
---|---|
private ReplicationPeerStorage |
ReplicationPeerManager.peerStorage |
Modifier and Type | Method and Description |
---|---|
ReplicationPeerStorage |
ReplicationPeerManager.getPeerStorage() |
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 |
FSReplicationPeerStorage
A filesystem based replication peer storage.
|
class |
ZKReplicationPeerStorage
ZK based replication peer storage.
|
Modifier and Type | Field and Description |
---|---|
private ReplicationPeerStorage |
ReplicationPeers.peerStorage |
Modifier and Type | Field and Description |
---|---|
private Class<? extends ReplicationPeerStorage> |
ReplicationPeerStorageType.clazz |
Modifier and Type | Method and Description |
---|---|
private ReplicationPeerStorage |
CopyReplicationPeers.create(String type,
org.apache.hadoop.fs.FileSystem fs,
ZKWatcher zk) |
ReplicationPeerStorage |
ReplicationPeers.getPeerStorage() |
static ReplicationPeerStorage |
ReplicationStorageFactory.getReplicationPeerStorage(org.apache.hadoop.fs.FileSystem fs,
ZKWatcher zk,
org.apache.hadoop.conf.Configuration conf)
Create a new
ReplicationPeerStorage . |
Modifier and Type | Method and Description |
---|---|
Class<? extends ReplicationPeerStorage> |
ReplicationPeerStorageType.getClazz() |
private static Class<? extends ReplicationPeerStorage> |
ReplicationStorageFactory.getReplicationPeerStorageClass(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
private void |
CopyReplicationPeers.migrate(ReplicationPeerStorage src,
ReplicationPeerStorage dst) |
Constructor and Description |
---|
ReplicationPeerStorageType(Class<? extends ReplicationPeerStorage> clazz) |
Modifier and Type | Field and Description |
---|---|
private ReplicationPeerStorage |
ReplicationChecker.peerStorage |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.