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

ZKUtils.getActiveNameNode介绍

[英]Gets the active namenode name.
[中]获取活动名称节点名称。

代码示例

代码示例来源：origin: Impetus/jumbune

/**
 * Gets the leader name node from zookeeper.
 * @param zkHosts 
 *
 * @return the leader name node from zookeeper
 */
public static byte[] getLeaderNameNodeFromZK(String[] zkHosts) {
  final int retryTimes = 10;
  byte[] nameHostName = null;
  int retryCount = 1;
  do {
    List<String> nameNodeNameList = getNodeChildrenList(zkHosts, ZKConstants.HADOOP_NODE_PATH);
    for (String nameNodeName : nameNodeNameList) {
      nameHostName = getActiveNameNode(zkHosts,
          ZKConstants.HADOOP_NODE_PATH + File.separator + nameNodeName + ZKConstants.ACTIVE_BREAD_CRUMB);
    }
    if (nameHostName == null) {
      try {
        LOGGER.warn("found active NN null from ZK, retrying after " + 100 * retryCount + " millisecs");
        Thread.sleep(100 * retryCount);
      } catch (InterruptedException e) {
      }
    }
    retryCount++;
  } while (nameHostName == null && retryCount <= retryTimes);
  return nameHostName;
}

代码示例来源：origin: Impetus/jumbune

/**
 * Gets the leader name node from zookeeper.
 * @param zkHosts 
 *
 * @return the leader name node from zookeeper
 */
public static byte[] getLeaderNameNodeFromZK(String[] zkHosts) {
  final int retryTimes = 10;
  byte[] nameHostName = null;
  int retryCount = 1;
  do {
    List<String> nameNodeNameList = getNodeChildrenList(zkHosts, ZKConstants.HADOOP_NODE_PATH);
    for (String nameNodeName : nameNodeNameList) {
      nameHostName = getActiveNameNode(zkHosts,
          ZKConstants.HADOOP_NODE_PATH + File.separator + nameNodeName + ZKConstants.ACTIVE_BREAD_CRUMB);
    }
    if (nameHostName == null) {
      try {
        LOGGER.warn("found active NN null from ZK, retrying after " + 100 * retryCount + " millisecs");
        Thread.sleep(100 * retryCount);
      } catch (InterruptedException e) {
      }
    }
    retryCount++;
  } while (nameHostName == null && retryCount <= retryTimes);
  return nameHostName;
}