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

ZooKeeperWatcher.getZNodeForReplica介绍

[英]Get the znode string corresponding to a replicaId
[中]获取与replicaId对应的znode字符串

代码示例

代码示例来源：origin: com.aliyun.hbase/alihbase-client

/**
 * Is it the default meta replica's znode
 * @param node
 * @return true or false
 */
public boolean isDefaultMetaReplicaZnode(String node) {
 if (getZNodeForReplica(HRegionInfo.DEFAULT_REPLICA_ID).equals(node)) {
  return true;
 }
 return false;
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Is it the default meta replica's znode
 * @param node
 * @return true or false
 */
public boolean isDefaultMetaReplicaZnode(String node) {
 if (getZNodeForReplica(HRegionInfo.DEFAULT_REPLICA_ID).equals(node)) {
  return true;
 }
 return false;
}

代码示例来源：origin: harbby/presto-connectors

public void deleteMetaLocation(ZooKeeperWatcher zookeeper, int replicaId)
throws KeeperException {
 if (replicaId == HRegionInfo.DEFAULT_REPLICA_ID) {
  LOG.info("Deleting hbase:meta region location in ZooKeeper");
 } else {
  LOG.info("Deleting hbase:meta for " + replicaId + " region location in ZooKeeper");
 }
 try {
  // Just delete the node.  Don't need any watches.
  ZKUtil.deleteNode(zookeeper, zookeeper.getZNodeForReplica(replicaId));
 } catch(KeeperException.NoNodeException nne) {
  // Has already been deleted
 }
}
/**

代码示例来源：origin: harbby/presto-connectors

private void unassignMetaReplica(HbckInfo hi) throws IOException, InterruptedException,
KeeperException {
 undeployRegions(hi);
 ZooKeeperWatcher zkw = createZooKeeperWatcher();
 try {
  ZKUtil.deleteNode(zkw, zkw.getZNodeForReplica(hi.metaEntry.getReplicaId()));
 } finally {
  zkw.close();
 }
}

代码示例来源：origin: harbby/presto-connectors

byte[] data = ProtobufUtil.prependPBMagic(pbrsr.toByteArray());
try {
 ZKUtil.setData(zookeeper, zookeeper.getZNodeForReplica(replicaId), data);
} catch(KeeperException.NoNodeException nne) {
 if (replicaId == HRegionInfo.DEFAULT_REPLICA_ID) {
    ", create it");
 ZKUtil.createAndWatch(zookeeper, zookeeper.getZNodeForReplica(replicaId), data);

代码示例来源：origin: harbby/presto-connectors

private void unassignExcessMetaReplica(ZooKeeperWatcher zkw, int numMetaReplicasConfigured) {
 // unassign the unneeded replicas (for e.g., if the previous master was configured
 // with a replication of 3 and now it is 2, we need to unassign the 1 unneeded replica)
 try {
  List<String> metaReplicaZnodes = zooKeeper.getMetaReplicaNodes();
  for (String metaReplicaZnode : metaReplicaZnodes) {
   int replicaId = zooKeeper.getMetaReplicaIdFromZnode(metaReplicaZnode);
   if (replicaId >= numMetaReplicasConfigured) {
    RegionState r = MetaTableLocator.getMetaRegionState(zkw, replicaId);
    LOG.info("Closing excess replica of meta region " + r.getRegion());
    // send a close and wait for a max of 30 seconds
    ServerManager.closeRegionSilentlyAndWait(getConnection(), r.getServerName(),
      r.getRegion(), 30000);
    ZKUtil.deleteNode(zkw, zkw.getZNodeForReplica(replicaId));
   }
  }
 } catch (Exception ex) {
  // ignore the exception since we don't want the master to be wedged due to potential
  // issues in the cleanup of the extra regions. We can do that cleanup via hbck or manually
  LOG.warn("Ignoring exception " + ex);
 }
}

代码示例来源：origin: harbby/presto-connectors

ServerName serverName = null;
try {
 byte[] data = ZKUtil.getData(zkw, zkw.getZNodeForReplica(replicaId));
 if (data != null && data.length > 0 && ProtobufUtil.isPBMagicPrefix(data)) {
  try {