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

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

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

MiniZooKeeperCluster.shutdown介绍

暂无

代码示例

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

@Override
public void run() {
 super.run();
 if (this.zkcluster != null) {
  try {
   this.zkcluster.shutdown();
  } catch (IOException e) {
   LOG.error("Failed to shutdown MiniZooKeeperCluster", e);
  }
 }
}

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

/**
 * Shuts down zk cluster created by call to {@link #startMiniZKCluster(File)} or does nothing.
 * @see #startMiniZKCluster()
 */
public void shutdownMiniZKCluster() throws IOException {
 if (!passedZkCluster && this.zkCluster != null) {
  this.zkCluster.shutdown();
  this.zkCluster = null;
 }
}

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

private void shutDownMiniClusters() throws Exception {
 int numClusters = utilities.length;
 for (int i = numClusters - 1; i >= 0; i--) {
  if (utilities[i] != null) {
   utilities[i].shutdownMiniCluster();
  }
 }
 miniZK.shutdown();
}

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

@Override
public void serviceStop() throws IOException {
 for (int i = 0 ; i < numInstances ; i++) {
  if (llapDaemons[i] != null) {
   llapDaemons[i].stop();
   llapDaemons[i] = null;
  }
 }
 if (ownZkCluster) {
  if (miniZooKeeperCluster != null) {
   LOG.info("Stopping MiniZooKeeper cluster");
   miniZooKeeperCluster.shutdown();
   miniZooKeeperCluster = null;
   LOG.info("Stopped MiniZooKeeper cluster");
  }
 } else {
  LOG.info("Not stopping MiniZK cluster since it is now owned by us"); 
 }
}

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

@AfterClass
public static void afterAllTests() throws Exception {
 TEST_UTIL.shutdownMiniCluster();
 clientZkCluster.shutdown();
 FileUtils.deleteDirectory(clientZkDir);
}

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

@After
public void teardown() throws Exception {
 if (cluster != null) {
  cluster.shutdown();
  cluster = null;
 }
 if (zkCluster != null) {
  zkCluster.shutdown();
  zkCluster = null;
 }
}

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

shutdown();

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

@AfterClass
public static void afterClass() throws IOException {
 UTIL.getZkCluster().shutdown();
}

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

clientZkCluster.shutdown();

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

public void tearDown() throws Exception {
  CuratorFrameworkSingleton.closeAndReleaseInstance();
  if (zooKeeperCluster != null) {
   zooKeeperCluster.shutdown();
   zooKeeperCluster = null;
  }
 }
}

代码示例来源:origin: alibaba/wasp

@Override
public void run() {
 super.run();
 if (this.zkcluster != null) {
  try {
   this.zkcluster.shutdown();
  } catch (IOException e) {
   e.printStackTrace();
  }
 }
}

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

/**
 * Shuts down zk cluster created by call to {@link #startMiniZKCluster(File)} or does nothing.
 * @see #startMiniZKCluster()
 */
public void shutdownMiniZKCluster() throws IOException {
 if (!passedZkCluster && this.zkCluster != null) {
  this.zkCluster.shutdown();
  this.zkCluster = null;
 }
}

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

@Override
public void run() {
 super.run();
 if (this.zkcluster != null) {
  try {
   this.zkcluster.shutdown();
  } catch (IOException e) {
   e.printStackTrace();
  }
 }
}

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

@Override
public void run() {
 super.run();
 if (this.zkcluster != null) {
  try {
   this.zkcluster.shutdown();
  } catch (IOException e) {
   e.printStackTrace();
  }
 }
}

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

/**
 * Shuts down zk cluster created by call to {@link #startMiniZKCluster(File)} or does nothing.
 * @see #startMiniZKCluster()
 */
public void shutdownMiniZKCluster() throws IOException {
 if (!passedZkCluster && this.zkCluster != null) {
  this.zkCluster.shutdown();
  this.zkCluster = null;
 }
}

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

private void shutDownMiniClusters() throws Exception {
 int numClusters = utilities.length;
 for (int i = numClusters - 1; i >= 0; i--) {
  if (utilities[i] != null) {
   utilities[i].shutdownMiniCluster();
  }
 }
 miniZK.shutdown();
}

代码示例来源:origin: cdapio/cdap

@AfterClass
public static void tearDown() throws Exception {
 zkCluster.shutdown();
}

代码示例来源:origin: cdapio/cdap

@AfterClass
public static void tearDown() throws Exception {
 zkCluster.shutdown();
}

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

@AfterClass
public static void afterAllTests() throws Exception {
 TEST_UTIL.shutdownMiniCluster();
 clientZkCluster.shutdown();
 FileUtils.deleteDirectory(clientZkDir);
}

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

@After
public void teardown() throws Exception {
 if (cluster != null) {
  cluster.shutdown();
  cluster = null;
 }
 if (zkCluster != null) {
  zkCluster.shutdown();
  zkCluster = null;
 }
}

相关文章