本文整理了Java中org.apache.hadoop.hbase.replication.ZKReplicationPeerStorage类的一些代码示例，展示了ZKReplicationPeerStorage类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKReplicationPeerStorage类的具体详情如下：
包路径：org.apache.hadoop.hbase.replication.ZKReplicationPeerStorage
类名称：ZKReplicationPeerStorage

ZKReplicationPeerStorage介绍

[英]ZK based replication peer storage.
[中]基于ZK的复制对等存储。

代码示例

代码示例来源：origin: apache/hbase

/**
 * Create a new {@link ReplicationPeerStorage}.
 */
public static ReplicationPeerStorage getReplicationPeerStorage(ZKWatcher zk, Configuration conf) {
 return new ZKReplicationPeerStorage(zk, conf);
}

代码示例来源：origin: apache/hbase

@Override
public void addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled,
  SyncReplicationState syncReplicationState) throws ReplicationException {
 List<ZKUtilOp> multiOps = Arrays.asList(
  ZKUtilOp.createAndFailSilent(getPeerNode(peerId),
   ReplicationPeerConfigUtil.toByteArray(peerConfig)),
  ZKUtilOp.createAndFailSilent(getPeerStateNode(peerId),
   enabled ? ENABLED_ZNODE_BYTES : DISABLED_ZNODE_BYTES),
  ZKUtilOp.createAndFailSilent(getSyncReplicationStateNode(peerId),
   SyncReplicationState.toByteArray(syncReplicationState)),
  ZKUtilOp.createAndFailSilent(getNewSyncReplicationStateNode(peerId), NONE_STATE_ZNODE_BYTES));
 try {
  ZKUtil.createWithParents(zookeeper, peersZNode);
  ZKUtil.multiOrSequential(zookeeper, multiOps, false);
 } catch (KeeperException e) {
  throw new ReplicationException(
   "Could not add peer with id=" + peerId + ", peerConfig=>" + peerConfig + ", state=" +
    (enabled ? "ENABLED" : "DISABLED") + ", syncReplicationState=" + syncReplicationState,
   e);
 }
}

代码示例来源：origin: apache/hbase

@Override
 public SyncReplicationState getPeerSyncReplicationState(String peerId)
   throws ReplicationException {
  return getSyncReplicationState(peerId, getSyncReplicationStateNode(peerId));
 }
}

代码示例来源：origin: apache/hbase

@Override
public SyncReplicationState getPeerNewSyncReplicationState(String peerId)
  throws ReplicationException {
 return getSyncReplicationState(peerId, getNewSyncReplicationStateNode(peerId));
}

代码示例来源：origin: apache/hbase

@Override
public void transitPeerSyncReplicationState(String peerId) throws ReplicationException {
 String newStateNode = getNewSyncReplicationStateNode(peerId);
 try {
  byte[] data = ZKUtil.getData(zookeeper, newStateNode);
  ZKUtil.multiOrSequential(zookeeper,
   Arrays.asList(ZKUtilOp.setData(newStateNode, NONE_STATE_ZNODE_BYTES),
    ZKUtilOp.setData(getSyncReplicationStateNode(peerId), data)),
   false);
 } catch (KeeperException | InterruptedException e) {
  throw new ReplicationException(
   "Error transiting sync replication state for peer with id=" + peerId, e);
 }
}

代码示例来源：origin: apache/hbase

int peerCount = 10;
for (int i = 0; i < peerCount; i++) {
 STORAGE.addPeer(Integer.toString(i), getConfig(i), i % 2 == 0,
  SyncReplicationState.valueOf(i % 4));
List<String> peerIds = STORAGE.listPeerIds();
assertEquals(peerCount, peerIds.size());
for (String peerId : peerIds) {
 int seed = Integer.parseInt(peerId);
 assertConfigEquals(getConfig(seed), STORAGE.getPeerConfig(peerId));
 STORAGE.updatePeerConfig(Integer.toString(i), getConfig(i + 1));
 assertConfigEquals(getConfig(seed + 1), STORAGE.getPeerConfig(peerId));
 assertEquals(i % 2 == 0, STORAGE.isPeerEnabled(Integer.toString(i)));
 STORAGE.setPeerState(Integer.toString(i), i % 2 != 0);
 assertEquals(i % 2 != 0, STORAGE.isPeerEnabled(Integer.toString(i)));
  STORAGE.getPeerSyncReplicationState(Integer.toString(i)));
STORAGE.removePeer(toRemove);
peerIds = STORAGE.listPeerIds();
assertEquals(peerCount - 1, peerIds.size());
assertFalse(peerIds.contains(toRemove));
 STORAGE.getPeerConfig(toRemove);

代码示例来源：origin: apache/hbase

STORAGE.getPeerSyncReplicationState(peerId);
 fail("Should throw a ReplicationException when getting state of inexist peer");
} catch (ReplicationException e) {
 STORAGE.getPeerNewSyncReplicationState(peerId);
 fail("Should throw a ReplicationException when getting state of inexist peer");
} catch (ReplicationException e) {
STORAGE.addPeer(peerId, getConfig(0), true, SyncReplicationState.NONE);
ZKUtil.deleteNode(UTIL.getZooKeeperWatcher(), STORAGE.getSyncReplicationStateNode(peerId));
ZKUtil.deleteNode(UTIL.getZooKeeperWatcher(), STORAGE.getNewSyncReplicationStateNode(peerId));
assertEquals(SyncReplicationState.NONE, STORAGE.getPeerSyncReplicationState(peerId));
assertEquals(SyncReplicationState.NONE, STORAGE.getPeerNewSyncReplicationState(peerId));
 ZKUtil.checkExists(UTIL.getZooKeeperWatcher(), STORAGE.getSyncReplicationStateNode(peerId)));
assertNotEquals(-1, ZKUtil.checkExists(UTIL.getZooKeeperWatcher(),
 STORAGE.getNewSyncReplicationStateNode(peerId)));

代码示例来源：origin: apache/hbase

@VisibleForTesting
public String getNewSyncReplicationStateNode(String peerId) {
 return ZNodePaths.joinZNode(getPeerNode(peerId), NEW_SYNC_REPLICATION_STATE_ZNODE);
}

代码示例来源：origin: apache/hbase

@Override
public void setPeerNewSyncReplicationState(String peerId, SyncReplicationState state)
  throws ReplicationException {
 try {
  ZKUtil.createSetData(zookeeper, getNewSyncReplicationStateNode(peerId),
   SyncReplicationState.toByteArray(state));
 } catch (KeeperException e) {
  throw new ReplicationException(
   "Unable to set the new sync replication state for peer with id=" + peerId, e);
 }
}

代码示例来源：origin: apache/hbase

@Override
public boolean isPeerEnabled(String peerId) throws ReplicationException {
 try {
  return Arrays.equals(ENABLED_ZNODE_BYTES,
   ZKUtil.getData(zookeeper, getPeerStateNode(peerId)));
 } catch (KeeperException | InterruptedException e) {
  throw new ReplicationException("Unable to get status of the peer with id=" + peerId, e);
 }
}

代码示例来源：origin: org.apache.hbase/hbase-replication

@Override
public void addPeer(String peerId, ReplicationPeerConfig peerConfig, boolean enabled)
  throws ReplicationException {
 try {
  ZKUtil.createWithParents(zookeeper, peersZNode);
  ZKUtil.multiOrSequential(zookeeper,
   Arrays.asList(
    ZKUtilOp.createAndFailSilent(getPeerNode(peerId),
     ReplicationPeerConfigUtil.toByteArray(peerConfig)),
    ZKUtilOp.createAndFailSilent(getPeerStateNode(peerId),
     enabled ? ENABLED_ZNODE_BYTES : DISABLED_ZNODE_BYTES)),
   false);
 } catch (KeeperException e) {
  throw new ReplicationException("Could not add peer with id=" + peerId + ", peerConfif=>"
    + peerConfig + ", state=" + (enabled ? "ENABLED" : "DISABLED"), e);
 }
}

代码示例来源：origin: apache/hbase

@Override
public void removePeer(String peerId) throws ReplicationException {
 try {
  ZKUtil.deleteNodeRecursively(zookeeper, getPeerNode(peerId));
 } catch (KeeperException e) {
  throw new ReplicationException("Could not remove peer with id=" + peerId, e);
 }
}

代码示例来源：origin: apache/hbase

@Override
public void setPeerState(String peerId, boolean enabled) throws ReplicationException {
 byte[] stateBytes = enabled ? ENABLED_ZNODE_BYTES : DISABLED_ZNODE_BYTES;
 try {
  ZKUtil.setData(zookeeper, getPeerStateNode(peerId), stateBytes);
 } catch (KeeperException e) {
  throw new ReplicationException("Unable to change state of the peer with id=" + peerId, e);
 }
}

代码示例来源：origin: apache/hbase

@BeforeClass
public static void setUp() throws Exception {
 UTIL.startMiniZKCluster();
 STORAGE = new ZKReplicationPeerStorage(UTIL.getZooKeeperWatcher(), UTIL.getConfiguration());
}

代码示例来源：origin: apache/hbase

@VisibleForTesting
public String getSyncReplicationStateNode(String peerId) {
 return ZNodePaths.joinZNode(getPeerNode(peerId), SYNC_REPLICATION_STATE_ZNODE);
}

代码示例来源：origin: org.apache.hbase/hbase-replication

@Override
public boolean isPeerEnabled(String peerId) throws ReplicationException {
 try {
  return Arrays.equals(ENABLED_ZNODE_BYTES,
   ZKUtil.getData(zookeeper, getPeerStateNode(peerId)));
 } catch (KeeperException | InterruptedException e) {
  throw new ReplicationException("Unable to get status of the peer with id=" + peerId, e);
 }
}

代码示例来源：origin: org.apache.hbase/hbase-replication

/**
 * Create a new {@link ReplicationPeerStorage}.
 */
public static ReplicationPeerStorage getReplicationPeerStorage(ZKWatcher zk, Configuration conf) {
 return new ZKReplicationPeerStorage(zk, conf);
}

代码示例来源：origin: apache/hbase

@VisibleForTesting
public String getPeerStateNode(String peerId) {
 return ZNodePaths.joinZNode(getPeerNode(peerId), peerStateNodeName);
}

代码示例来源：origin: org.apache.hbase/hbase-replication

@Override
public void setPeerState(String peerId, boolean enabled) throws ReplicationException {
 byte[] stateBytes = enabled ? ENABLED_ZNODE_BYTES : DISABLED_ZNODE_BYTES;
 try {
  ZKUtil.setData(zookeeper, getPeerStateNode(peerId), stateBytes);
 } catch (KeeperException e) {
  throw new ReplicationException("Unable to change state of the peer with id=" + peerId, e);
 }
}

代码示例来源：origin: apache/hbase

@Override
public void updatePeerConfig(String peerId, ReplicationPeerConfig peerConfig)
  throws ReplicationException {
 try {
  ZKUtil.setData(this.zookeeper, getPeerNode(peerId),
   ReplicationPeerConfigUtil.toByteArray(peerConfig));
 } catch (KeeperException e) {
  throw new ReplicationException(
   "There was a problem trying to save changes to the " + "replication peer " + peerId, e);
 }
}