org.apache.hadoop.hbase.zookeeper.MiniZooKeeperCluster.waitForServerDown()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(77)

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

MiniZooKeeperCluster.waitForServerDown介绍

暂无

代码示例

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

/**
 * @throws IOException if waiting for the shutdown of a server fails
 */
public void shutdown() throws IOException {
 // shut down all the zk servers
 for (int i = 0; i < standaloneServerFactoryList.size(); i++) {
  NIOServerCnxnFactory standaloneServerFactory =
   standaloneServerFactoryList.get(i);
  int clientPort = clientPortList.get(i);
  standaloneServerFactory.shutdown();
  if (!waitForServerDown(clientPort, connectionTimeout)) {
   throw new IOException("Waiting for shutdown of standalone server");
  }
 }
 standaloneServerFactoryList.clear();
 for (ZooKeeperServer zkServer: zooKeeperServers) {
  //explicitly close ZKDatabase since ZookeeperServer does not close them
  zkServer.getZKDatabase().close();
 }
 zooKeeperServers.clear();
 // clear everything
 if (started) {
  started = false;
  activeZKServerIndex = 0;
  clientPortList.clear();
  LOG.info("Shutdown MiniZK cluster with all ZK servers");
 }
}

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

if (!waitForServerDown(clientPort, connectionTimeout)) {
 throw new IOException("Waiting for shutdown of standalone server");

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

/**
 * Kill one back up ZK servers.
 *
 * @throws IOException if waiting for the shutdown of a server fails
 */
public void killOneBackupZooKeeperServer() throws IOException, InterruptedException {
 if (!started || activeZKServerIndex < 0 || standaloneServerFactoryList.size() <= 1) {
  return ;
 }
 int backupZKServerIndex = activeZKServerIndex+1;
 // Shutdown the current active one
 NIOServerCnxnFactory standaloneServerFactory =
  standaloneServerFactoryList.get(backupZKServerIndex);
 int clientPort = clientPortList.get(backupZKServerIndex);
 standaloneServerFactory.shutdown();
 if (!waitForServerDown(clientPort, connectionTimeout)) {
  throw new IOException("Waiting for shutdown of standalone server");
 }
 zooKeeperServers.get(backupZKServerIndex).getZKDatabase().close();
 // remove this backup zk server
 standaloneServerFactoryList.remove(backupZKServerIndex);
 clientPortList.remove(backupZKServerIndex);
 zooKeeperServers.remove(backupZKServerIndex);
 LOG.info("Kill one backup ZK servers in the cluster " +
   "on client port: " + clientPort);
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * @throws IOException
 */
public void shutdown() throws IOException {
 if (!started) {
  return;
 }
 // shut down all the zk servers
 for (int i = 0; i < standaloneServerFactoryList.size(); i++) {
  NIOServerCnxnFactory standaloneServerFactory =
   standaloneServerFactoryList.get(i);
  int clientPort = clientPortList.get(i);
  standaloneServerFactory.shutdown();
  if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
   throw new IOException("Waiting for shutdown of standalone server");
  }
 }
 // clear everything
 started = false;
 activeZKServerIndex = 0;
 standaloneServerFactoryList.clear();
 clientPortList.clear();
 zooKeeperServers.clear();
 LOG.info("Shutdown MiniZK cluster with all ZK servers");
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * Kill one back up ZK servers
 * @throws IOException
 * @throws InterruptedException
 */
public void killOneBackupZooKeeperServer() throws IOException,
                   InterruptedException {
 if (!started || activeZKServerIndex < 0 ||
   standaloneServerFactoryList.size() <= 1) {
  return ;
 }
 int backupZKServerIndex = activeZKServerIndex+1;
 // Shutdown the current active one
 NIOServerCnxnFactory standaloneServerFactory =
  standaloneServerFactoryList.get(backupZKServerIndex);
 int clientPort = clientPortList.get(backupZKServerIndex);
 standaloneServerFactory.shutdown();
 if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
  throw new IOException("Waiting for shutdown of standalone server");
 }
 // remove this backup zk server
 standaloneServerFactoryList.remove(backupZKServerIndex);
 clientPortList.remove(backupZKServerIndex);
 zooKeeperServers.remove(backupZKServerIndex);
 LOG.info("Kill one backup ZK servers in the cluster " +
   "on client port: " + clientPort);
}

代码示例来源：origin: co.cask.hbase/hbase

if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
 throw new IOException("Waiting for shutdown of standalone server");

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

/**
 * Kill one back up ZK servers.
 *
 * @throws IOException if waiting for the shutdown of a server fails
 */
public void killOneBackupZooKeeperServer() throws IOException, InterruptedException {
 if (!started || activeZKServerIndex < 0 || standaloneServerFactoryList.size() <= 1) {
  return ;
 }
 int backupZKServerIndex = activeZKServerIndex+1;
 // Shutdown the current active one
 NIOServerCnxnFactory standaloneServerFactory =
  standaloneServerFactoryList.get(backupZKServerIndex);
 int clientPort = clientPortList.get(backupZKServerIndex);
 standaloneServerFactory.shutdown();
 if (!waitForServerDown(clientPort, connectionTimeout)) {
  throw new IOException("Waiting for shutdown of standalone server");
 }
 zooKeeperServers.get(backupZKServerIndex).getZKDatabase().close();
 // remove this backup zk server
 standaloneServerFactoryList.remove(backupZKServerIndex);
 clientPortList.remove(backupZKServerIndex);
 zooKeeperServers.remove(backupZKServerIndex);
 LOG.info("Kill one backup ZK servers in the cluster " +
   "on client port: " + clientPort);
}

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

/**
 * @throws IOException if waiting for the shutdown of a server fails
 */
public void shutdown() throws IOException {
 // shut down all the zk servers
 for (int i = 0; i < standaloneServerFactoryList.size(); i++) {
  NIOServerCnxnFactory standaloneServerFactory =
   standaloneServerFactoryList.get(i);
  int clientPort = clientPortList.get(i);
  standaloneServerFactory.shutdown();
  if (!waitForServerDown(clientPort, connectionTimeout)) {
   throw new IOException("Waiting for shutdown of standalone server");
  }
 }
 standaloneServerFactoryList.clear();
 for (ZooKeeperServer zkServer: zooKeeperServers) {
  //explicitly close ZKDatabase since ZookeeperServer does not close them
  zkServer.getZKDatabase().close();
 }
 zooKeeperServers.clear();
 // clear everything
 if (started) {
  started = false;
  activeZKServerIndex = 0;
  clientPortList.clear();
  LOG.info("Shutdown MiniZK cluster with all ZK servers");
 }
}

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

if (!waitForServerDown(clientPort, connectionTimeout)) {
 throw new IOException("Waiting for shutdown of standalone server");

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

/**
 * Kill one back up ZK servers
 * @throws IOException
 * @throws InterruptedException
 */
public void killOneBackupZooKeeperServer() throws IOException,
                   InterruptedException {
 if (!started || activeZKServerIndex < 0 ||
   standaloneServerFactoryList.size() <= 1) {
  return ;
 }
 int backupZKServerIndex = activeZKServerIndex+1;
 // Shutdown the current active one
 NIOServerCnxnFactory standaloneServerFactory =
  standaloneServerFactoryList.get(backupZKServerIndex);
 int clientPort = clientPortList.get(backupZKServerIndex);
 standaloneServerFactory.shutdown();
 if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
  throw new IOException("Waiting for shutdown of standalone server");
 }
 zooKeeperServers.get(backupZKServerIndex).getZKDatabase().close();
 // remove this backup zk server
 standaloneServerFactoryList.remove(backupZKServerIndex);
 clientPortList.remove(backupZKServerIndex);
 zooKeeperServers.remove(backupZKServerIndex);
 LOG.info("Kill one backup ZK servers in the cluster " +
   "on client port: " + clientPort);
}

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

/**
 * @throws IOException
 */
public void shutdown() throws IOException {
 // shut down all the zk servers
 for (int i = 0; i < standaloneServerFactoryList.size(); i++) {
  NIOServerCnxnFactory standaloneServerFactory =
   standaloneServerFactoryList.get(i);
  int clientPort = clientPortList.get(i);
  standaloneServerFactory.shutdown();
  if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
   throw new IOException("Waiting for shutdown of standalone server");
  }
 }
 standaloneServerFactoryList.clear();
 for (ZooKeeperServer zkServer: zooKeeperServers) {
  //explicitly close ZKDatabase since ZookeeperServer does not close them
  zkServer.getZKDatabase().close();
 }
 zooKeeperServers.clear();
 // clear everything
 if (started) {
  started = false;
  activeZKServerIndex = 0;
  clientPortList.clear();
  LOG.info("Shutdown MiniZK cluster with all ZK servers");
 }
}

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

if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
 throw new IOException("Waiting for shutdown of standalone server");

代码示例来源：origin: kakao/hbase-tools

/**
 * Kill one back up ZK servers
 * @throws IOException
 * @throws InterruptedException
 */
public void killOneBackupZooKeeperServer() throws IOException,
    InterruptedException {
  if (!started || activeZKServerIndex < 0 ||
      standaloneServerFactoryList.size() <= 1) {
    return ;
  }
  int backupZKServerIndex = activeZKServerIndex+1;
  // Shutdown the current active one
  NIOServerCnxnFactory standaloneServerFactory =
      standaloneServerFactoryList.get(backupZKServerIndex);
  int clientPort = clientPortList.get(backupZKServerIndex);
  standaloneServerFactory.shutdown();
  if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
    throw new IOException("Waiting for shutdown of standalone server");
  }
  zooKeeperServers.get(backupZKServerIndex).getZKDatabase().close();
  // remove this backup zk server
  standaloneServerFactoryList.remove(backupZKServerIndex);
  clientPortList.remove(backupZKServerIndex);
  zooKeeperServers.remove(backupZKServerIndex);
  LOG.info("Kill one backup ZK servers in the cluster " +
      "on client port: " + clientPort);
}

代码示例来源：origin: kakao/hbase-tools

if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
  throw new IOException("Waiting for shutdown of standalone server");

代码示例来源：origin: kakao/hbase-tools

/**
 * @throws IOException
 */
public void shutdown() throws IOException {
  if (!started) {
    return;
  }
  // shut down all the zk servers
  for (int i = 0; i < standaloneServerFactoryList.size(); i++) {
    NIOServerCnxnFactory standaloneServerFactory =
        standaloneServerFactoryList.get(i);
    int clientPort = clientPortList.get(i);
    standaloneServerFactory.shutdown();
    if (!waitForServerDown(clientPort, CONNECTION_TIMEOUT)) {
      throw new IOException("Waiting for shutdown of standalone server");
    }
  }
  for (ZooKeeperServer zkServer: zooKeeperServers) {
    //explicitly close ZKDatabase since ZookeeperServer does not close them
    zkServer.getZKDatabase().close();
  }
  // clear everything
  started = false;
  activeZKServerIndex = 0;
  standaloneServerFactoryList.clear();
  clientPortList.clear();
  zooKeeperServers.clear();
  LOG.info("Shutdown MiniZK cluster with all ZK servers");
}

内容来源于网络，如有侵权，请联系作者删除！

MiniZooKeeperCluster

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com