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

ZkPathsConfig.getLiveSegmentsPath介绍

暂无

代码示例

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

@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: 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

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

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

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

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

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