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

ZKSplitLogManagerCoordination.getDataSetWatch介绍

暂无

代码示例

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

private void createRescanSuccess(String path) {
 SplitLogCounters.tot_mgr_rescan.increment();
 getDataSetWatch(path, zkretries);
}

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

private void createNodeSuccess(String path) {
 LOG.debug("Put up splitlog task at znode " + path);
 getDataSetWatch(path, zkretries);
}

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

@Override
public void nodeDataChanged(String path) {
 Task task;
 task = details.getTasks().get(path);
 if (task != null || ZKSplitLog.isRescanNode(watcher, path)) {
  if (task != null) {
   task.heartbeatNoDetails(EnvironmentEdgeManager.currentTime());
  }
  getDataSetWatch(path, zkretries);
 }
}

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

private void lookForOrphans() {
 List<String> orphans;
 try {
  orphans = ZKUtil.listChildrenNoWatch(this.watcher,
      this.watcher.getZNodePaths().splitLogZNode);
  if (orphans == null) {
   LOG.warn("Could not get children of " + this.watcher.getZNodePaths().splitLogZNode);
   return;
  }
 } catch (KeeperException e) {
  LOG.warn("Could not get children of " + this.watcher.getZNodePaths().splitLogZNode + " "
    + StringUtils.stringifyException(e));
  return;
 }
 int rescan_nodes = 0;
 int listSize = orphans.size();
 for (int i = 0; i < listSize; i++) {
  String path = orphans.get(i);
  String nodepath = ZNodePaths.joinZNode(watcher.getZNodePaths().splitLogZNode, path);
  if (ZKSplitLog.isRescanNode(watcher, nodepath)) {
   rescan_nodes++;
   LOG.debug("Found orphan rescan node " + path);
  } else {
   LOG.info("Found orphan task " + path);
  }
  getDataSetWatch(nodepath, zkretries);
 }
 LOG.info("Found " + (orphans.size() - rescan_nodes) + " orphan tasks and " + rescan_nodes
   + " rescan nodes");
}

代码示例来源：origin: harbby/presto-connectors

private void createRescanSuccess(String path) {
 SplitLogCounters.tot_mgr_rescan.incrementAndGet();
 getDataSetWatch(path, zkretries);
}

代码示例来源：origin: harbby/presto-connectors

private void createNodeSuccess(String path) {
 LOG.debug("put up splitlog task at znode " + path);
 getDataSetWatch(path, zkretries);
}

代码示例来源：origin: harbby/presto-connectors

@Override
public void nodeDataChanged(String path) {
 Task task;
 task = details.getTasks().get(path);
 if (task != null || ZKSplitLog.isRescanNode(watcher, path)) {
  if (task != null) {
   task.heartbeatNoDetails(EnvironmentEdgeManager.currentTime());
  }
  getDataSetWatch(path, zkretries);
 }
}

代码示例来源：origin: harbby/presto-connectors

private void lookForOrphans() {
 List<String> orphans;
 try {
  orphans = ZKUtil.listChildrenNoWatch(this.watcher, this.watcher.splitLogZNode);
  if (orphans == null) {
   LOG.warn("could not get children of " + this.watcher.splitLogZNode);
   return;
  }
 } catch (KeeperException e) {
  LOG.warn("could not get children of " + this.watcher.splitLogZNode + " "
    + StringUtils.stringifyException(e));
  return;
 }
 int rescan_nodes = 0;
 int listSize = orphans.size();
 for (int i = 0; i < listSize; i++) {
  String path = orphans.get(i);
  String nodepath = ZKUtil.joinZNode(watcher.splitLogZNode, path);
  if (ZKSplitLog.isRescanNode(watcher, nodepath)) {
   rescan_nodes++;
   LOG.debug("found orphan rescan node " + path);
  } else {
   LOG.info("found orphan task " + path);
  }
  getDataSetWatch(nodepath, zkretries);
 }
 LOG.info("Found " + (orphans.size() - rescan_nodes) + " orphan tasks and " + rescan_nodes
   + " rescan nodes");
}