Package | Description |
---|---|
org.apache.hadoop.hbase.client.replication | |
org.apache.hadoop.hbase.replication | |
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Method and Description |
---|---|
ReplicationPeerConfig |
ReplicationAdmin.getPeerConfig(java.lang.String id) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,ReplicationPeerConfig> |
ReplicationAdmin.listPeerConfigs() |
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.
|
Modifier and Type | Method and Description |
---|---|
ReplicationPeerConfig |
ReplicationPeer.getPeerConfig()
Get the peer config object
|
ReplicationPeerConfig |
ReplicationPeerZKImpl.getPeerConfig()
Get the peer config object
|
ReplicationPeerConfig |
ReplicationEndpoint.Context.getPeerConfig() |
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.
|
ReplicationPeerConfig |
ReplicationPeerConfig.setClusterKey(java.lang.String clusterKey)
Set the clusterKey which is the concatenation of the slave cluster's:
hbase.zookeeper.quorum:hbase.zookeeper.property.clientPort:zookeeper.znode.parent
|
ReplicationPeerConfig |
ReplicationPeerConfig.setReplicationEndpointImpl(java.lang.String replicationEndpointImpl)
Sets the ReplicationEndpoint plugin class for this peer.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,ReplicationPeerConfig> |
ReplicationPeers.getAllPeerConfigs()
List the cluster replication configs of all remote slave clusters (whether they are
enabled/disabled or connected/disconnected).
|
java.util.Map<java.lang.String,ReplicationPeerConfig> |
ReplicationPeersZKImpl.getAllPeerConfigs() |
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
Context(Configuration conf,
FileSystem fs,
ReplicationPeerConfig peerConfig,
java.lang.String peerId,
java.util.UUID clusterId,
ReplicationPeer replicationPeer,
MetricsSource metrics,
TableDescriptors tableDescriptors) |
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 |
---|---|
protected ReplicationSourceInterface |
ReplicationSourceManager.getReplicationSource(Configuration conf,
FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueues replicationQueues,
ReplicationPeers replicationPeers,
Server server,
java.lang.String peerId,
java.util.UUID clusterId,
ReplicationPeerConfig peerConfig,
ReplicationPeer replicationPeer)
Factory method to create a replication source
|