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

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

本文整理了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

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

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

@Override
public void removeQueue(ServerName serverName, String queueId) throws ReplicationException {
 try {
  ZKUtil.deleteNodeRecursively(zookeeper, getQueueNode(serverName, queueId));
 } catch (KeeperException e) {
  throw new ReplicationException(
    "Failed to delete queue (serverName=" + serverName + ", queueId=" + queueId + ")", e);
 }
}

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

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

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

@Override
public void removePeerFromHFileRefs(String peerId) throws ReplicationException {
 String peerNode = getHFileRefsPeerNode(peerId);
 try {
  if (ZKUtil.checkExists(zookeeper, peerNode) == -1) {
    LOG.debug("Peer {} not found in hfile reference queue.", peerNode);
  } else {
   LOG.info("Removing peer {} from hfile reference queue.", peerNode);
   ZKUtil.deleteNodeRecursively(zookeeper, peerNode);
  }
 } catch (KeeperException e) {
  throw new ReplicationException(
    "Failed to remove peer " + peerId + " from hfile reference queue.", e);
 }
}

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

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

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

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

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

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

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

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

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

/**
 * Create a znode with data
 */
@Test
public void testCreateWithParents() throws KeeperException, InterruptedException {
 byte[] expectedData = new byte[] { 1, 2, 3 };
 ZKUtil.createWithParents(ZKW, "/l1/l2/l3/l4/testCreateWithParents", expectedData);
 byte[] data = ZKUtil.getData(ZKW, "/l1/l2/l3/l4/testCreateWithParents");
 assertTrue(Bytes.equals(expectedData, data));
 ZKUtil.deleteNodeRecursively(ZKW, "/l1");
 ZKUtil.createWithParents(ZKW, "/testCreateWithParents", expectedData);
 data = ZKUtil.getData(ZKW, "/testCreateWithParents");
 assertTrue(Bytes.equals(expectedData, data));
 ZKUtil.deleteNodeRecursively(ZKW, "/testCreateWithParents");
}

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

@After
public void tearDown()
throws KeeperException, ZooKeeperConnectionException, IOException {
 // Make sure zk is clean before we run the next test.
 ZKWatcher zkw = new ZKWatcher(TESTUTIL.getConfiguration(),
   "@Before", new Abortable() {
  @Override
  public void abort(String why, Throwable e) {
   throw new RuntimeException(why, e);
  }
  @Override
  public boolean isAborted() {
   return false;
  }
 });
 ZKUtil.deleteNodeRecursively(zkw, zkw.getZNodePaths().baseZNode);
 zkw.close();
}

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

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

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

/**
 * Create a bunch of znodes in a hierarchy, try deleting one that has childs (it will fail), then
 * delete it recursively, then delete the last znode
 */
@Test
public void testZNodeDeletes() throws Exception {
 ZKUtil.createWithParents(ZKW, "/l1/l2/l3/l4");
 try {
  ZKUtil.deleteNode(ZKW, "/l1/l2");
  fail("We should not be able to delete if znode has childs");
 } catch (KeeperException ex) {
  assertNotNull(ZKUtil.getDataNoWatch(ZKW, "/l1/l2/l3/l4", null));
 }
 ZKUtil.deleteNodeRecursively(ZKW, "/l1/l2");
 // make sure it really is deleted
 assertNull(ZKUtil.getDataNoWatch(ZKW, "/l1/l2/l3/l4", null));
 // do the same delete again and make sure it doesn't crash
 ZKUtil.deleteNodeRecursively(ZKW, "/l1/l2");
 ZKUtil.deleteNode(ZKW, "/l1");
 assertNull(ZKUtil.getDataNoWatch(ZKW, "/l1/l2", null));
}

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

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

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

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

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

@Override
public void removeQueue(ServerName serverName, String queueId) throws ReplicationException {
 try {
  ZKUtil.deleteNodeRecursively(zookeeper, getQueueNode(serverName, queueId));
 } catch (KeeperException e) {
  throw new ReplicationException(
    "Failed to delete queue (serverName=" + serverName + ", queueId=" + queueId + ")", e);
 }
}

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

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

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

@After
public void tearUp() throws IOException {
 try {
  ZKUtil.deleteNodeRecursively(zkw, ZookeeperWorkerRegister.THEMIS_ROOT_NODE);
 } catch (Exception e) {
  throw new IOException(e);
 }
 zkw.close();
 super.tearUp();
}

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

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

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

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

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

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

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

ZKUtil

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    ZKUtil类方法

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