本文整理了Java中com.liveramp.hank.coordinator.zk.ZkDomain.delete()
方法的一些代码示例,展示了ZkDomain.delete()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkDomain.delete()
方法的具体详情如下:
包路径:com.liveramp.hank.coordinator.zk.ZkDomain
类名称:ZkDomain
方法名:delete
暂无
代码示例来源:origin: LiveRamp/hank
@Override
public boolean deleteDomain(String domainName) throws IOException {
ZkDomain domain = domains.remove(domainName);
if (domain == null) {
return false;
}
// remove domain from all domain groups
for (DomainGroup domainGroup : getDomainGroups()) {
domainGroup.removeDomain(domain);
}
return domain.delete();
}
代码示例来源:origin: LiveRamp/hank
@Test
public void testDelete() throws Exception {
ZkDomain dc = ZkDomain.create(getZk(), getRoot(), "domain0", 1, ConstantStorageEngine.Factory.class.getName(), "---", Murmur64Partitioner.class.getName(), 0, Collections.<String>emptyList());
assertNotNull(getZk().exists(ZkPath.append(getRoot(), "domain0"), false));
assertTrue(dc.delete());
WaitUntil.orDie(() -> {
try {
return getZk().exists(ZkPath.append(getRoot(), "domain0"), false) == null;
} catch (KeeperException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
});
assertNull(getZk().exists(ZkPath.append(getRoot(), "domain0"), false));
}
}
内容来源于网络,如有侵权,请联系作者删除!