本文整理了Java中org.apache.helix.manager.zk.ZkClient.delete()
方法的一些代码示例,展示了ZkClient.delete()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkClient.delete()
方法的具体详情如下:
包路径:org.apache.helix.manager.zk.ZkClient
类名称:ZkClient
方法名:delete
暂无
代码示例来源:origin: org.apache.helix/helix-core
/**
* sync remove
*/
@Override
public boolean remove(String path, int options) {
try {
// optimize on common path
return _zkClient.delete(path);
} catch (ZkException e) {
LOG.warn(String.format("Caught exception when deleting %s with options %s.", path, options),
e);
return _zkClient.deleteRecursive(path);
}
}
代码示例来源:origin: org.apache.helix/helix-core
zkClient.delete("/" + clusterName + "/CONFIGS/CLUSTER/verify");
代码示例来源:origin: apache/helix
_zkClient.delete(TEST_PATH);
_zkClient.delete(TEST_PATH);
Assert.assertTrue(callbackFinish.await(10, TimeUnit.SECONDS));
Assert.assertEquals((long) beanServer.getAttribute(name, "DataChangeEventCounter"), 1);
代码示例来源:origin: org.apache.helix/helix-core
zkClient.delete(path);
} else {
try {
代码示例来源:origin: apache/helix
client.delete(path);
代码示例来源:origin: org.apache.helix/helix-core
public void post(String zkServer, Message message, String clusterName, String instanceName) {
ZkClient client = new ZkClient(zkServer);
client.setZkSerializer(new ZNRecordSerializer());
String path = PropertyPathBuilder.instanceMessage(clusterName, instanceName, message.getId());
client.delete(path);
ZNRecord record = client.readData(PropertyPathBuilder.liveInstance(clusterName, instanceName));
message.setTgtSessionId(record.getSimpleField(LiveInstanceProperty.SESSION_ID.toString()));
message.setTgtName(record.getId());
// System.out.println(message);
client.createPersistent(path, message.getRecord());
}
内容来源于网络,如有侵权,请联系作者删除!