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

ZKPaths.getNodeFromPath介绍

[英]Given a full path, return the node name. i.e. "/one/two/three" will return "three"
[中]给定完整路径，返回节点名称。i、 e.“/one/two/three”将返回“three”

代码示例

代码示例来源：origin: mpusher/mpush

public String getTail(String childPaths) {
  return ZKPaths.getNodeFromPath(childPaths);
}

代码示例来源：origin: soabase/exhibitor

@Override
  public boolean apply(ChildData data)
  {
    return ZKPaths.getNodeFromPath(data.getPath()).equals(CONFIG_NODE_NAME);
  }
},

代码示例来源：origin: apache/incubator-druid

private void entryRemoved(String path)
{
 synchronized (lock) {
  if (currentlyProcessing == null) {
   log.warn("Server[%s] an entry[%s] was removed even though it wasn't loading!?", basePath, path);
   return;
  }
  if (!ZKPaths.getNodeFromPath(path).equals(currentlyProcessing.getSegmentId().toString())) {
   log.warn(
     "Server[%s] entry [%s] was removed even though it's not what is currently loading[%s]",
     basePath, path, currentlyProcessing
   );
   return;
  }
  log.debug(
    "Server[%s] done processing %s of segment [%s]",
    basePath,
    currentlyProcessing.getType() == LOAD ? "load" : "drop",
    path
  );
  actionCompleted();
 }
}

代码示例来源：origin: HubSpot/Singularity

@Override
 public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
  try {
   if (event.getStat() != null) {
    objects.add(Transcoders.getFromStringFunction(idTranscoder).apply(ZKPaths.getNodeFromPath(event.getPath())));
   }
  } finally {
   latch.countDown();
  }
 }
};

代码示例来源：origin: info.xiancloud/xian-curator-recipes

@Override
  public String getNodeName() {
    return ZKPaths.getNodeFromPath(path);
  }
};

代码示例来源：origin: info.xiancloud/xian-curator-recipes

/**
 * Given a full ZNode path, return the member ID
 *
 * @param path full ZNode path
 * @return id
 */
public String idFromPath(String path)
{
  return ZKPaths.getNodeFromPath(path);
}

代码示例来源：origin: com.github.mpusher/mpush-zk

public String getTail(String childPaths) {
  return ZKPaths.getNodeFromPath(childPaths);
}

代码示例来源：origin: nirmata/workflow

public static String getTaskIdFromCompletedTasksPath(String path)
{
  String n = ZKPaths.getNodeFromPath(path);
  return Splitter.on(SEPARATOR).splitToList(n).get(1);
}

代码示例来源：origin: nirmata/workflow

public static String getRunIdFromCompletedTasksPath(String path)
{
  String n = ZKPaths.getNodeFromPath(path);
  return Splitter.on(SEPARATOR).splitToList(n).get(0);
}

代码示例来源：origin: pravega/pravega

private StreamImpl getStreamFromPath(String path) {
  String scopedStream = decodedScopedStreamName(ZKPaths.getNodeFromPath(path));
  String[] splits = scopedStream.split("/");
  return new StreamImpl(splits[0], splits[1]);
}

代码示例来源：origin: io.fabric8/fabric-zookeeper

private synchronized void addToParent(String fullPath) {
  Optional<String> parent = getParentOf(fullPath);
  if (parent.isPresent()) {
    TreeData parentData = currentData.getIfPresent(parent.get());
    if (parentData != null) {
      parentData.getChildren().add(ZKPaths.getNodeFromPath(fullPath));
    }
  }
}

代码示例来源：origin: io.fabric8/fabric-zookeeper

private synchronized void removeFromParent(String fullPath) {
  Optional<String> parent = getParentOf(fullPath);
  if (parent.isPresent()) {
    TreeData parentData = currentData.getIfPresent(parent.get());
    if (parentData != null) {
      parentData.getChildren().remove(ZKPaths.getNodeFromPath(fullPath));
    }
  }
}

代码示例来源：origin: com.hubspot/SingularityService

@Override
 public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
  try {
   if (event.getStat() != null) {
    objects.add(Transcoders.getFromStringFunction(idTranscoder).apply(ZKPaths.getNodeFromPath(event.getPath())));
   }
  } finally {
   latch.countDown();
  }
 }
};

代码示例来源：origin: jboss-fuse/fabric8

private synchronized void addToParent(String fullPath) {
  Optional<String> parent = getParentOf(fullPath);
  if (parent.isPresent()) {
    TreeData parentData = currentData.getIfPresent(parent.get());
    if (parentData != null) {
      parentData.getChildren().add(ZKPaths.getNodeFromPath(fullPath));
    }
  }
}

代码示例来源：origin: jboss-fuse/fabric8

private synchronized void removeFromParent(String fullPath) {
  Optional<String> parent = getParentOf(fullPath);
  if (parent.isPresent()) {
    TreeData parentData = currentData.getIfPresent(parent.get());
    if (parentData != null) {
      parentData.getChildren().remove(ZKPaths.getNodeFromPath(fullPath));
    }
  }
}

代码示例来源：origin: dCache/dcache

@Override
  Map<String,CoreDomainInfo> cores()
  {
    Map<String, CoreDomainInfo> coresInfo = new HashMap<>();
    for (ChildData d: cores.getCurrentData()) {
      coresInfo.put(ZKPaths.getNodeFromPath(d.getPath()), new CoreDomainInfoUri(d.getData()));
    }
    return coresInfo;
  }
}

代码示例来源：origin: dCache/dcache

@Override
  Map<String,CoreDomainInfo> cores()
  {
    Map<String, CoreDomainInfo> coresInfo = new HashMap<>();
    for (ChildData d: cores.getCurrentData()) {
      coresInfo.put(ZKPaths.getNodeFromPath(d.getPath()), new CoreDomainInfoPlain(d.getData()));
    }
    return coresInfo;
  }
}

代码示例来源：origin: hekailiang/cloud-config

protected String safeGetNodeNameFromEvent(PathChildrenCacheEvent event) {
  return event.getData() != null ?
      ZKPaths.getNodeFromPath(event.getData().getPath()) : "";
}

代码示例来源：origin: hekailiang/cloud-config

@Override
protected void handleChildAdded(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {
  String nodeName = event.getData()!=null ?
      ZKPaths.getNodeFromPath(event.getData().getPath()) : "";
  buildResourceConfig(nodeName);
}

代码示例来源：origin: apache/incubator-sentry

public static void setUpdateFromChildEvent(PathChildrenCacheEvent cacheEvent,
  Update update) throws IOException {
 byte eventData[] = cacheEvent.getData().getData();
 update.deserialize(eventData);
 String seqNum = ZKPaths.getNodeFromPath(cacheEvent.getData().getPath());
 update.setSeqNum(Integer.valueOf(seqNum));
}