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

ZkPathsConfig.getLoadQueuePath介绍

暂无

代码示例

代码示例来源：origin: io.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: io.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: com.n3twork.druid/druid-server

for (DruidServer server : servers) {
 if (!loadManagementPeons.containsKey(server.getName())) {
  String basePath = ZKPaths.makePath(zkPaths.getLoadQueuePath(), server.getName());
  LoadQueuePeon loadQueuePeon = taskMaster.giveMePeon(basePath);
  log.info("Creating LoadQueuePeon for server[%s] at path[%s]", server.getName(), basePath);

代码示例来源：origin: com.n3twork.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());

代码示例来源：origin: com.n3twork.druid/druid-server

final String toLoadQueueSegPath = ZKPaths.makePath(ZKPaths.makePath(zkPaths.getLoadQueuePath(), to), segmentName);
final String toServedSegPath = ZKPaths.makePath(
  ZKPaths.makePath(serverInventoryView.getInventoryManagerConfig().getInventoryPath(), to), segmentName

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

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

代码示例来源：origin: io.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());