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

ZKReplicationPeerStorage.getNewSyncReplicationStateNode介绍

暂无

代码示例

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

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

代码示例来源：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 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

@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

ZKUtil.deleteNode(UTIL.getZooKeeperWatcher(), STORAGE.getNewSyncReplicationStateNode(peerId));
 ZKUtil.checkExists(UTIL.getZooKeeperWatcher(), STORAGE.getSyncReplicationStateNode(peerId)));
assertNotEquals(-1, ZKUtil.checkExists(UTIL.getZooKeeperWatcher(),
 STORAGE.getNewSyncReplicationStateNode(peerId)));