gpt4 book ai didi

org.apache.helix.store.zk.ZNode.getChildSet()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-13 09:48:52 26 4
gpt4 key购买 nike

本文整理了Java中org.apache.helix.store.zk.ZNode.getChildSet()方法的一些代码示例,展示了ZNode.getChildSet()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZNode.getChildSet()方法的具体详情如下:
包路径:org.apache.helix.store.zk.ZNode
类名称:ZNode
方法名:getChildSet

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;

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com