org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.4k)|赞(0)|评价(0)|浏览(102)

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

ZooKeeperTreeTracker.<init>介绍

暂无

代码示例

代码示例来源:origin: org.fusesource.insight/insight-graph

this.tracker = new ZooKeeperTreeTracker<OutputWriter>(collector.getZkClient(), reader, zkPath);

代码示例来源:origin: org.fusesource.fabric/fabric-configadmin

protected ZooKeeperTreeTracker<String> track(String path) throws InterruptedException, KeeperException, IOException {
  ZooKeeperTreeTracker<String> tree = trees.get(path);
  if (tree == null) {
    if (ZooKeeperUtils.exists(zooKeeper, path) != null) {
      tree = new ZooKeeperTreeTracker<String>(zooKeeper, new ZKStringDataReader(), path);
      trees.put(path, tree);
      tree.track(this);
      String[] parents = getParents(tree.getTree().get(path));
      for (String parent : parents) {
        track(ZkPath.CONFIG_VERSIONS_PROFILE.getPath(version, parent));
      }
    } else {
      // If the node does not exist yet, we track the parent to make
      // sure we receive the node creation event
      String p = ZkPath.CONFIG_VERSIONS_PROFILES.getPath(version);
      if (!trees.containsKey(p)) {
        tree = new ZooKeeperTreeTracker<String>(zooKeeper, new ZKStringDataReader(), p, 1);
        trees.put(p, tree);
        tree.track(this);
      }
      return null;
    }
  }
  return tree;
}

相关文章