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

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

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

ZKUtil.deleteNodeRecursively介绍

[英]Delete the specified node and all of it's children.

If the node does not exist, just returns.

Sets no watches. Throws all exceptions besides dealing with deletion of children.
[中]删除指定的节点及其所有子节点。
如果节点不存在，只返回。
没有手表。抛出除处理删除子项之外的所有异常。

代码示例

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

  1. /**
  2.  * Disable long-term archival of all hfiles for all tables in the cluster.
  3.  * @return <tt>this</tt> for chaining.
  4.  * @throws IOException if the number of attempts is exceeded
  5.  */
  6. public HFileArchiveManager disableHFileBackup() throws IOException {
  7.  LOG.debug("Disabling backups on all tables.");
  8.  try {
  9.   ZKUtil.deleteNodeRecursively(this.zooKeeper, archiveZnode);
  10.   return this;
  11.  } catch (KeeperException e) {
  12.   throw new IOException("Unexpected ZK exception!", e);
  13.  }
  14. }

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

  1. @Override
  2. public void removeQueue(ServerName serverName, String queueId) throws ReplicationException {
  3.  try {
  4.   ZKUtil.deleteNodeRecursively(zookeeper, getQueueNode(serverName, queueId));
  5.  } catch (KeeperException e) {
  6.   throw new ReplicationException(
  7.     "Failed to delete queue (serverName=" + serverName + ", queueId=" + queueId + ")", e);
  8.  }
  9. }

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

  1. @Override
  2. public void removePeer(String peerId) throws ReplicationException {
  3.  try {
  4.   ZKUtil.deleteNodeRecursively(zookeeper, getPeerNode(peerId));
  5.  } catch (KeeperException e) {
  6.   throw new ReplicationException("Could not remove peer with id=" + peerId, e);
  7.  }
  8. }

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

  1. @Override
  2. public void removePeerFromHFileRefs(String peerId) throws ReplicationException {
  3.  String peerNode = getHFileRefsPeerNode(peerId);
  4.  try {
  5.   if (ZKUtil.checkExists(zookeeper, peerNode) == -1) {
  6.     LOG.debug("Peer {} not found in hfile reference queue.", peerNode);
  7.   } else {
  8.    LOG.info("Removing peer {} from hfile reference queue.", peerNode);
  9.    ZKUtil.deleteNodeRecursively(zookeeper, peerNode);
  10.   }
  11.  } catch (KeeperException e) {
  12.   throw new ReplicationException(
  13.     "Failed to remove peer " + peerId + " from hfile reference queue.", e);
  14.  }
  15. }

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

  1. @After
  2. public void tearDown() throws KeeperException, IOException {
  3.  ZKUtil.deleteNodeRecursively(zkw, replicationZNode);
  4. }

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

  1. /**
  2.  * Disable all archiving of files for a given table
  3.  * <p>
  4.  * Inherently an <b>asynchronous operation</b>.
  5.  * @param zooKeeper watcher for the ZK cluster
  6.  * @param table name of the table to disable
  7.  * @throws KeeperException if an unexpected ZK connection issues occurs
  8.  */
  9. private void disable(ZKWatcher zooKeeper, byte[] table) throws KeeperException {
  10.  // ensure the latest state of the archive node is found
  11.  zooKeeper.sync(archiveZnode);
  12.  // if the top-level archive node is gone, then we are done
  13.  if (ZKUtil.checkExists(zooKeeper, archiveZnode) < 0) {
  14.   return;
  15.  }
  16.  // delete the table node, from the archive
  17.  String tableNode = this.getTableNode(table);
  18.  // make sure the table is the latest version so the delete takes
  19.  zooKeeper.sync(tableNode);
  20.  LOG.debug("Attempting to delete table node:" + tableNode);
  21.  ZKUtil.deleteNodeRecursively(zooKeeper, tableNode);
  22. }

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

  1. /**
  2.  * Verifies that for the given root node, it should delete all the nodes recursively using
  3.  * multi-update api.
  4.  */
  5. @Test
  6. public void testDeleteNodeRecursivelyMulti() throws Exception {
  7.  String parentZNode = "/testdeleteNodeRecursivelyMulti";
  8.  createZNodeTree(parentZNode);
  9.  ZKUtil.deleteNodeRecursively(zkw, parentZNode);
  10.  assertTrue("Parent znode should be deleted.", ZKUtil.checkExists(zkw, parentZNode) == -1);
  11. }

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

  1. @After
  2. public void after() throws Exception {
  3.  TEST_UTIL.shutdownMiniHBaseCluster();
  4.  TEST_UTIL.getTestFileSystem().delete(FSUtils.getRootDir(TEST_UTIL.getConfiguration()), true);
  5.  ZKUtil.deleteNodeRecursively(TEST_UTIL.getZooKeeperWatcher(), "/hbase");
  6. }

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

  1. /**
  2.  * Create a znode with data
  3.  */
  4. @Test
  5. public void testCreateWithParents() throws KeeperException, InterruptedException {
  6.  byte[] expectedData = new byte[] { 1, 2, 3 };
  7.  ZKUtil.createWithParents(ZKW, "/l1/l2/l3/l4/testCreateWithParents", expectedData);
  8.  byte[] data = ZKUtil.getData(ZKW, "/l1/l2/l3/l4/testCreateWithParents");
  9.  assertTrue(Bytes.equals(expectedData, data));
  10.  ZKUtil.deleteNodeRecursively(ZKW, "/l1");
  11.  ZKUtil.createWithParents(ZKW, "/testCreateWithParents", expectedData);
  12.  data = ZKUtil.getData(ZKW, "/testCreateWithParents");
  13.  assertTrue(Bytes.equals(expectedData, data));
  14.  ZKUtil.deleteNodeRecursively(ZKW, "/testCreateWithParents");
  15. }

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

  1. @After
  2. public void tearDown()
  3. throws KeeperException, ZooKeeperConnectionException, IOException {
  4.  // Make sure zk is clean before we run the next test.
  5.  ZKWatcher zkw = new ZKWatcher(TESTUTIL.getConfiguration(),
  6.    "@Before", new Abortable() {
  7.   @Override
  8.   public void abort(String why, Throwable e) {
  9.    throw new RuntimeException(why, e);
  10.   }
  11.   @Override
  12.   public boolean isAborted() {
  13.    return false;
  14.   }
  15.  });
  16.  ZKUtil.deleteNodeRecursively(zkw, zkw.getZNodePaths().baseZNode);
  17.  zkw.close();
  18. }

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

  1. ZKUtil.deleteNodeRecursively(watcher, controller.getZkController().getBaseZnode());
  2. assertEquals("Didn't delete prepare node", -1, ZKUtil.checkExists(watcher, prepare));
  3. assertEquals("Didn't delete commit node", -1, ZKUtil.checkExists(watcher, commit));

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

  1. /**
  2.  * Create a bunch of znodes in a hierarchy, try deleting one that has childs (it will fail), then
  3.  * delete it recursively, then delete the last znode
  4.  */
  5. @Test
  6. public void testZNodeDeletes() throws Exception {
  7.  ZKUtil.createWithParents(ZKW, "/l1/l2/l3/l4");
  8.  try {
  9.   ZKUtil.deleteNode(ZKW, "/l1/l2");
  10.   fail("We should not be able to delete if znode has childs");
  11.  } catch (KeeperException ex) {
  12.   assertNotNull(ZKUtil.getDataNoWatch(ZKW, "/l1/l2/l3/l4", null));
  13.  }
  14.  ZKUtil.deleteNodeRecursively(ZKW, "/l1/l2");
  15.  // make sure it really is deleted
  16.  assertNull(ZKUtil.getDataNoWatch(ZKW, "/l1/l2/l3/l4", null));
  17.  // do the same delete again and make sure it doesn't crash
  18.  ZKUtil.deleteNodeRecursively(ZKW, "/l1/l2");
  19.  ZKUtil.deleteNode(ZKW, "/l1");
  20.  assertNull(ZKUtil.getDataNoWatch(ZKW, "/l1/l2", null));
  21. }

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

  1. @After
  2. public void after() throws Exception {
  3.  try {
  4.   TEST_UTIL.getHBaseCluster().waitForActiveAndReadyMaster(10000);
  5.   // Some regionserver could fail to delete its znode.
  6.   // So shutdown could hang. Let's kill them all instead.
  7.   TEST_UTIL.getHBaseCluster().killAll();
  8.   // Still need to clean things up
  9.   TEST_UTIL.shutdownMiniHBaseCluster();
  10.  } finally {
  11.   TEST_UTIL.getTestFileSystem().delete(FSUtils.getRootDir(TEST_UTIL.getConfiguration()), true);
  12.   ZKUtil.deleteNodeRecursively(TEST_UTIL.getZooKeeperWatcher(), "/hbase");
  13.  }
  14. }

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

  1. public void clearZNodes(String procedureName) throws KeeperException {
  2.   // TODO This is potentially racy since not atomic. update when we support zk that has multi
  3.   LOG.info("Clearing all znodes for procedure " + procedureName + "including nodes "
  4.     + acquiredZnode + " " + reachedZnode + " " + abortZnode);
  5.   ZKUtil.deleteNodeRecursively(watcher, getAcquiredBarrierNode(procedureName));
  6.   ZKUtil.deleteNodeRecursively(watcher, getReachedBarrierNode(procedureName));
  7.   ZKUtil.deleteNodeRecursively(watcher, getAbortZNode(procedureName));
  8.  }
  9. }

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

  1. @Override
  2. public void removeQueue(ServerName serverName, String queueId) throws ReplicationException {
  3.  try {
  4.   ZKUtil.deleteNodeRecursively(zookeeper, getQueueNode(serverName, queueId));
  5.  } catch (KeeperException e) {
  6.   throw new ReplicationException(
  7.     "Failed to delete queue (serverName=" + serverName + ", queueId=" + queueId + ")", e);
  8.  }
  9. }

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

  1. @Override
  2. public void removePeer(String peerId) throws ReplicationException {
  3.  try {
  4.   ZKUtil.deleteNodeRecursively(zookeeper, getPeerNode(peerId));
  5.  } catch (KeeperException e) {
  6.   throw new ReplicationException("Could not remove peer with id=" + peerId, e);
  7.  }
  8. }

代码示例来源：origin: XiaoMi/themis

  1. @After
  2. public void tearUp() throws IOException {
  3.  try {
  4.   ZKUtil.deleteNodeRecursively(zkw, ZookeeperWorkerRegister.THEMIS_ROOT_NODE);
  5.  } catch (Exception e) {
  6.   throw new IOException(e);
  7.  }
  8.  zkw.close();
  9.  super.tearUp();
  10. }

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

  1. /**
  2.  * Verifies that for the given root node, it should delete all the nodes recursively using
  3.  * multi-update api.
  4.  */
  5. @Test
  6. public void testDeleteNodeRecursivelyMulti() throws Exception {
  7.  String parentZNode = "/testdeleteNodeRecursivelyMulti";
  8.  createZNodeTree(parentZNode);
  9.  ZKUtil.deleteNodeRecursively(zkw, parentZNode);
  10.  assertTrue("Parent znode should be deleted.", ZKUtil.checkExists(zkw, parentZNode) == -1);
  11. }

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

  1. /**
  2.  * Verifies that for the given root node, it should delete all the nodes recursively using
  3.  * multi-update api.
  4.  */
  5. @Test
  6. public void testDeleteNodeRecursivelyMulti() throws Exception {
  7.  String parentZNode = "/testdeleteNodeRecursivelyMulti";
  8.  createZNodeTree(parentZNode);
  9.  ZKUtil.deleteNodeRecursively(zkw, parentZNode);
  10.  assertTrue("Parent znode should be deleted.", ZKUtil.checkExists(zkw, parentZNode) == -1);
  11. }

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

  1. @After
  2. public void after() throws Exception {
  3.  TEST_UTIL.shutdownMiniHBaseCluster();
  4.  TEST_UTIL.getTestFileSystem().delete(FSUtils.getRootDir(TEST_UTIL.getConfiguration()), true);
  5.  ZKUtil.deleteNodeRecursively(TEST_UTIL.getZooKeeperWatcher(), "/hbase");
  6. }

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

ZKUtil

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    ZKUtil类方法

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