Searched refs:replicationPeer (Results 1 – 4 of 4) sorted by relevance
57 private final ReplicationPeer replicationPeer; field in ReplicationEndpoint.Context69 final ReplicationPeer replicationPeer, in Context() argument77 this.replicationPeer = replicationPeer; in Context()97 return replicationPeer; in getReplicationPeer()
208 public PeerRegionServerListener(HBaseReplicationEndpoint replicationPeer) { in PeerRegionServerListener() argument209 super(replicationPeer.getZkw()); in PeerRegionServerListener()210 this.replicationEndpoint = replicationPeer; in PeerRegionServerListener()
205 ReplicationPeer replicationPeer = this.peerClusters.get(id); in getTableCFs() local206 if (replicationPeer == null) { in getTableCFs()209 return replicationPeer.getTableCFs(); in getTableCFs()214 ReplicationPeer replicationPeer = this.peerClusters.get(id); in getStatusOfPeer() local215 if (replicationPeer == null) { in getStatusOfPeer()218 return replicationPeer.getPeerState() == PeerState.ENABLED; in getStatusOfPeer()
436 final ReplicationPeerConfig peerConfig, final ReplicationPeer replicationPeer) in getReplicationSource() argument486 replicationEndpoint.init(new ReplicationEndpoint.Context(replicationPeer.getConfiguration(), in getReplicationSource()487 fs, peerConfig, peerId, clusterId, replicationPeer, metrics, tableDescriptors)); in getReplicationSource()