Modifier and Type | Method and Description |
---|---|
void |
ReplicationAdmin.addPeer(java.lang.String id,
ReplicationPeerConfig peerConfig,
java.util.Map<TableName,? extends java.util.Collection<java.lang.String>> tableCfs)
Add a new remote slave cluster for replication.
|
void |
ReplicationAdmin.addPeer(java.lang.String id,
java.lang.String clusterKey)
Deprecated.
Use addPeer(String, ReplicationPeerConfig, Map) instead.
|
void |
ReplicationAdmin.addPeer(java.lang.String id,
java.lang.String clusterKey,
java.lang.String tableCFs)
Deprecated.
|
void |
ReplicationAdmin.appendPeerTableCFs(java.lang.String id,
java.util.Map<TableName,? extends java.util.Collection<java.lang.String>> tableCfs)
Append the replicable table-cf config of the specified peer
|
void |
ReplicationAdmin.appendPeerTableCFs(java.lang.String id,
java.lang.String tableCfs)
Append the replicable table-cf config of the specified peer
|
void |
ReplicationAdmin.disablePeer(java.lang.String id)
Stop the replication stream to the specified peer.
|
void |
ReplicationAdmin.enablePeer(java.lang.String id)
Restart the replication stream to the specified peer.
|
ReplicationPeerConfig |
ReplicationAdmin.getPeerConfig(java.lang.String id) |
boolean |
ReplicationAdmin.getPeerState(java.lang.String id)
Get the state of the specified peer cluster
|
java.lang.String |
ReplicationAdmin.getPeerTableCFs(java.lang.String id)
Get the replicable table-cf config of the specified peer.
|
void |
ReplicationAdmin.removePeer(java.lang.String id)
Removes a peer cluster and stops the replication to it.
|
void |
ReplicationAdmin.removePeerTableCFs(java.lang.String id,
java.util.Map<TableName,? extends java.util.Collection<java.lang.String>> tableCfs)
Remove some table-cfs from config of the specified peer
|
void |
ReplicationAdmin.removePeerTableCFs(java.lang.String id,
java.lang.String tableCf)
Remove some table-cfs from table-cfs config of the specified peer
|
void |
ReplicationAdmin.setPeerTableCFs(java.lang.String id,
java.util.Map<TableName,? extends java.util.Collection<java.lang.String>> tableCfs)
Set the replicable table-cf config of the specified peer
|
void |
ReplicationAdmin.setPeerTableCFs(java.lang.String id,
java.lang.String tableCFs)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
TestReplicationHFileCleaner.cleanup() |
void |
TestReplicationHFileCleaner.setup() |
void |
TestReplicationHFileCleaner.testIsFileDeletable() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationQueues.addHFileRefs(java.lang.String peerId,
java.util.List<Pair<Path,Path>> pairs)
Add new hfile references to the queue.
|
void |
ReplicationQueuesZKImpl.addHFileRefs(java.lang.String peerId,
java.util.List<Pair<Path,Path>> pairs) |
void |
ReplicationQueues.addLog(java.lang.String queueId,
java.lang.String filename)
Add a new WAL file to the given queue.
|
void |
ReplicationQueuesZKImpl.addLog(java.lang.String queueId,
java.lang.String filename) |
void |
ReplicationPeers.addPeer(java.lang.String peerId,
ReplicationPeerConfig peerConfig,
java.lang.String tableCFs)
Add a new remote slave cluster for replication.
|
void |
ReplicationPeersZKImpl.addPeer(java.lang.String id,
ReplicationPeerConfig peerConfig,
java.lang.String tableCFs) |
void |
ReplicationQueues.addPeerToHFileRefs(java.lang.String peerId)
Add a peer to hfile reference queue if peer does not exist.
|
void |
ReplicationQueuesZKImpl.addPeerToHFileRefs(java.lang.String peerId) |
boolean |
ReplicationPeersZKImpl.createAndAddPeer(java.lang.String peerId)
Attempt to connect to a new remote slave cluster.
|
void |
ReplicationPeers.disablePeer(java.lang.String peerId)
Stop the replication to the specified remote slave cluster.
|
void |
ReplicationPeersZKImpl.disablePeer(java.lang.String id) |
void |
ReplicationPeers.enablePeer(java.lang.String peerId)
Restart the replication to the specified remote slave cluster.
|
void |
ReplicationPeersZKImpl.enablePeer(java.lang.String id) |
long |
ReplicationQueues.getLogPosition(java.lang.String queueId,
java.lang.String filename)
Get the current position for a specific WAL in a given queue.
|
long |
ReplicationQueuesZKImpl.getLogPosition(java.lang.String queueId,
java.lang.String filename) |
Pair<ReplicationPeerConfig,Configuration> |
ReplicationPeers.getPeerConf(java.lang.String peerId)
Returns the configuration needed to talk to the remote slave cluster.
|
Pair<ReplicationPeerConfig,Configuration> |
ReplicationPeersZKImpl.getPeerConf(java.lang.String peerId) |
java.lang.String |
ReplicationPeers.getPeerTableCFsConfig(java.lang.String peerId)
Get the table and column-family list string of the peer from ZK.
|
java.lang.String |
ReplicationPeersZKImpl.getPeerTableCFsConfig(java.lang.String id) |
ReplicationPeerConfig |
ReplicationPeers.getReplicationPeerConfig(java.lang.String peerId)
Returns the configured ReplicationPeerConfig for this peerId
|
ReplicationPeerConfig |
ReplicationPeersZKImpl.getReplicationPeerConfig(java.lang.String peerId)
Returns a ReplicationPeerConfig from the znode or null for the given peerId.
|
boolean |
ReplicationPeers.getStatusOfPeerFromBackingStore(java.lang.String peerId)
Get the replication status for the specified remote slave cluster, which doesn't
have to be connected.
|
boolean |
ReplicationPeersZKImpl.getStatusOfPeerFromBackingStore(java.lang.String id) |
void |
ReplicationPeers.init()
Initialize the ReplicationPeers interface.
|
void |
ReplicationPeersZKImpl.init() |
void |
ReplicationQueuesClient.init()
Initialize the replication queue client interface.
|
void |
ReplicationQueuesClientZKImpl.init() |
void |
ReplicationQueues.init(java.lang.String serverName)
Initialize the region server replication queue interface.
|
void |
ReplicationQueuesZKImpl.init(java.lang.String serverName) |
boolean |
ReplicationPeers.peerAdded(java.lang.String peerId) |
boolean |
ReplicationPeersZKImpl.peerAdded(java.lang.String peerId) |
void |
ReplicationPeers.removePeer(java.lang.String peerId)
Removes a remote slave cluster and stops the replication to it.
|
void |
ReplicationPeersZKImpl.removePeer(java.lang.String id) |
void |
ReplicationPeers.setPeerTableCFsConfig(java.lang.String peerId,
java.lang.String tableCFs)
Set the table and column-family list string of the peer to ZK.
|
void |
ReplicationPeersZKImpl.setPeerTableCFsConfig(java.lang.String id,
java.lang.String tableCFsStr) |
Constructor and Description |
---|
ReplicationPeerZKImpl(Configuration conf,
java.lang.String id,
ReplicationPeerConfig peerConfig)
Constructor that takes all the objects required to communicate with the
specified peer, except for the region server addresses.
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicationSource.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
void |
ReplicationSourceInterface.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs)
Add hfile names to the queue to be replicated.
|
void |
ReplicationSourceManager.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
protected ReplicationSourceInterface |
ReplicationSourceManager.addSource(java.lang.String id)
Add a new normal source to this region server
|
protected void |
ReplicationSourceManager.init()
Adds a normal source per registered peer cluster and tries to process all
old region server wal queues
|