| /dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ |
| H A D | ReplicationPeersZKImpl.java | 108 public void addPeer(String id, ReplicationPeerConfig peerConfig, String tableCFs) in addPeer()
250 ReplicationPeerConfig peerConfig = getReplicationPeerConfig(id); in getAllPeerConfigs() local
312 ReplicationPeerConfig peerConfig = getReplicationPeerConfig(peerId); in getPeerConf() local
508 ReplicationPeerConfig peerConfig = new ReplicationPeerConfig(); in convert() local
526 private static ZooKeeperProtos.ReplicationPeer convert(ReplicationPeerConfig peerConfig) { in convert()
558 private static byte[] toByteArray(final ReplicationPeerConfig peerConfig) { in toByteArray()
|
| H A D | ReplicationPeerZKImpl.java | 48 private final ReplicationPeerConfig peerConfig; field in ReplicationPeerZKImpl
64 public ReplicationPeerZKImpl(Configuration conf, String id, ReplicationPeerConfig peerConfig) in ReplicationPeerZKImpl()
79 public ReplicationPeerZKImpl(Configuration conf, String id, ReplicationPeerConfig peerConfig, in ReplicationPeerZKImpl()
|
| H A D | ReplicationPeers.java | 55 void addPeer(String peerId, ReplicationPeerConfig peerConfig, String tableCFs) in addPeer()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/ |
| H A D | ReplicationEndpoint.java | 56 private final ReplicationPeerConfig peerConfig; field in ReplicationEndpoint.Context
66 final ReplicationPeerConfig peerConfig, in Context()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/ |
| H A D | TestRegionReplicaReplicationEndpoint.java | 122 ReplicationPeerConfig peerConfig = admin.getPeerConfig(peerId); in testRegionReplicaReplicationPeerIsCreated() local
155 ReplicationPeerConfig peerConfig = admin.getPeerConfig(peerId); in testRegionReplicaReplicationPeerIsCreatedForModifyTable() local
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ |
| H A D | ReplicationSourceManager.java | 256 ReplicationPeerConfig peerConfig = replicationPeers.getReplicationPeerConfig(id); in addSource() local
436 final ReplicationPeerConfig peerConfig, final ReplicationPeer replicationPeer) in getReplicationSource()
652 ReplicationPeerConfig peerConfig = null; in run() local
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/util/ |
| H A D | ServerRegionReplicaUtil.java | 150 ReplicationPeerConfig peerConfig = new ReplicationPeerConfig(); in setupRegionReplicaReplication() local
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/ |
| H A D | VerifyReplication.java | 265 ReplicationPeerConfig peerConfig = peerConfigPair.getFirst(); in createSubmittableJob() local
|
| /dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/payment/ |
| H A D | p2p.go | 668 func (w *p2pWatcher) peerConfig() *peer.Config { func
|
| /dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/payment/ |
| H A D | p2p.go | 668 func (w *p2pWatcher) peerConfig() *peer.Config { func
|
| /dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/payment/ |
| H A D | p2p.go | 668 func (w *p2pWatcher) peerConfig() *peer.Config { func
|
| /dports/net-p2p/bitmark/bitmarkd-0.13.3/payment/ |
| H A D | p2p.go | 668 func (w *p2pWatcher) peerConfig() *peer.Config { func
|
| /dports/databases/hbase/hbase-1.2.1/hbase-it/src/test/java/org/apache/hadoop/hbase/test/ |
| H A D | IntegrationTestReplication.java | 232 ReplicationPeerConfig peerConfig = new ReplicationPeerConfig(); in setupTablesAndReplication() local
|