本文整理了Java中org.apache.helix.store.zk.ZNode.getChildSet()
方法的一些代码示例,展示了ZNode.getChildSet()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZNode.getChildSet()
方法的具体详情如下:
包路径:org.apache.helix.store.zk.ZNode
类名称:ZNode
方法名:getChildSet
暂无
代码示例来源:origin: org.apache.helix/helix-core
public void purgeRecursive(String path) {
try {
_lock.writeLock().lock();
String parentPath = HelixUtil.getZkParentPath(path);
String name = HelixUtil.getZkName(path);
removeFromParentChildSet(parentPath, name);
ZNode znode = _cache.remove(path);
if (znode != null) {
// recursively remove children nodes
Set<String> childNames = znode.getChildSet();
for (String childName : childNames) {
String childPath = path + "/" + childName;
purgeRecursive(childPath);
}
}
} finally {
_lock.writeLock().unlock();
}
}
代码示例来源:origin: apache/helix
public void purgeRecursive(String path) {
try {
_lock.writeLock().lock();
String parentPath = HelixUtil.getZkParentPath(path);
String name = HelixUtil.getZkName(path);
removeFromParentChildSet(parentPath, name);
ZNode znode = _cache.remove(path);
if (znode != null) {
// recursively remove children nodes
Set<String> childNames = znode.getChildSet();
for (String childName : childNames) {
String childPath = path + "/" + childName;
purgeRecursive(childPath);
}
}
} finally {
_lock.writeLock().unlock();
}
}
代码示例来源:origin: apache/helix
public static void printCache(Map<String, ZNode> cache) {
System.out.println("START:Print cache");
TreeMap<String, ZNode> map = new TreeMap<String, ZNode>();
map.putAll(cache);
for (String key : map.keySet()) {
ZNode node = map.get(key);
TreeSet<String> childSet = new TreeSet<String>();
childSet.addAll(node.getChildSet());
System.out.print(key + "=" + node.getData() + ", " + childSet + ", "
+ (node.getStat() == null ? "null\n" : node.getStat()));
}
System.out.println("END:Print cache");
}
代码示例来源:origin: org.apache.helix/helix-core
@Override
public List<String> getChildNames(String parentPath, int options) {
String serverParentPath = prependChroot(parentPath);
Cache<T> cache = getCache(serverParentPath);
if (cache != null) {
// System.out.println("zk-cache");
ZNode znode = cache.get(serverParentPath);
if (znode != null && znode.getChildSet() != Collections.<String> emptySet()) {
// System.out.println("zk-cache-hit: " + parentPath);
List<String> childNames = new ArrayList<String>(znode.getChildSet());
Collections.sort(childNames);
return childNames;
} else {
// System.out.println("zk-cache-miss");
try {
cache.lockWrite();
List<String> childNames = _baseAccessor.getChildNames(serverParentPath, options);
// System.out.println("\t--" + childNames);
cache.addToParentChildSet(serverParentPath, childNames);
return childNames;
} finally {
cache.unlockWrite();
}
}
}
// no cache
return _baseAccessor.getChildNames(serverParentPath, options);
}
代码示例来源:origin: apache/helix
@Override
public List<String> getChildNames(String parentPath, int options) {
String serverParentPath = prependChroot(parentPath);
Cache<T> cache = getCache(serverParentPath);
if (cache != null) {
// System.out.println("zk-cache");
ZNode znode = cache.get(serverParentPath);
if (znode != null && znode.getChildSet() != Collections.<String>emptySet()) {
// System.out.println("zk-cache-hit: " + parentPath);
List<String> childNames = new ArrayList<String>(znode.getChildSet());
Collections.sort(childNames);
return childNames;
} else {
// System.out.println("zk-cache-miss");
try {
cache.lockWrite();
List<String> childNames = _baseAccessor.getChildNames(serverParentPath, options);
// System.out.println("\t--" + childNames);
cache.addToParentChildSet(serverParentPath, childNames);
return childNames;
} finally {
cache.unlockWrite();
}
}
}
// no cache
return _baseAccessor.getChildNames(serverParentPath, options);
}
代码示例来源:origin: apache/helix
if ((zkNode.getChildSet() == null && cacheNode.getChildSet() != null)
|| (zkNode.getChildSet() != null && cacheNode.getChildSet() == null)
|| (zkNode.getChildSet() != null && cacheNode.getChildSet() != null && !zkNode
.getChildSet().equals(cacheNode.getChildSet()))) {
+ cacheNode.getChildSet() + ", onZk: " + zkNode.getChildSet());
return false;
内容来源于网络,如有侵权,请联系作者删除!