- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperItf.delete()
方法的一些代码示例,展示了ZooKeeperItf.delete()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperItf.delete()
方法的具体详情如下:
包路径:com.ngdata.sep.util.zookeeper.ZooKeeperItf
类名称:ZooKeeperItf
方法名:delete
暂无
代码示例来源:origin: com.ngdata/hbase-indexer-common
@Override
public Object execute() throws KeeperException, InterruptedException {
zk.delete(lockId, -1);
return null;
}
});
代码示例来源:origin: NGDATA/hbase-indexer
@Override
public Integer execute() throws KeeperException, InterruptedException {
zk.delete(indexerProcessId, -1);
return 0;
}
});
代码示例来源:origin: NGDATA/hbase-indexer
@Override
public Object execute() throws KeeperException, InterruptedException {
zk.delete(lockId, -1);
return null;
}
});
代码示例来源:origin: NGDATA/hbase-indexer
@Override
public Object execute() throws KeeperException, InterruptedException {
try {
zk.delete(childPath, -1);
} catch (KeeperException.NoNodeException e) {
// ignore
}
return null;
}
});
代码示例来源:origin: com.ngdata/hbase-indexer-model
@Override
public Integer execute() throws KeeperException, InterruptedException {
zk.delete(indexerProcessId, -1);
return 0;
}
});
代码示例来源:origin: com.ngdata/hbase-indexer-common
@Override
public Object execute() throws KeeperException, InterruptedException {
try {
zk.delete(childPath, -1);
} catch (KeeperException.NoNodeException e) {
// ignore
}
return null;
}
});
代码示例来源:origin: NGDATA/hbase-indexer
zk.delete(indexerLockPath + "/" + child, -1);
} catch (KeeperException.NoNodeException e) {
zk.delete(indexerLockPath, -1);
} catch (KeeperException.NoNodeException e) {
zk.delete(indexerPath, -1);
代码示例来源:origin: com.ngdata/hbase-indexer-model
zk.delete(indexerLockPath + "/" + child, -1);
} catch (KeeperException.NoNodeException e) {
zk.delete(indexerLockPath, -1);
} catch (KeeperException.NoNodeException e) {
zk.delete(indexerPath, -1);
代码示例来源:origin: NGDATA/hbase-indexer
@Override
public Boolean execute() throws KeeperException, InterruptedException {
Stat stat = zk.exists(path, false);
if (stat != null) {
try {
zk.delete(path, stat.getVersion());
} catch (KeeperException.NoNodeException nne) {
// This is ok, the node is already gone
}
// We don't catch BadVersion or NotEmpty as these are probably signs that there is something
// unexpected going on with the node that is to be deleted
}
return true;
}
});
代码示例来源:origin: com.ngdata/hbase-sep-impl
public void stop() {
Closer.close(zkWatcher);
if (running) {
running = false;
Closer.close(rpcServer);
try {
// This ZK node will likely already be gone if the index has been removed
// from ZK, but we'll try to remove it here to be sure
zk.delete(zkNodePath, -1);
} catch (Exception e) {
log.debug("Exception while removing zookeeper node", e);
if (e instanceof InterruptedException) {
Thread.currentThread().interrupt();
}
}
}
sepMetrics.shutdown();
for (ThreadPoolExecutor executor : executors) {
executor.shutdown();
}
}
代码示例来源:origin: com.ngdata/hbase-sep-impl-common
@Override
public Boolean execute() throws KeeperException, InterruptedException {
Stat stat = zk.exists(path, false);
if (stat != null) {
try {
zk.delete(path, stat.getVersion());
} catch (KeeperException.NoNodeException nne) {
// This is ok, the node is already gone
}
// We don't catch BadVersion or NotEmpty as these are probably signs that there is something
// unexpected going on with the node that is to be deleted
}
return true;
}
});
代码示例来源:origin: NGDATA/hbase-indexer
public void stop() {
Closer.close(zkWatcher);
if (running) {
running = false;
Closer.close(rpcServer);
try {
// This ZK node will likely already be gone if the index has been removed
// from ZK, but we'll try to remove it here to be sure
zk.delete(zkNodePath, -1);
} catch (Exception e) {
log.debug("Exception while removing zookeeper node", e);
if (e instanceof InterruptedException) {
Thread.currentThread().interrupt();
}
}
}
sepMetrics.shutdown();
for (ThreadPoolExecutor executor : executors) {
executor.shutdown();
}
}
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.delete()方法的一些代码示例,展示了ZooKeeperItf.delete()的具体用
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.getSessionPasswd()方法的一些代码示例,展示了ZooKeeperItf.ge
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.close()方法的一些代码示例,展示了ZooKeeperItf.close()的具体用法。
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.getSessionId()方法的一些代码示例,展示了ZooKeeperItf.getSes
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.isCurrentThreadEventThread()方法的一些代码示例,展示了ZooKe
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.addDefaultWatcher()方法的一些代码示例,展示了ZooKeeperItf.a
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.setData()方法的一些代码示例,展示了ZooKeeperItf.setData()的具
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.removeDefaultWatcher()方法的一些代码示例,展示了ZooKeeperIt
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.create()方法的一些代码示例,展示了ZooKeeperItf.create()的具体用
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.exists()方法的一些代码示例,展示了ZooKeeperItf.exists()的具体用
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.getChildren()方法的一些代码示例,展示了ZooKeeperItf.getChil
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.getData()方法的一些代码示例,展示了ZooKeeperItf.getData()的具
本文整理了Java中org.lilyproject.util.zookeeper.ZooKeeperItf.retryOperation()方法的一些代码示例,展示了ZooKeeperItf.retr
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperItf.addDefaultWatcher()方法的一些代码示例,展示了ZooKeeperItf.ad
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperItf.removeDefaultWatcher()方法的一些代码示例,展示了ZooKeeperItf
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperItf.getData()方法的一些代码示例,展示了ZooKeeperItf.getData()的具体
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperItf.create()方法的一些代码示例,展示了ZooKeeperItf.create()的具体用法
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperItf.exists()方法的一些代码示例,展示了ZooKeeperItf.exists()的具体用法
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperItf.retryOperation()方法的一些代码示例,展示了ZooKeeperItf.retry
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperItf.setData()方法的一些代码示例,展示了ZooKeeperItf.setData()的具体
我是一名优秀的程序员,十分优秀!