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

ZKFailoverController.getParentZnode介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

private boolean confirmFormat() {
 String parentZnode = getParentZnode();
 System.err.println(
   "===============================================\n" +
   "The configured parent znode " + parentZnode + " already exists.\n" +
   "Are you sure you want to clear all failover information from\n" +
   "ZooKeeper?\n" +
   "WARNING: Before proceeding, ensure that all HDFS services and\n" +
   "failover controllers are stopped!\n" +
   "===============================================");
 try {
  return ToolRunner.confirmPrompt("Proceed formatting " + parentZnode + "?");
 } catch (IOException e) {
  LOG.debug("Failed to confirm", e);
  return false;
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

private void initZK() throws HadoopIllegalArgumentException, IOException,
  KeeperException {
 zkQuorum = conf.get(ZK_QUORUM_KEY);
 int zkTimeout = conf.getInt(ZK_SESSION_TIMEOUT_KEY,
   ZK_SESSION_TIMEOUT_DEFAULT);
 // Parse ACLs from configuration.
 String zkAclConf = conf.get(ZK_ACL_KEY, ZK_ACL_DEFAULT);
 zkAclConf = ZKUtil.resolveConfIndirection(zkAclConf);
 List<ACL> zkAcls = ZKUtil.parseACLs(zkAclConf);
 if (zkAcls.isEmpty()) {
  zkAcls = Ids.CREATOR_ALL_ACL;
 }
 
 // Parse authentication from configuration.
 List<ZKAuthInfo> zkAuths = SecurityUtil.getZKAuthInfos(conf, ZK_AUTH_KEY);
 // Sanity check configuration.
 Preconditions.checkArgument(zkQuorum != null,
   "Missing required configuration '%s' for ZooKeeper quorum",
   ZK_QUORUM_KEY);
 Preconditions.checkArgument(zkTimeout > 0,
   "Invalid ZK session timeout %s", zkTimeout);
 
 int maxRetryNum = conf.getInt(
   CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_KEY,
   CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
 elector = new ActiveStandbyElector(zkQuorum,
   zkTimeout, getParentZnode(), zkAcls, zkAuths,
   new ElectorCallbacks(), maxRetryNum);
}

代码示例来源：origin: io.hops/hadoop-common

private boolean confirmFormat() {
 String parentZnode = getParentZnode();
 System.err.println(
   "===============================================\n" +
   "The configured parent znode " + parentZnode + " already exists.\n" +
   "Are you sure you want to clear all failover information from\n" +
   "ZooKeeper?\n" +
   "WARNING: Before proceeding, ensure that all HDFS services and\n" +
   "failover controllers are stopped!\n" +
   "===============================================");
 try {
  return ToolRunner.confirmPrompt("Proceed formatting " + parentZnode + "?");
 } catch (IOException e) {
  LOG.debug("Failed to confirm", e);
  return false;
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

private boolean confirmFormat() {
 String parentZnode = getParentZnode();
 System.err.println(
   "===============================================\n" +
   "The configured parent znode " + parentZnode + " already exists.\n" +
   "Are you sure you want to clear all failover information from\n" +
   "ZooKeeper?\n" +
   "WARNING: Before proceeding, ensure that all HDFS services and\n" +
   "failover controllers are stopped!\n" +
   "===============================================");
 try {
  return ToolRunner.confirmPrompt("Proceed formatting " + parentZnode + "?");
 } catch (IOException e) {
  LOG.debug("Failed to confirm", e);
  return false;
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

private boolean confirmFormat() {
 String parentZnode = getParentZnode();
 System.err.println(
   "===============================================\n" +
   "The configured parent znode " + parentZnode + " already exists.\n" +
   "Are you sure you want to clear all failover information from\n" +
   "ZooKeeper?\n" +
   "WARNING: Before proceeding, ensure that all HDFS services and\n" +
   "failover controllers are stopped!\n" +
   "===============================================");
 try {
  return ToolRunner.confirmPrompt("Proceed formatting " + parentZnode + "?");
 } catch (IOException e) {
  LOG.debug("Failed to confirm", e);
  return false;
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

private boolean confirmFormat() {
 String parentZnode = getParentZnode();
 System.err.println(
   "===============================================\n" +
   "The configured parent znode " + parentZnode + " already exists.\n" +
   "Are you sure you want to clear all failover information from\n" +
   "ZooKeeper?\n" +
   "WARNING: Before proceeding, ensure that all HDFS services and\n" +
   "failover controllers are stopped!\n" +
   "===============================================");
 try {
  return ToolRunner.confirmPrompt("Proceed formatting " + parentZnode + "?");
 } catch (IOException e) {
  LOG.debug("Failed to confirm", e);
  return false;
 }
}

代码示例来源：origin: io.hops/hadoop-common

CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
elector = new ActiveStandbyElector(zkQuorum,
  zkTimeout, getParentZnode(), zkAcls, zkAuths,
  new ElectorCallbacks(), maxRetryNum);

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
elector = new ActiveStandbyElector(zkQuorum,
  zkTimeout, getParentZnode(), zkAcls, zkAuths,
  new ElectorCallbacks(), maxRetryNum);

代码示例来源：origin: ch.cern.hadoop/hadoop-common

CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
elector = new ActiveStandbyElector(zkQuorum,
  zkTimeout, getParentZnode(), zkAcls, zkAuths,
  new ElectorCallbacks(), maxRetryNum);

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

CommonConfigurationKeys.HA_FC_ELECTOR_ZK_OP_RETRIES_DEFAULT);
elector = new ActiveStandbyElector(zkQuorum,
  zkTimeout, getParentZnode(), zkAcls, zkAuths,
  new ElectorCallbacks(), maxRetryNum);