io.druid.segment.QueryableIndexSegment类的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(2.6k)|赞(0)|评价(0)|浏览(64)

本文整理了Java中io.druid.segment.QueryableIndexSegment类的一些代码示例,展示了QueryableIndexSegment类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryableIndexSegment类的具体详情如下:
包路径:io.druid.segment.QueryableIndexSegment
类名称: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)

相关文章

微信公众号

最新文章

更多

QueryableIndexSegment类方法