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

ZkPathsConfig.getCoordinatorPath介绍

暂无

代码示例

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

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

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

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);
}