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

ZkPathsConfig.getLoadQueuePath介绍

暂无

代码示例

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

@Override
public boolean equals(Object other)
{
 if (null == other) {
  return false;
 }
 if (this == other) {
  return true;
 }
 if (!(other instanceof ZkPathsConfig)) {
  return false;
 }
 ZkPathsConfig otherConfig = (ZkPathsConfig) other;
 if (this.getBase().equals(otherConfig.getBase()) &&
   this.getAnnouncementsPath().equals(otherConfig.getAnnouncementsPath()) &&
   this.getConnectorPath().equals(otherConfig.getConnectorPath()) &&
   this.getLiveSegmentsPath().equals(otherConfig.getLiveSegmentsPath()) &&
   this.getCoordinatorPath().equals(otherConfig.getCoordinatorPath()) &&
   this.getLoadQueuePath().equals(otherConfig.getLoadQueuePath()) &&
   this.getPropertiesPath().equals(otherConfig.getPropertiesPath()) &&
   this.getServedSegmentsPath().equals(otherConfig.getServedSegmentsPath())) {
  return true;
 }
 return false;
}

代码示例来源：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: apache/incubator-druid

zkCoordinator.start();
String segmentZkPath = ZKPaths.makePath(zkPaths.getLoadQueuePath(), me.getName(), segment.getId().toString());

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

ZKPaths.makePath(zkPaths.getLoadQueuePath(), toServer.getName(), segmentId.toString());

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

final String loadQueueLocation = ZKPaths.makePath(zkPaths.getLoadQueuePath(), me.getName());
final String servedSegmentsLocation = ZKPaths.makePath(zkPaths.getServedSegmentsPath(), me.getName());
final String liveSegmentsLocation = ZKPaths.makePath(zkPaths.getLiveSegmentsPath(), me.getName());

代码示例来源：origin: org.apache.druid/druid-server

@Override
public boolean equals(Object other)
{
 if (null == other) {
  return false;
 }
 if (this == other) {
  return true;
 }
 if (!(other instanceof ZkPathsConfig)) {
  return false;
 }
 ZkPathsConfig otherConfig = (ZkPathsConfig) other;
 if (this.getBase().equals(otherConfig.getBase()) &&
   this.getAnnouncementsPath().equals(otherConfig.getAnnouncementsPath()) &&
   this.getConnectorPath().equals(otherConfig.getConnectorPath()) &&
   this.getLiveSegmentsPath().equals(otherConfig.getLiveSegmentsPath()) &&
   this.getCoordinatorPath().equals(otherConfig.getCoordinatorPath()) &&
   this.getLoadQueuePath().equals(otherConfig.getLoadQueuePath()) &&
   this.getPropertiesPath().equals(otherConfig.getPropertiesPath()) &&
   this.getServedSegmentsPath().equals(otherConfig.getServedSegmentsPath())) {
  return true;
 }
 return false;
}

代码示例来源：origin: org.apache.druid/druid-server

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: org.apache.druid/druid-server

zkPaths.getLoadQueuePath(),
  toServer.getName()
), segmentName

代码示例来源：origin: org.apache.druid/druid-server

final String loadQueueLocation = ZKPaths.makePath(zkPaths.getLoadQueuePath(), me.getName());
final String servedSegmentsLocation = ZKPaths.makePath(zkPaths.getServedSegmentsPath(), me.getName());
final String liveSegmentsLocation = ZKPaths.makePath(zkPaths.getLiveSegmentsPath(), me.getName());