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

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

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

ZKUtil.deleteChildrenRecursively介绍

[英]Delete all the children of the specified node but not the node itself. Sets no watches. Throws all exceptions besides dealing with deletion of children.
[中]删除指定节点的所有子节点，但不删除节点本身。没有手表。抛出除处理删除子项之外的所有异常。

代码示例

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

@Before
public void setup() throws Exception {
 TEST_UTIL = new HBaseTestingUtility();
 TEST_UTIL.startMiniZKCluster();
 conf = TEST_UTIL.getConfiguration();
 // Use a different ZK wrapper instance for each tests.
 zkw =
   new ZKWatcher(conf, "split-log-manager-tests" + TEST_UTIL.getRandomUUID().toString(), null);
 master = new DummyMasterServices(zkw, conf);
 ZKUtil.deleteChildrenRecursively(zkw, zkw.getZNodePaths().baseZNode);
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().baseZNode);
 assertTrue(ZKUtil.checkExists(zkw, zkw.getZNodePaths().baseZNode) != -1);
 LOG.debug(zkw.getZNodePaths().baseZNode + " created");
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().splitLogZNode);
 assertTrue(ZKUtil.checkExists(zkw, zkw.getZNodePaths().splitLogZNode) != -1);
 LOG.debug(zkw.getZNodePaths().splitLogZNode + " created");
 resetCounters();
 // By default, we let the test manage the error as before, so the server
 // does not appear as dead from the master point of view, only from the split log pov.
 Mockito.when(sm.isServerOnline(Mockito.any())).thenReturn(true);
 to = 12000;
 conf.setInt(HConstants.HBASE_SPLITLOG_MANAGER_TIMEOUT, to);
 conf.setInt("hbase.splitlog.manager.unassigned.timeout", 2 * to);
 conf.setInt("hbase.splitlog.manager.timeoutmonitor.period", 100);
 to = to + 16 * 100;
}

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

@Before
public void setup() throws Exception {
 TEST_UTIL.startMiniZKCluster();
 Configuration conf = TEST_UTIL.getConfiguration();
 zkw = new ZKWatcher(TEST_UTIL.getConfiguration(),
   "split-log-worker-tests", null);
 ds = new DummyServer(zkw, conf);
 ZKUtil.deleteChildrenRecursively(zkw, zkw.getZNodePaths().baseZNode);
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().baseZNode);
 assertThat(ZKUtil.checkExists(zkw, zkw.getZNodePaths().baseZNode), not(is(-1)));
 LOG.debug(zkw.getZNodePaths().baseZNode + " created");
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().splitLogZNode);
 assertThat(ZKUtil.checkExists(zkw, zkw.getZNodePaths().splitLogZNode), not(is(-1)));
 LOG.debug(zkw.getZNodePaths().splitLogZNode + " created");
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().rsZNode);
 assertThat(ZKUtil.checkExists(zkw, zkw.getZNodePaths().rsZNode), not(is(-1)));
 SplitLogCounters.resetCounters();
 executorService = new ExecutorService("TestSplitLogWorker");
 executorService.startExecutorService(ExecutorType.RS_LOG_REPLAY_OPS, 10);
}

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

@Test
 public void testRefreshKeys() throws Exception {
  Configuration conf = TEST_UTIL.getConfiguration();
  ZKWatcher zk = newZK(conf, "127.0.0.1", new MockAbortable());
  AuthenticationTokenSecretManager keyManager =
    new AuthenticationTokenSecretManager(conf, zk, "127.0.0.1",
      60 * 60 * 1000, 60 * 1000);
  ZKSecretWatcher watcher = new ZKSecretWatcher(conf, zk, keyManager);
  ZKUtil.deleteChildrenRecursively(zk, watcher.getKeysParentZNode());
  Integer[] keys = { 1, 2, 3, 4, 5, 6 };
  for (Integer key : keys) {
   AuthenticationKey ak = new AuthenticationKey(key,
     System.currentTimeMillis() + 600 * 1000, null);
   ZKUtil.createWithParents(zk,
     ZNodePaths.joinZNode(watcher.getKeysParentZNode(), key.toString()),
     Writables.getBytes(ak));
  }
  Assert.assertNull(keyManager.getCurrentKey());
  watcher.refreshKeys();
  for (Integer key : keys) {
   Assert.assertNotNull(keyManager.getKey(key.intValue()));
  }
 }
}

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

public void clearChildZNodes() throws KeeperException {
 // TODO This is potentially racy since not atomic. update when we support zk that has multi
 LOG.info("Clearing all procedure znodes: " + acquiredZnode + " " + reachedZnode + " "
   + abortZnode);
 // If the coordinator was shutdown mid-procedure, then we are going to lose
 // an procedure that was previously started by cleaning out all the previous state. Its much
 // harder to figure out how to keep an procedure going and the subject of HBASE-5487.
 ZKUtil.deleteChildrenRecursively(watcher, acquiredZnode);
 ZKUtil.deleteChildrenRecursively(watcher, reachedZnode);
 ZKUtil.deleteChildrenRecursively(watcher, abortZnode);
}

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

/**
 * Deletes all unassigned nodes regardless of their state.
 *
 * <p>No watchers are set.
 *
 * <p>This method is used by the Master during cluster startup to clear out
 * any existing state from other cluster runs.
 *
 * @param zkw zk reference
 * @throws KeeperException if unexpected zookeeper exception
 */
public static void deleteAllNodes(ZooKeeperWatcher zkw)
throws KeeperException {
 LOG.debug(zkw.prefix("Deleting any existing unassigned nodes"));
 ZKUtil.deleteChildrenRecursively(zkw, zkw.assignmentZNode);
}

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

/**
 * Deletes all unassigned nodes regardless of their state.
 *
 * <p>No watchers are set.
 *
 * <p>This method is used by the Master during cluster startup to clear out
 * any existing state from other cluster runs.
 *
 * @param zkw zk reference
 * @throws KeeperException if unexpected zookeeper exception
 */
public static void deleteAllNodes(ZooKeeperWatcher zkw)
throws KeeperException {
 LOG.debug(zkw.prefix("Deleting any existing unassigned nodes"));
 ZKUtil.deleteChildrenRecursively(zkw, zkw.assignmentZNode);
}

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

public static void deleteRecoveringRegionZNodes(ZooKeeperWatcher watcher, List<String> regions) {
 try {
  if (regions == null) {
   // remove all children under /home/recovering-regions
   LOG.debug("Garbage collecting all recovering region znodes");
   ZKUtil.deleteChildrenRecursively(watcher, watcher.recoveringRegionsZNode);
  } else {
   for (String curRegion : regions) {
    String nodePath = ZKUtil.joinZNode(watcher.recoveringRegionsZNode, curRegion);
    ZKUtil.deleteNodeRecursively(watcher, nodePath);
   }
  }
 } catch (KeeperException e) {
  LOG.warn("Cannot remove recovering regions from ZooKeeper", e);
 }
}

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

@Before
public void setup() throws Exception {
 TEST_UTIL = new HBaseTestingUtility();
 TEST_UTIL.startMiniZKCluster();
 conf = TEST_UTIL.getConfiguration();
 // Use a different ZK wrapper instance for each tests.
 zkw =
   new ZKWatcher(conf, "split-log-manager-tests" + TEST_UTIL.getRandomUUID().toString(), null);
 master = new DummyMasterServices(zkw, conf);
 ZKUtil.deleteChildrenRecursively(zkw, zkw.getZNodePaths().baseZNode);
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().baseZNode);
 assertTrue(ZKUtil.checkExists(zkw, zkw.getZNodePaths().baseZNode) != -1);
 LOG.debug(zkw.getZNodePaths().baseZNode + " created");
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().splitLogZNode);
 assertTrue(ZKUtil.checkExists(zkw, zkw.getZNodePaths().splitLogZNode) != -1);
 LOG.debug(zkw.getZNodePaths().splitLogZNode + " created");
 resetCounters();
 // By default, we let the test manage the error as before, so the server
 // does not appear as dead from the master point of view, only from the split log pov.
 Mockito.when(sm.isServerOnline(Mockito.any())).thenReturn(true);
 to = 12000;
 conf.setInt(HConstants.HBASE_SPLITLOG_MANAGER_TIMEOUT, to);
 conf.setInt("hbase.splitlog.manager.unassigned.timeout", 2 * to);
 conf.setInt("hbase.splitlog.manager.timeoutmonitor.period", 100);
 to = to + 16 * 100;
}

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

@Before
public void setup() throws Exception {
 TEST_UTIL.startMiniZKCluster();
 Configuration conf = TEST_UTIL.getConfiguration();
 zkw = new ZKWatcher(TEST_UTIL.getConfiguration(),
   "split-log-worker-tests", null);
 ds = new DummyServer(zkw, conf);
 ZKUtil.deleteChildrenRecursively(zkw, zkw.getZNodePaths().baseZNode);
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().baseZNode);
 assertThat(ZKUtil.checkExists(zkw, zkw.getZNodePaths().baseZNode), not(is(-1)));
 LOG.debug(zkw.getZNodePaths().baseZNode + " created");
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().splitLogZNode);
 assertThat(ZKUtil.checkExists(zkw, zkw.getZNodePaths().splitLogZNode), not(is(-1)));
 LOG.debug(zkw.getZNodePaths().splitLogZNode + " created");
 ZKUtil.createAndFailSilent(zkw, zkw.getZNodePaths().rsZNode);
 assertThat(ZKUtil.checkExists(zkw, zkw.getZNodePaths().rsZNode), not(is(-1)));
 SplitLogCounters.resetCounters();
 executorService = new ExecutorService("TestSplitLogWorker");
 executorService.startExecutorService(ExecutorType.RS_LOG_REPLAY_OPS, 10);
}

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

@Test
 public void testRefreshKeys() throws Exception {
  Configuration conf = TEST_UTIL.getConfiguration();
  ZKWatcher zk = newZK(conf, "127.0.0.1", new MockAbortable());
  AuthenticationTokenSecretManager keyManager =
    new AuthenticationTokenSecretManager(conf, zk, "127.0.0.1",
      60 * 60 * 1000, 60 * 1000);
  ZKSecretWatcher watcher = new ZKSecretWatcher(conf, zk, keyManager);
  ZKUtil.deleteChildrenRecursively(zk, watcher.getKeysParentZNode());
  Integer[] keys = { 1, 2, 3, 4, 5, 6 };
  for (Integer key : keys) {
   AuthenticationKey ak = new AuthenticationKey(key,
     System.currentTimeMillis() + 600 * 1000, null);
   ZKUtil.createWithParents(zk,
     ZNodePaths.joinZNode(watcher.getKeysParentZNode(), key.toString()),
     Writables.getBytes(ak));
  }
  Assert.assertNull(keyManager.getCurrentKey());
  watcher.refreshKeys();
  for (Integer key : keys) {
   Assert.assertNotNull(keyManager.getKey(key.intValue()));
  }
 }
}

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

ZKUtil

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    ZKUtil类方法

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