- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.zookeeper.ZooKeeper.delete()
方法的一些代码示例,展示了ZooKeeper.delete()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeper.delete()
方法的具体详情如下:
包路径:org.apache.zookeeper.ZooKeeper
类名称:ZooKeeper
方法名:delete
[英]Delete the node with the given path. The call will succeed if such a node exists, and the given version matches the node's version (if the given version is -1, it matches any node's versions).
A KeeperException with error code KeeperException.NoNode will be thrown if the nodes does not exist.
A KeeperException with error code KeeperException.BadVersion will be thrown if the given version does not match the node's version.
A KeeperException with error code KeeperException.NotEmpty will be thrown if the node has children.
This operation, if successful, will trigger all the watches on the node of the given path left by exists API calls, and the watches on the parent node left by getChildren API calls.
[中]删除具有给定路径的节点。如果存在这样一个节点,并且给定的版本与该节点的版本匹配(如果给定的版本为-1,则与任何节点的版本匹配),则调用将成功。
错误代码为KeeperException的KeeperException。如果节点不存在,将抛出NoNode。
错误代码为KeeperException的KeeperException。如果给定的版本与节点的版本不匹配,将抛出BadVersion。
错误代码为KeeperException的KeeperException。如果节点有子节点,将抛出NotEmpty。
如果此操作成功,将触发exists API调用留下的给定路径节点上的所有监视,以及getChildren API调用留下的父节点上的监视。
代码示例来源:origin: apache/zookeeper
public boolean execute() throws KeeperException,
InterruptedException {
zookeeper.delete(id, -1);
return Boolean.TRUE;
}
};
代码示例来源:origin: knightliao/disconf
public boolean execute() throws KeeperException, InterruptedException {
zookeeper.delete(id, -1);
return Boolean.TRUE;
}
};
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@Override public void execute() {
zk.delete(path, -1, this, null);
}
代码示例来源:origin: apache/zookeeper
@Override
public void nodeSerialized(String path) {
try {
zkClient.delete(child, -1);
LOG.info("Deleted the child node after the parent is serialized");
} catch (Exception e) {
LOG.error("Error when deleting node {}", e);
}
}
});
代码示例来源:origin: yu199195/hmily
@Override
public int remove(final String id) {
try {
zooKeeper.delete(buildRootPath(id), -1);
return ROWS;
} catch (Exception e) {
throw new HmilyRuntimeException(e);
}
}
代码示例来源:origin: apache/hbase
private void deleteNode(String path, Long retries) {
SplitLogCounters.tot_mgr_node_delete_queued.increment();
// Once a task znode is ready for delete, that is it is in the TASK_DONE
// state, then no one should be writing to it anymore. That is no one
// will be updating the znode version any more.
this.watcher.getRecoverableZooKeeper().getZooKeeper()
.delete(path, -1, new DeleteAsyncCallback(), retries);
}
代码示例来源:origin: apache/zookeeper
public void delete() {
zk.delete(path, version, this, toString());
}
代码示例来源:origin: apache/zookeeper
@Test
public void testDeleteWithChildren() throws Exception {
ZooKeeper zk = createClient();
zk.create("/parent", new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
zk.create("/parent/child", new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
try {
zk.delete("/parent", -1);
Assert.fail("Should have received a not equals message");
} catch (KeeperException e) {
Assert.assertEquals(KeeperException.Code.NOTEMPTY, e.code());
}
zk.delete("/parent/child", -1);
zk.delete("/parent", -1);
zk.close();
}
代码示例来源:origin: apache/zookeeper
@Test
public void testSuperIsSuper() throws Exception {
ZooKeeper zk = createClient();
try {
zk.create("/digest_read", null, Arrays.asList(new ACL(Perms.READ, otherDigestUser)), CreateMode.PERSISTENT);
zk.create("/digest_read/sub", null, Arrays.asList(new ACL(Perms.READ, otherDigestUser)), CreateMode.PERSISTENT);
zk.create("/sasl_read", null, Arrays.asList(new ACL(Perms.READ, otherSaslUser)), CreateMode.PERSISTENT);
zk.create("/sasl_read/sub", null, Arrays.asList(new ACL(Perms.READ, otherSaslUser)), CreateMode.PERSISTENT);
zk.delete("/digest_read/sub", -1);
zk.delete("/digest_read", -1);
zk.delete("/sasl_read/sub", -1);
zk.delete("/sasl_read", -1);
//If the test failes it will most likely fail with a NoAuth exception before it ever gets to this assertion
Assert.assertEquals(authFailed.get(), 0);
} finally {
zk.close();
}
}
}
代码示例来源:origin: apache/zookeeper
public void verifyDeleteFailure_NoNode() {
rc = Code.NONODE;
zk.delete(path, version, this, toString());
verify();
}
代码示例来源:origin: apache/pulsar
@Override
public void removeManagedLedger(String ledgerName, MetaStoreCallback<Void> callback) {
log.info("[{}] Remove ManagedLedger", ledgerName);
zk.delete(prefix + ledgerName, -1, (rc, path, ctx) -> executor.executeOrdered(ledgerName, safeRun(() -> {
if (log.isDebugEnabled()) {
log.debug("[{}] zk delete done. rc={}", ledgerName, Code.get(rc));
}
if (rc == Code.OK.intValue()) {
callback.operationComplete(null, null);
} else {
callback.operationFailed(new MetaStoreException(KeeperException.create(Code.get(rc))));
}
})), null);
}
代码示例来源:origin: changmingxie/tcc-transaction
@Override
protected int doDelete(Transaction transaction) {
try {
getZk().delete(getTxidPath(transaction.getXid()), (int) transaction.getVersion() - 1);
return 1;
} catch (Exception e) {
throw new TransactionIOException(e);
}
}
代码示例来源:origin: twitter/distributedlog
private void deleteLog(String logName) throws Exception {
Optional<URI> logUriOptional = FutureUtils.result(metadataStore.getLogLocation(logName));
assertTrue(logUriOptional.isPresent());
URI logUri = logUriOptional.get();
zkc.get().delete(logUri.getPath() + "/" + logName, -1);
}
代码示例来源:origin: twitter/distributedlog
private void rmAll(ZooKeeperClient client, String path) throws Exception {
List<String> nodes = client.get().getChildren(path, false);
for (String node : nodes) {
String childPath = path + "/" + node;
rmAll(client, childPath);
}
client.get().delete(path, 0);
}
代码示例来源:origin: apache/zookeeper
@Test(timeout = 30000)
public void testSimpleDeletion()
throws KeeperException, InterruptedException {
zk.create("/foo", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.CONTAINER);
zk.create("/foo/bar", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
zk.delete("/foo/bar", -1); // should cause "/foo" to get deleted when checkContainers() is called
ContainerManager containerManager = new ContainerManager(serverFactory.getZooKeeperServer()
.getZKDatabase(), serverFactory.getZooKeeperServer().firstProcessor, 1, 100);
containerManager.checkContainers();
Thread.sleep(1000);
Assert.assertNull("Container should have been deleted", zk.exists("/foo", false));
}
代码示例来源:origin: apache/zookeeper
private void deleteNodeIfExists(ZooKeeper zk, String nodeName)
throws InterruptedException {
try {
zk.delete(nodeName, -1);
} catch (KeeperException ke) {
Code code = ke.code();
boolean valid = code == KeeperException.Code.NONODE ||
code == KeeperException.Code.NOTEMPTY;
if (!valid) {
Assert.fail("Unexpected exception code for delete: " + ke.getMessage());
}
}
}
代码示例来源:origin: apache/zookeeper
@Test(timeout = 30000)
public void testCascadingDeletion()
throws KeeperException, InterruptedException {
zk.create("/foo", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.CONTAINER);
zk.create("/foo/bar", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.CONTAINER);
zk.create("/foo/bar/one", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
zk.delete("/foo/bar/one", -1); // should cause "/foo/bar" and "/foo" to get deleted when checkContainers() is called
ContainerManager containerManager = new ContainerManager(serverFactory.getZooKeeperServer()
.getZKDatabase(), serverFactory.getZooKeeperServer().firstProcessor, 1, 100);
containerManager.checkContainers();
Thread.sleep(1000);
containerManager
.checkContainers();
Thread.sleep(1000);
Assert.assertNull("Container should have been deleted", zk.exists("/foo/bar", false));
Assert.assertNull("Container should have been deleted", zk.exists("/foo", false));
}
代码示例来源:origin: apache/zookeeper
/**
* Developers might use standalone mode (which is the default for one server).
* This test checks SSL works in standalone mode of ZK server.
* <p/>
* Note that in this test the Zk server has only secureClientPort
*/
@Test
public void testSecureStandaloneServer() throws Exception {
Integer secureClientPort = PortAssignment.unique();
MainThread mt = new MainThread(MainThread.UNSET_MYID, "", secureClientPort, false);
mt.start();
ZooKeeper zk = ClientBase.createZKClient("127.0.0.1:" + secureClientPort, TIMEOUT);
zk.create("/test", "".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
zk.delete("/test", -1);
zk.close();
mt.shutdown();
}
}
代码示例来源:origin: apache/zookeeper
public void verifyDeleteFailure_BadVersion() {
new StringCB(zk).verifyCreate();
rc = Code.BADVERSION;
zk.delete(path, version + 1, this, toString());
verify();
}
代码示例来源:origin: apache/zookeeper
public void verifyDeleteFailure_NotEmpty() {
StringCB scb = new StringCB(zk);
scb.create();
scb.setPath(path + "/bar");
scb.create();
rc = Code.NOTEMPTY;
zk.delete(path, version, this, toString());
verify();
}
我尝试理解[c代码 -> 汇编]代码 void node::Check( data & _data1, vector& _data2) { -> push ebp -> mov ebp,esp ->
我需要在当前表单(代码)的上下文中运行文本文件中的代码。其中一项要求是让代码创建新控件并将其添加到当前窗体。 例如,在Form1.cs中: using System.Windows.Forms; ..
我有此 C++ 代码并将其转换为 C# (.net Framework 4) 代码。有没有人给我一些关于 malloc、free 和 sprintf 方法的提示? int monate = ee; d
我的网络服务器代码有问题 #include #include #include #include #include #include #include int
给定以下 html 代码,将列表中的第三个元素(即“美丽”一词)以斜体显示的 CSS 代码是什么?当然,我可以给这个元素一个 id 或一个 class,但 html 代码必须保持不变。谢谢
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 我们不允许提问寻求书籍、工具、软件库等的推荐。您可以编辑问题,以便用事实和引用来回答。 关闭 7 年前。
我试图制作一个宏来避免重复代码和注释。 我试过这个: #define GrowOnPage(any Page, any Component) Component.Width := Page.Surfa
我正在尝试将我的旧 C++ 代码“翻译”成头条新闻所暗示的 C# 代码。问题是我是 C# 中的新手,并不是所有的东西都像 C++ 中那样。在 C++ 中这些解决方案运行良好,但在 C# 中只是不能。我
在 Windows 10 上工作,R 语言的格式化程序似乎没有在 Visual Studio Code 中完成它的工作。我试过R support for Visual Studio Code和 R-T
我正在处理一些报告(计数),我必须获取不同参数的计数。非常简单但乏味。 一个参数的示例查询: qCountsEmployee = ( "select count(*) from %s wher
最近几天我尝试从 d00m 调试网络错误。我开始用尽想法/线索,我希望其他 SO 用户拥有可能有用的宝贵经验。我希望能够提供所有相关信息,但我个人无法控制服务器环境。 整个事情始于用户注意到我们应用程
我有一个 app.js 文件,其中包含如下 dojo amd 模式代码: require(["dojo/dom", ..], function(dom){ dom.byId('someId').i
我对“-gencode”语句中的“code=sm_X”选项有点困惑。 一个例子:NVCC 编译器选项有什么作用 -gencode arch=compute_13,code=sm_13 嵌入库中? 只有
我为我的表格使用 X-editable 框架。 但是我有一些问题。 $(document).ready(function() { $('.access').editable({
我一直在通过本教程学习 flask/python http://blog.miguelgrinberg.com/post/the-flask-mega-tutorial-part-i-hello-wo
我想将 Vim 和 EMACS 用于 CNC、G 代码和 M 代码。 Vim 或 EMACS 是否有任何语法或模式来处理这种类型的代码? 最佳答案 一些快速搜索使我找到了 this vim 和 thi
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 想改进这个问题?更新问题,使其成为 on-topic对于堆栈溢出。 7年前关闭。 Improve this
这个问题在这里已经有了答案: Enabling markdown highlighting in Vim (5 个回答) 6年前关闭。 当我在 Vim 中编辑包含 Markdown 代码的 READM
我正在 Swift3 iOS 中开发视频应用程序。基本上我必须将视频 Assets 和音频与淡入淡出效果合并为一个并将其保存到 iPhone 画廊。为此,我使用以下方法: private func d
pipeline { agent any stages { stage('Build') { steps { e
我是一名优秀的程序员,十分优秀!