- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths.deleteChildren()
方法的一些代码示例,展示了ZKPaths.deleteChildren()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKPaths.deleteChildren()
方法的具体详情如下:
包路径:org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths
类名称:ZKPaths
方法名:deleteChildren
暂无
代码示例来源:origin: com.alibaba.blink/flink-runtime
@Override
public void shutdown(JobStatus jobStatus) throws Exception {
if (jobStatus.isGloballyTerminalState()) {
LOG.info("Shutting down");
for (CompletedCheckpoint checkpoint : completedCheckpoints) {
try {
removeShutdown(checkpoint, jobStatus);
} catch (Exception e) {
LOG.error("Failed to discard checkpoint.", e);
}
}
completedCheckpoints.clear();
String path = "/" + client.getNamespace();
LOG.info("Removing {} from ZooKeeper", path);
ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, true);
} else {
LOG.info("Suspending");
// Clear the local handles, but don't remove any state
completedCheckpoints.clear();
// Release the state handle locks in ZooKeeper such that they can be deleted
checkpointsInZooKeeper.releaseAll();
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
@Override
public void shutdown(JobStatus jobStatus) throws Exception {
if (jobStatus.isGloballyTerminalState()) {
LOG.info("Shutting down");
for (CompletedCheckpoint checkpoint : completedCheckpoints) {
tryRemoveCompletedCheckpoint(
checkpoint,
completedCheckpoint -> completedCheckpoint.discardOnShutdown(jobStatus));
}
completedCheckpoints.clear();
String path = "/" + client.getNamespace();
LOG.info("Removing {} from ZooKeeper", path);
ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, true);
} else {
LOG.info("Suspending");
// Clear the local handles, but don't remove any state
completedCheckpoints.clear();
// Release the state handle locks in ZooKeeper such that they can be deleted
checkpointsInZooKeeper.releaseAll();
}
}
代码示例来源:origin: org.apache.flink/flink-runtime
@Override
public void shutdown(JobStatus jobStatus) throws Exception {
if (jobStatus.isGloballyTerminalState()) {
LOG.info("Shutting down");
for (CompletedCheckpoint checkpoint : completedCheckpoints) {
tryRemoveCompletedCheckpoint(
checkpoint,
completedCheckpoint -> completedCheckpoint.discardOnShutdown(jobStatus));
}
completedCheckpoints.clear();
String path = "/" + client.getNamespace();
LOG.info("Removing {} from ZooKeeper", path);
ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, true);
} else {
LOG.info("Suspending");
// Clear the local handles, but don't remove any state
completedCheckpoints.clear();
// Release the state handle locks in ZooKeeper such that they can be deleted
checkpointsInZooKeeper.releaseAll();
}
}
本文整理了Java中io.fabric8.zookeeper.ZkPath.loadURL()方法的一些代码示例,展示了ZkPath.loadURL()的具体用法。这些代码示例主要来源于Github/
本文整理了Java中io.fabric8.zookeeper.ZkPath.getPath()方法的一些代码示例,展示了ZkPath.getPath()的具体用法。这些代码示例主要来源于Github/
本文整理了Java中org.apache.curator.utils.ZKPaths.makePath()方法的一些代码示例,展示了ZKPaths.makePath()的具体用法。这些代码示例主要来源
本文整理了Java中org.apache.curator.utils.ZKPaths.getNodeFromPath()方法的一些代码示例,展示了ZKPaths.getNodeFromPath()的具
本文整理了Java中org.apache.curator.utils.ZKPaths.fixForNamespace()方法的一些代码示例,展示了ZKPaths.fixForNamespace()的具
本文整理了Java中org.apache.curator.utils.ZKPaths.getPathAndNode()方法的一些代码示例,展示了ZKPaths.getPathAndNode()的具体用
本文整理了Java中org.apache.curator.utils.ZKPaths.deleteChildren()方法的一些代码示例,展示了ZKPaths.deleteChildren()的具体用
本文整理了Java中org.apache.curator.utils.ZKPaths.mkdirs()方法的一些代码示例,展示了ZKPaths.mkdirs()的具体用法。这些代码示例主要来源于Git
本文整理了Java中me.hao0.antares.common.util.ZkPaths.pathOfServer()方法的一些代码示例,展示了ZkPaths.pathOfServer()的具体用法
本文整理了Java中me.hao0.antares.common.util.ZkPaths.pathOfAppClients()方法的一些代码示例,展示了ZkPaths.pathOfAppClient
本文整理了Java中me.hao0.antares.common.util.ZkPaths.pathOfJobInstances()方法的一些代码示例,展示了ZkPaths.pathOfJobInst
本文整理了Java中me.hao0.antares.common.util.ZkPaths.pathOfJobInstance()方法的一些代码示例,展示了ZkPaths.pathOfJobInsta
本文整理了Java中me.hao0.antares.common.util.ZkPaths.lastNode()方法的一些代码示例,展示了ZkPaths.lastNode()的具体用法。这些代码示例主
本文整理了Java中com.netflix.curator.utils.ZKPaths.getNodeFromPath()方法的一些代码示例,展示了ZKPaths.getNodeFromPath()的
本文整理了Java中com.netflix.curator.utils.ZKPaths.makePath()方法的一些代码示例,展示了ZKPaths.makePath()的具体用法。这些代码示例主要来
本文整理了Java中com.netflix.curator.utils.ZKPaths.getPathAndNode()方法的一些代码示例,展示了ZKPaths.getPathAndNode()的具体
本文整理了Java中org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths.getNodeFromPath()方法的一些代码示
本文整理了Java中org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths.deleteChildren()方法的一些代码示例
我是一名优秀的程序员,十分优秀!