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

ZKPaths.makePath介绍

[英]Given a parent path and a child node, create a combined full path
[中]

代码示例

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

public static String getTierListenerPath(String tier)
{
 return ZKPaths.makePath(LookupCoordinatorManager.LOOKUP_LISTEN_ANNOUNCE_KEY, tier);
}

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

ListenerResourceAnnouncer(
  Announcer announcer,
  String announceBasePath,
  HostAndPortWithScheme node
)
{
 this.announcePath = ZKPaths.makePath(announceBasePath, node.toString());
 this.announcer = announcer;
}

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

private String makeServedSegmentPath(String zNode)
{
 return ZKPaths.makePath(liveSegmentLocation, StringUtils.format("%s%s", zNode, counter.getAndIncrement()));
}

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

private String defaultIndexerPath(final String subPath)
{
 return ZKPaths.makePath(getBase(), subPath);
}

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

public ListenerResourceAnnouncer(
  Announcer announcer,
  ListeningAnnouncerConfig listeningAnnouncerConfig,
  String listener_key,
  HostAndPortWithScheme node
)
{
 this(
   announcer,
   ZKPaths.makePath(listeningAnnouncerConfig.getListenersPath(), listener_key),
   node
 );
}

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

public String defaultPath(final String subPath)
{
 return ZKPaths.makePath(getBase(), subPath);
}

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

private String makeAnnouncementPath()
 {
  return ZKPaths.makePath(config.getAnnouncementsPath(), server.getName());
 }
}

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

/**
  * Build a path for the particular named listener. The first implementation of this is used with zookeeper, but
  * there is nothing restricting its use in a more general pathing (example: http endpoint proxy for raft)
  * @param listenerName The key for the listener.
  * @return A path appropriate for use in zookeeper to discover the listeners with the particular listener name
  */
 public String getAnnouncementPath(String listenerName)
 {
  return ZKPaths.makePath(
    getListenersPath(),
    Preconditions.checkNotNull(
      StringUtils.emptyToNullNonDruidDataString(listenerName), "Listener name cannot be null"
    )
  );
 }
}

代码示例来源：origin: spotify/helios

private void delete(final String node) throws KeeperException {
 final ZooKeeperClient client = client("delete");
 final String nodePath = ZKPaths.makePath(path, node);
 if (client.stat(nodePath) != null) {
  log.debug("deleting node: {}", nodePath);
  client.delete(nodePath);
 }
}

代码示例来源：origin: spotify/helios

private void write(final String node, final byte[] data) throws KeeperException {
 final ZooKeeperClient client = client("write");
 final String nodePath = ZKPaths.makePath(path, node);
 if (client.stat(nodePath) != null) {
  log.debug("setting node: {}", nodePath);
  client.setData(nodePath, data);
 } else {
  log.debug("creating node: {}", nodePath);
  client.createAndSetData(nodePath, data);
 }
}

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

public UsageListing(Exhibitor exhibitor, String startPath, int maxChildren)
{
  if ( startPath.trim().length() == 0 )
  {
    startPath = "/";
  }
  ZKPaths.PathAndNode pathAndNode = ZKPaths.getPathAndNode(startPath);
  this.exhibitor = exhibitor;
  this.startPath = ZKPaths.makePath(pathAndNode.getPath(), pathAndNode.getNode());
  this.maxChildren = maxChildren;
}

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

public LoadQueuePeon giveMePeon(ImmutableDruidServer server)
 {
  if ("http".equalsIgnoreCase(config.getLoadQueuePeonType())) {
   return new HttpLoadQueuePeon(server.getURL(), jsonMapper, httpClient, config, peonExec, callbackExec);
  } else {
   return new CuratorLoadQueuePeon(
     curator,
     ZKPaths.makePath(zkPaths.getLoadQueuePath(), server.getName()),
     jsonMapper,
     peonExec,
     callbackExec,
     config
   );
  }
 }
}

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

private void recursivelyDelete(String path) throws Exception
{
  List<String>        children = context.getExhibitor().getLocalConnection().getChildren().forPath(path);
  for ( String name : children )
  {
    recursivelyDelete(ZKPaths.makePath(path, name));
  }
  context.getExhibitor().getLocalConnection().delete().forPath(path);
  context.getExhibitor().getLog().add(ActivityLog.Type.INFO, String.format("deleteNode() deleted node [%s]", path));
}

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

@Override
public void announce(DiscoveryDruidNode discoveryDruidNode)
{
 try {
  log.info("Announcing [%s].", discoveryDruidNode);
  String path = ZKPaths.makePath(
    config.getInternalDiscoveryPath(),
    discoveryDruidNode.getNodeType().toString(),
    discoveryDruidNode.getDruidNode().getHostAndPortToUse()
  );
  announcer.announce(path, jsonMapper.writeValueAsBytes(discoveryDruidNode));
  log.info("Announced [%s].", discoveryDruidNode);
 }
 catch (JsonProcessingException e) {
  throw Throwables.propagate(e);
 }
}

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

NodeTypeWatcher(
  ExecutorService listenerExecutor,
  CuratorFramework curatorFramework,
  String basePath,
  ObjectMapper jsonMapper,
  NodeType nodeType
)
{
 this.listenerExecutor = listenerExecutor;
 this.curatorFramework = curatorFramework;
 this.nodeType = nodeType;
 this.jsonMapper = jsonMapper;
 // This is required to be single threaded from Docs in PathChildrenCache;
 this.cacheExecutor = Execs.singleThreaded(StringUtils.format("NodeTypeWatcher[%s]", nodeType));
 this.cache = new PathChildrenCache(
   curatorFramework,
   ZKPaths.makePath(basePath, nodeType.toString()),
   true,
   true,
   cacheExecutor
 );
}

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

propertyValues.put(StringUtils.format("%s.propertiesPath", configPrefix), ZKPaths.makePath(base, "properties"));
propertyValues.put(StringUtils.format("%s.announcementsPath", configPrefix), ZKPaths.makePath(base, "announcements"));
propertyValues.put(StringUtils.format("%s.servedSegmentsPath", configPrefix), ZKPaths.makePath(base, "servedSegments"));
propertyValues.put(StringUtils.format("%s.liveSegmentsPath", configPrefix), ZKPaths.makePath(base, "segments"));
propertyValues.put(StringUtils.format("%s.coordinatorPath", configPrefix), ZKPaths.makePath(base, "coordinator"));
propertyValues.put(StringUtils.format("%s.loadQueuePath", configPrefix), ZKPaths.makePath(base, "loadQueue"));
propertyValues.put(StringUtils.format("%s.connectorPath", configPrefix), ZKPaths.makePath(base, "connector"));

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

private void unannounceSegmentForServer(DruidServer druidServer, DataSegment segment) throws Exception
{
 curator
   .delete()
   .guaranteed()
   .forPath(ZKPaths.makePath(inventoryPath, druidServer.getHost(), segment.getId().toString()));
}

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

@Override
 public void unannounce(DiscoveryDruidNode discoveryDruidNode)
 {
  log.info("Unannouncing [%s].", discoveryDruidNode);

  String path = ZKPaths.makePath(
    config.getInternalDiscoveryPath(),
    discoveryDruidNode.getNodeType().toString(),
    discoveryDruidNode.getDruidNode().getHostAndPortToUse()
  );
  announcer.unannounce(path);

  log.info("Unannounced [%s].", discoveryDruidNode);
 }
}

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

protected void unannounceSegmentForServer(DruidServer druidServer, DataSegment segment, ZkPathsConfig zkPathsConfig)
  throws Exception
{
 String path = ZKPaths.makePath(
   zkPathsConfig.getLiveSegmentsPath(),
   druidServer.getHost(),
   segment.getId().toString()
 );
 curator.delete().guaranteed().forPath(path);
}

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

@Test
 public void testStartCorrect()
 {
  final Announcer announcer = EasyMock.createStrictMock(Announcer.class);
  final HostAndPortWithScheme node = HostAndPortWithScheme.fromString("some_host");

  final ListenerResourceAnnouncer resourceAnnouncer = new ListenerResourceAnnouncer(
    announcer,
    listeningAnnouncerConfig,
    listenerKey,
    node
  )
  {
  };

  announcer.announce(
    EasyMock.eq(ZKPaths.makePath(announcePath, StringUtils.format("%s:%s", node.getScheme(), node.getHostText()))),
    EasyMock.aryEq(resourceAnnouncer.getAnnounceBytes())
  );
  EasyMock.expectLastCall().once();
  EasyMock.replay(announcer);
  resourceAnnouncer.start();
  EasyMock.verify(announcer);
 }
}