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

QueryableIndexSegment.<init>介绍

暂无

代码示例

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

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;
}

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

private List<QueryRunner<Row>> getQueryRunnerForSegment2()
{
 List<QueryRunner<Row>> runners = new ArrayList<>();
 QueryableIndex index2 = groupByIndices.get(1);
 QueryRunner<Row> tooSmallRunner = makeQueryRunnerForSegment(
   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()
{
 List<QueryRunner<Row>> runners = new ArrayList<>();
 QueryableIndex index = groupByIndices.get(0);
 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>> getQueryRunnerForSegment1()
{
 List<QueryRunner<Row>> runners = new ArrayList<>();
 QueryableIndex index = groupByIndices.get(0);
 QueryRunner<Row> runner = makeQueryRunnerForSegment(
   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>> makeGroupByMultiRunners()
{
 List<QueryRunner<Row>> runners = new ArrayList<>();
 for (QueryableIndex qindex : groupByIndices) {
  QueryRunner<Row> runner = makeQueryRunner(
    groupByFactory,
    SegmentId.dummy(qindex.toString()),
    new QueryableIndexSegment(qindex, SegmentId.dummy(qindex.toString()))
  );
  runners.add(groupByFactory.getToolchest().preMergeQueryDecoration(runner));
 }
 return runners;
}

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

@Parameterized.Parameters
public static Collection<?> constructorFeeder()
{
 List<Object[]> argumentArrays = new ArrayList<>();
 for (SegmentWriteOutMediumFactory segmentWriteOutMediumFactory : SegmentWriteOutMediumFactory.builtInFactories()) {
  SchemalessIndexTest schemalessIndexTest = new SchemalessIndexTest(segmentWriteOutMediumFactory);
  final IncrementalIndex incrementalIndex = SchemalessIndexTest.getIncrementalIndex();
  final QueryableIndex persistedIncrementalIndex = TestIndex.persistRealtimeAndLoadMMapped(incrementalIndex);
  final QueryableIndex mergedIncrementalIndex = schemalessIndexTest.getMergedIncrementalIndex();
  argumentArrays.add(new Object[] {new IncrementalIndexSegment(incrementalIndex, null), false});
  argumentArrays.add(new Object[] {new QueryableIndexSegment(persistedIncrementalIndex, null), false});
  argumentArrays.add(new Object[] {new QueryableIndexSegment(mergedIncrementalIndex, null), true});
 }
 return argumentArrays;
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndex(Blackhole blackhole)
{
 QueryRunner<Row> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   SegmentId.dummy("qIndex"),
   new QueryableIndexSegment(queryableIndexes.get(0), SegmentId.dummy("qIndex"))
 );
 List<Row> results = GroupByBenchmark.runQuery(factory, runner, query);
 for (Row result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndex(Blackhole blackhole)
{
 final QueryRunner<Result<TimeseriesResultValue>> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   SegmentId.dummy("qIndex"),
   new QueryableIndexSegment(qIndexes.get(0), SegmentId.dummy("qIndex"))
 );
 List<Result<TimeseriesResultValue>> results = TimeseriesBenchmark.runQuery(factory, runner, query);
 for (Result<TimeseriesResultValue> result : results) {
  blackhole.consume(result);
 }
}

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

@Benchmark
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MICROSECONDS)
public void querySingleQueryableIndex(Blackhole blackhole)
{
 final QueryRunner<Result<TopNResultValue>> runner = QueryBenchmarkUtil.makeQueryRunner(
   factory,
   SegmentId.dummy("qIndex"),
   new QueryableIndexSegment(qIndexes.get(0), SegmentId.dummy("qIndex"))
 );
 List<Result<TopNResultValue>> results = TopNBenchmark.runQuery(factory, runner, query);
 for (Result<TopNResultValue> result : results) {
  blackhole.consume(result);
 }
}

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

@SuppressWarnings("unchecked")
public static QueryRunner makeMMappedQueryRunner(
  SegmentId segmentId,
  boolean rollup,
  QueryRunnerFactory factory
)
{
 QueryableIndex index = rollup ? TestIndex.getMMappedTestIndex() : TestIndex.getNoRollupMMappedTestIndex();
 return QueryRunnerTestHelper.makeQueryRunner(
   factory,
   segmentId,
   new QueryableIndexSegment(index, segmentId),
   null
 );
}