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

ZkPathsConfig介绍

暂无

代码示例

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

public String getLoadQueuePath()
{
 return (null == loadQueuePath) ? defaultPath("loadQueue") : loadQueuePath;
}

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

@Inject
public SingleServerInventoryView(
  final ZkPathsConfig zkPaths,
  final CuratorFramework curator,
  final ObjectMapper jsonMapper
)
{
 super(
   log,
   zkPaths.getAnnouncementsPath(),
   zkPaths.getServedSegmentsPath(),
   curator,
   jsonMapper,
   new TypeReference<DataSegment>(){}
 );
}

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

@Inject
public BatchServerInventoryView(
  final ZkPathsConfig zkPaths,
  final CuratorFramework curator,
  final ObjectMapper jsonMapper
)
{
 super(
   log,
   zkPaths.getAnnouncementsPath(),
   zkPaths.getLiveSegmentsPath(),
   curator,
   jsonMapper,
   new TypeReference<Set<DataSegment>>(){}
 );
}

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

.addBinding(CURATOR_KEY)
.toProvider(new DruidLeaderSelectorProvider(
  (zkPathsConfig) -> ZKPaths.makePath(zkPathsConfig.getCoordinatorPath(), "_COORDINATOR"))
.addBinding(CURATOR_KEY)
.toProvider(new DruidLeaderSelectorProvider(
  (zkPathsConfig) -> ZKPaths.makePath(zkPathsConfig.getOverlordPath(), "_OVERLORD"))

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

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

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

@Inject
public BatchDataSegmentAnnouncer(
  DruidServerMetadata server,
  BatchDataSegmentAnnouncerConfig config,
  ZkPathsConfig zkPaths,
  Announcer announcer,
  ObjectMapper jsonMapper
)
{
 super(server, zkPaths, announcer, jsonMapper);
 this.config = config;
 this.announcer = announcer;
 this.jsonMapper = jsonMapper;
 this.liveSegmentLocation = ZKPaths.makePath(zkPaths.getLiveSegmentsPath(), server.getName());
}

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

@Inject
public SingleDataSegmentAnnouncer(
  DruidServerMetadata server,
  ZkPathsConfig config,
  Announcer announcer,
  ObjectMapper jsonMapper
)
{
 super(server, config, announcer, jsonMapper);
 this.announcer = announcer;
 this.jsonMapper = jsonMapper;
 this.servedSegmentsLocation = ZKPaths.makePath(config.getServedSegmentsPath(), server.getName());
}

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

private LeaderLatch createNewLeaderLatch()
{
 final LeaderLatch newLeaderLatch = new LeaderLatch(
   curator, ZKPaths.makePath(zkPaths.getCoordinatorPath(), COORDINATOR_OWNER_NODE), config.getHost()
 );
 newLeaderLatch.addListener(
   new LeaderLatchListener()
   {
    @Override
    public void isLeader()
    {
     DruidCoordinator.this.becomeLeader();
    }
    @Override
    public void notLeader()
    {
     DruidCoordinator.this.stopBeingLeader();
    }
   },
   Execs.singleThreaded("CoordinatorLeader-%s")
 );
 return leaderLatch.getAndSet(newLeaderLatch);
}

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

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

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

@Override
public boolean equals(Object o)
{
 if (this == o) {
  return true;
 }
 if (o == null || getClass() != o.getClass()) {
  return false;
 }
 IndexerZkConfig that = (IndexerZkConfig) o;
 if (announcementsPath != null
   ? !announcementsPath.equals(that.announcementsPath)
   : that.announcementsPath != null) {
  return false;
 }
 if (base != null ? !base.equals(that.base) : that.base != null) {
  return false;
 }
 if (statusPath != null ? !statusPath.equals(that.statusPath) : that.statusPath != null) {
  return false;
 }
 if (tasksPath != null ? !tasksPath.equals(that.tasksPath) : that.tasksPath != null) {
  return false;
 }
 if (zkPathsConfig != null ? !zkPathsConfig.equals(that.zkPathsConfig) : that.zkPathsConfig != null) {
  return false;
 }
 return true;
}

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

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

@Inject
public SingleServerInventoryView(
  final ZkPathsConfig zkPaths,
  final CuratorFramework curator,
  final ObjectMapper jsonMapper,
  final Predicate<Pair<DruidServerMetadata, DataSegment>> defaultFilter
)
{
 super(
   log,
   zkPaths.getAnnouncementsPath(),
   zkPaths.getServedSegmentsPath(),
   curator,
   jsonMapper,
   new TypeReference<DataSegment>()
   {
   }
 );
 Preconditions.checkNotNull(defaultFilter);
 this.defaultFilter = defaultFilter;
}

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

@Inject
public BatchServerInventoryView(
  final ZkPathsConfig zkPaths,
  final CuratorFramework curator,
  final ObjectMapper jsonMapper,
  final Predicate<Pair<DruidServerMetadata, DataSegment>> defaultFilter
)
{
 super(
   log,
   zkPaths.getAnnouncementsPath(),
   zkPaths.getLiveSegmentsPath(),
   curator,
   jsonMapper,
   new TypeReference<Set<DataSegment>>()
   {
   }
 );
 this.defaultFilter = Preconditions.checkNotNull(defaultFilter);
}

代码示例来源：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

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

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

this.server = server;
this.liveSegmentLocation = ZKPaths.makePath(zkPaths.getLiveSegmentsPath(), server.getName());
segmentTransformer = new Function<DataSegment, DataSegment>()

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

public String getConnectorPath()
{
 return (null == connectorPath) ? defaultPath("connector") : connectorPath;
}