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

ZNode.getStat介绍

暂无

代码示例

代码示例来源：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

readStats.set(i, zNode.getStat());
} else {
 needRead = true;

代码示例来源：origin: apache/helix

readStats.set(i, zNode.getStat());
} else {
 needRead = true;

代码示例来源：origin: org.apache.helix/helix-core

Stat oldStat = znode.getStat();

代码示例来源：origin: apache/helix

Stat oldStat = znode.getStat();

代码示例来源：origin: org.apache.helix/helix-core

@Override
public Stat getStat(String path, int options) {
 String clientPath = path;
 String serverPath = prependChroot(clientPath);
 Cache<T> cache = getCache(serverPath);
 if (cache != null) {
  Stat stat = new Stat();
  ZNode znode = cache.get(serverPath);
  if (znode != null) {
   return znode.getStat();
  } else {
   // if cache miss, fall back to zk and update cache
   try {
    cache.lockWrite();
    T data = _baseAccessor.get(serverPath, stat, options);
    cache.update(serverPath, data, stat);
   } catch (ZkNoNodeException e) {
    return null;
   } finally {
    cache.unlockWrite();
   }
   return stat;
  }
 }
 // no cache
 return _baseAccessor.getStat(serverPath, options);
}

代码示例来源：origin: apache/helix

@Override
public Stat getStat(String path, int options) {
 String clientPath = path;
 String serverPath = prependChroot(clientPath);
 Cache<T> cache = getCache(serverPath);
 if (cache != null) {
  Stat stat = new Stat();
  ZNode znode = cache.get(serverPath);
  if (znode != null) {
   return znode.getStat();
  } else {
   // if cache miss, fall back to zk and update cache
   try {
    cache.lockWrite();
    T data = _baseAccessor.get(serverPath, stat, options);
    cache.update(serverPath, data, stat);
   } catch (ZkNoNodeException e) {
    return null;
   } finally {
    cache.unlockWrite();
   }
   return stat;
  }
 }
 // no cache
 return _baseAccessor.getStat(serverPath, options);
}

代码示例来源：origin: apache/helix

if (cacheNode.getStat() == null || !zkNode.getStat().equals(cacheNode.getStat())) {
 System.err.println("Stat mismatch on path: " + path + ", inCache: " + cacheNode.getStat()
   + ", onZk: " + zkNode.getStat());
 return false;

代码示例来源：origin: apache/helix

@Override
public void update(String path, T data, Stat stat) {
 String parentPath = HelixUtil.getZkParentPath(path);
 String childName = HelixUtil.getZkName(path);
 addToParentChildSet(parentPath, childName);
 ZNode znode = _cache.get(path);
 if (znode == null) {
  _cache.put(path, new ZNode(path, data, stat));
  fireEvents(path, EventType.NodeCreated);
 } else {
  Stat oldStat = znode.getStat();
  znode.setData(data);
  znode.setStat(stat);
  // System.out.println("\t\t--setData. path: " + path + ", data: " + data);
  if (oldStat.getCzxid() != stat.getCzxid()) {
   fireEvents(path, EventType.NodeDeleted);
   fireEvents(path, EventType.NodeCreated);
  } else if (oldStat.getVersion() != stat.getVersion()) {
   // System.out.println("\t--fireNodeChanged: " + path + ", oldVersion: " +
   // oldStat.getVersion() + ", newVersion: " + stat.getVersion());
   fireEvents(path, EventType.NodeDataChanged);
  }
 }
}

代码示例来源：origin: org.apache.helix/helix-core

@Override
public void update(String path, T data, Stat stat) {
 String parentPath = HelixUtil.getZkParentPath(path);
 String childName = HelixUtil.getZkName(path);
 addToParentChildSet(parentPath, childName);
 ZNode znode = _cache.get(path);
 if (znode == null) {
  _cache.put(path, new ZNode(path, data, stat));
  fireEvents(path, EventType.NodeCreated);
 } else {
  Stat oldStat = znode.getStat();
  znode.setData(data);
  znode.setStat(stat);
  // System.out.println("\t\t--setData. path: " + path + ", data: " + data);
  if (oldStat.getCzxid() != stat.getCzxid()) {
   fireEvents(path, EventType.NodeDeleted);
   fireEvents(path, EventType.NodeCreated);
  } else if (oldStat.getVersion() != stat.getVersion()) {
   // System.out.println("\t--fireNodeChanged: " + path + ", oldVersion: " +
   // oldStat.getVersion() + ", newVersion: " + stat.getVersion());
   fireEvents(path, EventType.NodeDataChanged);
  }
 }
}

代码示例来源：origin: apache/helix

DataTree.copyStat(znode.getStat(), stat);

代码示例来源：origin: org.apache.helix/helix-core

DataTree.copyStat(znode.getStat(), stat);