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

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

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

QueryableIndexSegment介绍

暂无

代码示例

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

@Override
 public Segment factorize(DataSegment dataSegment, File parentDir) throws SegmentLoadingException
 {
  try {
   return new QueryableIndexSegment(indexIO.loadIndex(parentDir), dataSegment.getId());
  }
  catch (IOException e) {
   throw new SegmentLoadingException(e, "%s", e.getMessage());
  }
 }
}

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

private List<QueryRunner<Row>> makeMultiRunners()
 {
  List<QueryRunner<Row>> runners = new ArrayList<>();
  for (int i = 0; i < numSegments; i++) {
   String segmentName = "qIndex" + i;
   QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
     factory,
     SegmentId.dummy(segmentName),
     new QueryableIndexSegment(queryableIndexes.get(i), SegmentId.dummy(segmentName))
   );
   runners.add(factory.getToolchest().preMergeQueryDecoration(runner));
  }
  return runners;
 }
}

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

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<T, Query<T>> factory = conglomerate.findFactory(query);
 final QueryRunner<T> runner = factory.createRunner(new QueryableIndexSegment(index, SegmentId.dummy("segment")));
 return factory
   .getToolchest()
   .mergeResults(factory.mergeRunners(Execs.directExecutor(), ImmutableList.of(runner)))
   .run(QueryPlus.wrap(query), new HashMap<>());
}

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

@Override
 public Segment apply(File segmentDir)
 {
  try {
   return new QueryableIndexSegment(indexIO.loadIndex(segmentDir), SegmentId.dummy(""));
  }
  catch (IOException ex) {
   throw Throwables.propagate(ex);
  }
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexStringThenLong(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Row> results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, stringQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
 runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, longQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexStringThenNumeric(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Row> results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, stringQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
 runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, longFloatQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexLongTwice(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Row> results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, longQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
 runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, longQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexStringTwice(Blackhole blackhole)
{
 QueryRunner<Result<TopNResultValue>> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(qIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Result<TopNResultValue>> results = TopNTypeInterfaceBenchmark.runQuery(factory, runner, stringQuery);
 for (Result<TopNResultValue> result : results) {
  blackhole.consume(result);
 }
 runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(qIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 results = TopNTypeInterfaceBenchmark.runQuery(factory, runner, stringQuery);
 for (Result<TopNResultValue> result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexFloatThenString(Blackhole blackhole)
{
 QueryRunner<Result<TopNResultValue>> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(qIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Result<TopNResultValue>> results = TopNTypeInterfaceBenchmark.runQuery(factory, runner, floatQuery);
 for (Result<TopNResultValue> result : results) {
  blackhole.consume(result);
 }
 runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(qIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 results = TopNTypeInterfaceBenchmark.runQuery(factory, runner, stringQuery);
 for (Result<TopNResultValue> result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexStringOnly(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Row> results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, stringQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexLongThenString(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Row> results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, longQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
 runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, stringQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexFloatOnly(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Row> results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, floatQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexFloatOnly(Blackhole blackhole)
{
 QueryRunner<Result<TopNResultValue>> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(qIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Result<TopNResultValue>> results = TopNTypeInterfaceBenchmark.runQuery(factory, runner, floatQuery);
 for (Result<TopNResultValue> result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexLongOnly(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Row> results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, longQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexNumericOnly(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(queryableIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Row> results = GroupByTypeInterfaceBenchmark.runQuery(factory, runner, longFloatQuery);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexStringOnly(Blackhole blackhole)
{
 QueryRunner<Result<TopNResultValue>> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(qIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Result<TopNResultValue>> results = TopNTypeInterfaceBenchmark.runQuery(factory, runner, stringQuery);
 for (Result<TopNResultValue> result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndexLongOnly(Blackhole blackhole)
{
 QueryRunner<Result<TopNResultValue>> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   Q_INDEX_SEGMENT_ID,
   new QueryableIndexSegment(qIndexes.get(0), Q_INDEX_SEGMENT_ID)
 );
 List<Result<TopNResultValue>> results = TopNTypeInterfaceBenchmark.runQuery(factory, runner, longQuery);
 for (Result<TopNResultValue> result : results) {
  blackhole.consume(result);
 }
}

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

private List<QueryRunner<Row>> getRunner2(int qIndexNumber)
{
 List<QueryRunner<Row>> runners = new ArrayList<>();
 QueryableIndex index2 = groupByIndices.get(qIndexNumber);
 QueryRunner<Row> tooSmallRunner = makeQueryRunner(
   groupByFactory2,
   SegmentId.dummy(index2.toString()),
   new QueryableIndexSegment(index2, SegmentId.dummy(index2.toString()))
 );
 runners.add(groupByFactory2.getToolchest().preMergeQueryDecoration(tooSmallRunner));
 return runners;
}

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

private List<QueryRunner<Row>> getRunner1(int qIndexNumber)
{
 List<QueryRunner<Row>> runners = new ArrayList<>();
 QueryableIndex index = groupByIndices.get(qIndexNumber);
 QueryRunner<Row> runner = makeQueryRunner(
   groupByFactory,
   SegmentId.dummy(index.toString()),
   new QueryableIndexSegment(index, SegmentId.dummy(index.toString()))
 );
 runners.add(groupByFactory.getToolchest().preMergeQueryDecoration(runner));
 return runners;
}

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

private List<QueryRunner<Row>> getRunner2()
{
 List<QueryRunner<Row>> runners = new ArrayList<>();
 QueryableIndex index2 = groupByIndices.get(1);
 QueryRunner<Row> tooSmallRunner = makeQueryRunner(
   tooSmallGroupByFactory,
   SegmentId.dummy(index2.toString()),
   new QueryableIndexSegment(index2, SegmentId.dummy(index2.toString()))
 );
 runners.add(tooSmallGroupByFactory.getToolchest().preMergeQueryDecoration(tooSmallRunner));
 return runners;
}

内容来源于网络，如有侵权，请联系作者删除！

QueryableIndexSegment

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    QueryableIndexSegment类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com