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

ZkPathsConfig.getLiveSegmentsPath介绍

暂无

代码示例

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

@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: 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 CoordinatorServerViewTest()
{
 jsonMapper = TestHelper.makeJsonMapper();
 zkPathsConfig = new ZkPathsConfig();
 inventoryPath = zkPathsConfig.getLiveSegmentsPath();
}

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

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

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

protected void announceSegmentForServer(
  DruidServer druidServer,
  DataSegment segment,
  ZkPathsConfig zkPathsConfig,
  ObjectMapper jsonMapper
)
{
 final String segmentAnnouncementPath =
   ZKPaths.makePath(zkPathsConfig.getLiveSegmentsPath(), druidServer.getHost(), segment.getId().toString());
 try {
  curator.create()
      .compressed()
      .withMode(CreateMode.EPHEMERAL)
      .forPath(segmentAnnouncementPath, jsonMapper.writeValueAsBytes(ImmutableSet.of(segment)));
 }
 catch (KeeperException.NodeExistsException e) {
  try {
   curator.setData()
       .forPath(segmentAnnouncementPath, jsonMapper.writeValueAsBytes(ImmutableSet.of(segment)));
  }
  catch (Exception e1) {
   Throwables.propagate(e1);
  }
 }
 catch (Exception e) {
  Throwables.propagate(e);
 }
}

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

zkPathsConfig.getLiveSegmentsPath(),
druidServer.getHost(),
UUIDUtils.generateUuid(

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

protected void setupZNodeForServer(DruidServer server, ZkPathsConfig zkPathsConfig, ObjectMapper jsonMapper)
 final String inventoryPath = zkPathsConfig.getLiveSegmentsPath();

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

final String liveSegmentsLocation = ZKPaths.makePath(zkPaths.getLiveSegmentsPath(), me.getName());

代码示例来源：origin: org.apache.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: 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

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

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

final String liveSegmentsLocation = ZKPaths.makePath(zkPaths.getLiveSegmentsPath(), me.getName());