org.apache.hadoop.hbase.replication.regionserver

Class CatalogReplicationSourcePeer

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationPeerImpl

org.apache.hadoop.hbase.replication.regionserver.CatalogReplicationSourcePeer

All Implemented Interfaces:

ReplicationPeer

@InterfaceAudience.Private
class CatalogReplicationSourcePeer
extends ReplicationPeerImpl

The 'peer' used internally by Catalog Region Replicas Replication Source. The Replication system has 'peer' baked into its core so though we do not need 'peering', we need a 'peer' and its configuration else the replication system breaks at a few locales. Set "hbase.region.replica.catalog.replication" if you want to change the configured endpoint.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationPeer

ReplicationPeer.PeerState

Constructor Summary

Constructors

Constructor and Description
CatalogReplicationSourcePeer(org.apache.hadoop.conf.Configuration configuration, String clusterKey)

Method Summary

Methods inherited from class org.apache.hadoop.hbase.replication.ReplicationPeerImpl

getConfiguration, getId, getNamespaces, getPeerBandwidth, getPeerConfig, getPeerState, getTableCFs, registerPeerConfigListener, setPeerConfig, setPeerState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationPeer

isPeerEnabled, trackPeerConfigChanges

Constructor Detail

CatalogReplicationSourcePeer

CatalogReplicationSourcePeer(org.apache.hadoop.conf.Configuration configuration,
                             String clusterKey)

Parameters:

clusterKey - Usually the UUID from zk passed in by caller as a String.