org.apache.hadoop.hbase.zookeeper.ZKServerTool类的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.0k)|赞(0)|评价(0)|浏览(167)

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

ZKServerTool介绍

[英]Tool for reading ZooKeeper servers from HBase XML configuration and producing a line-by-line list for use by bash scripts.
[中]用于从HBase XML配置中读取ZooKeeper服务器并生成供bash脚本使用的逐行列表的工具。

代码示例

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

/**
  * Run the tool.
  * @param args Command line arguments.
  */
 public static void main(String[] args) {
  for(ServerName server: readZKNodes(HBaseConfiguration.create())) {
   // bin/zookeeper.sh relies on the "ZK host" string for grepping which is case sensitive.
   System.out.println("ZK host: " + server.getHostname());
  }
 }
}

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

@Override
 public void perform() throws Exception {
  LOG.info("Performing action: Restart random zookeeper node");
  ServerName server = PolicyBasedChaosMonkey.selectRandomItem(
    ZKServerTool.readZKNodes(getConf()));
  restartZKNode(server, sleepTime);
 }
}

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

/**
  * Run the tool.
  * @param args Command line arguments.
  */
 public static void main(String[] args) {
  for(ServerName server: readZKNodes(HBaseConfiguration.create())) {
   // bin/zookeeper.sh relies on the "ZK host" string for grepping which is case sensitive.
   System.out.println("ZK host: " + server.getHostname());
  }
 }
}

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

/**
  * Run the tool.
  * @param args Command line arguments.
  */
 public static void main(String args[]) {
  for(ServerName server: readZKNodes(HBaseConfiguration.create())) {
   // bin/zookeeper.sh relies on the "ZK host" string for grepping which is case sensitive.
   System.out.println("ZK host: " + server.getHostname());
  }
 }
}

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

@Override
 public void perform() throws Exception {
  LOG.info("Performing action: Restart random zookeeper node");
  ServerName server = PolicyBasedChaosMonkey.selectRandomItem(
    ZKServerTool.readZKNodes(getConf()));
  restartZKNode(server, sleepTime);
 }
}

相关文章

ZKServerTool类方法