本文整理了Java中io.druid.segment.QueryableIndexSegment
类的一些代码示例,展示了QueryableIndexSegment
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryableIndexSegment
类的具体详情如下:
包路径:io.druid.segment.QueryableIndexSegment
类名称:QueryableIndexSegment
暂无
代码示例来源:origin: io.druid/druid-processing
@Override
public Segment factorize(DataSegment dataSegment, File parentDir) throws SegmentLoadingException
{
try {
return new QueryableIndexSegment(dataSegment.getIdentifier(), indexIO.loadIndex(parentDir));
}
catch (IOException e) {
throw new SegmentLoadingException(e, "%s", e.getMessage());
}
}
}
代码示例来源:origin: com.n3twork.druid/druid-server
@Override
public Segment getSegment(DataSegment segment) throws SegmentLoadingException
{
File segmentFiles = getSegmentFiles(segment);
final QueryableIndex index = factory.factorize(segmentFiles);
return new QueryableIndexSegment(segment.getIdentifier(), index);
}
代码示例来源:origin: eBay/embedded-druid
@SuppressWarnings("unchecked")
public static Sequence run(Query query, QueryableIndex index) {
return findFactory(query).createRunner(new QueryableIndexSegment("", index)).run(query, null);
}
代码示例来源:origin: io.druid/druid-services
private static <T> Sequence<T> executeQuery(final Injector injector, final QueryableIndex index, final Query<T> query)
{
final QueryRunnerFactoryConglomerate conglomerate = injector.getInstance(QueryRunnerFactoryConglomerate.class);
final QueryRunnerFactory factory = conglomerate.findFactory(query);
final QueryRunner<T> runner = factory.createRunner(new QueryableIndexSegment("segment", index));
final Sequence results = factory.getToolchest().mergeResults(
factory.mergeRunners(MoreExecutors.sameThreadExecutor(), ImmutableList.<QueryRunner>of(runner))
).run(QueryPlus.wrap(query), Maps.<String, Object>newHashMap());
return (Sequence<T>) results;
}
代码示例来源:origin: io.druid/druid-server
new QueryableIndexSegment(
identifier.getIdentifierAsString(),
indexIO.loadIndex(hydrantDir)
代码示例来源:origin: io.druid/druid-server
new QueryableIndexSegment(
DataSegment.makeDataSegmentIdentifier(
schema.getDataSource(),
代码示例来源:origin: com.n3twork.druid/druid-server
new QueryableIndexSegment(
DataSegment.makeDataSegmentIdentifier(
schema.getDataSource(),
代码示例来源:origin: com.n3twork.druid/druid-server
new QueryableIndexSegment(
indexToPersist.getSegment().getIdentifier(),
IndexIO.loadIndex(persistedFile)
代码示例来源:origin: io.druid/druid-server
new QueryableIndexSegment(
indexToPersist.getSegmentIdentifier(),
indexIO.loadIndex(persistedFile)
代码示例来源:origin: io.druid/druid-server
new QueryableIndexSegment(
indexToPersist.getSegmentIdentifier(),
indexIO.loadIndex(persistedFile)
内容来源于网络,如有侵权,请联系作者删除!