本文整理了Java中org.apache.druid.server.initialization.ZkPathsConfig.getLiveSegmentsPath()
方法的一些代码示例,展示了ZkPathsConfig.getLiveSegmentsPath()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkPathsConfig.getLiveSegmentsPath()
方法的具体详情如下:
包路径:org.apache.druid.server.initialization.ZkPathsConfig
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!