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

QueryRunner介绍

暂无

代码示例

代码示例来源：origin: io.druid/druid-processing

@Override
 public Sequence<T> call() throws Exception
 {
  //Note: this is assumed that baseRunner does most of the work eagerly on call to the
  //run() method and resulting sequence accumulate/yield is fast.
  return baseRunner.run(threadSafeQueryPlus, responseContext);
 }
}

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
 public Sequence<T> apply(final QueryRunner<T> input)
 {
  return input.run(query);
 }
}

代码示例来源：origin: io.druid/druid-processing

@Override
 public Sequence<T> apply(final QueryRunner<T> input)
 {
  return input.run(queryPlus, responseContext);
 }
}

代码示例来源：origin: com.n3twork.druid/druid-processing

public Sequence<T> run(QueryRunner<T> runner)
{
 return runner.run(this);
}

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
 public Sequence<T> call() throws Exception
 {
  return base.run(query);
 }
});

代码示例来源：origin: io.druid/druid-processing

@Override
 public Sequence<T> get()
 {
  return base.run(queryPlus, responseContext);
 }
}

代码示例来源：origin: io.druid/druid-server

@SuppressWarnings("unchecked")
private Sequence<T> getSimpleServerResults(
  final QueryRunner serverRunner,
  final MultipleSpecificSegmentSpec segmentsOfServerSpec
)
{
 return serverRunner.run(queryPlus.withQuerySegmentSpec(segmentsOfServerSpec), responseContext);
}

代码示例来源：origin: io.druid/druid-processing

public Sequence<T> run(QuerySegmentWalker walker, Map<String, Object> context)
 {
  return query.getRunner(walker).run(this, context);
 }
}

代码示例来源：origin: io.druid/druid-processing

@Override
 public Sequence<T> run(QueryPlus<T> queryPlus, Map<String, Object> responseContext)
 {
  return Sequences.withBaggage(runner.run(queryPlus, responseContext), closeable);
 }
};

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
 public Sequence<Row> run(Query<Row> input)
 {
  if (Boolean.valueOf((String) input.getContextValue(GROUP_BY_MERGE_KEY, "true"))) {
   return mergeGroupByResults(((GroupByQuery) input).withOverriddenContext(NO_MERGE_CONTEXT), runner);
  } else {
   return runner.run(input);
  }
 }
};

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
public Sequence<T> run(Query<T> query)
{
 if (query.getContextBySegment(false)) {
  return baseRunner.run(query);
 }
 return doRun(baseRunner, query);
}

代码示例来源：origin: io.druid/druid-processing

@Override
 public Sequence<T> apply(DataSource singleSource)
 {
  return baseRunner.run(
    queryPlus.withQuery(query.withDataSource(singleSource)),
    responseContext
  );
 }
}

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
 public Sequence<T> run(final Query<T> query)
 {
  final Closeable closeable = adapter.increment();
  try {
   final Sequence<T> baseSequence = factory.createRunner(adapter).run(query);

   return new ResourceClosingSequence<T>(baseSequence, closeable);
  }
  catch (RuntimeException e) {
   Closeables.closeQuietly(closeable);
   throw e;
  }
 }
}

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
 protected Sequence<Result<TimeBoundaryResultValue>> doRun(
   QueryRunner<Result<TimeBoundaryResultValue>> baseRunner, Query<Result<TimeBoundaryResultValue>> input
 )
 {
  TimeBoundaryQuery query = (TimeBoundaryQuery) input;
  return Sequences.simple(
    query.mergeResults(
      Sequences.toList(baseRunner.run(query), Lists.<Result<TimeBoundaryResultValue>>newArrayList())
    )
  );
 }
};

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
 public Sequence<T> run(final Query<T> query)
 {
  DataSource dataSource = query.getDataSource();
  if (dataSource instanceof QueryDataSource) {
   return run((Query<T>) ((QueryDataSource) dataSource).getQuery());
  } else {
   return baseRunner.run(query);
  }
 }
}

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
public Sequence<T> doRun(QueryRunner<T> baseRunner, Query<T> query)
{
 return CombiningSequence.create(baseRunner.run(query), makeOrdering(query), createMergeFn(query));
}

代码示例来源：origin: io.druid/druid-processing

@Override
 public Sequence<Row> run(QueryPlus<Row> queryPlus, Map<String, Object> responseContext)
 {
  if (QueryContexts.isBySegment(queryPlus.getQuery())) {
   return runner.run(queryPlus, responseContext);
  }
  final GroupByQuery groupByQuery = (GroupByQuery) queryPlus.getQuery();
  if (strategySelector.strategize(groupByQuery).doMergeResults(groupByQuery)) {
   return initAndMergeGroupByResults(
     groupByQuery,
     runner,
     responseContext
   );
  }
  return runner.run(queryPlus, responseContext);
 }
};

代码示例来源：origin: io.druid/druid-server

@Override
public Sequence run(QueryPlus queryPlus, Map responseContext)
{
 return baseRunner.run(
   QueryPlus.wrap((Query) withTimeoutAndMaxScatterGatherBytes(
     queryPlus.getQuery(),
     serverConfig
   )),
   responseContext
 );
}

代码示例来源：origin: io.druid/druid-processing

@Override
public Sequence<T> run(QueryPlus<T> queryPlus, Map<String, Object> responseContext)
{
 if (QueryContexts.isBySegment(queryPlus.getQuery())) {
  return baseRunner.run(queryPlus, responseContext);
 }
 return doRun(baseRunner, queryPlus, responseContext);
}

代码示例来源：origin: io.druid/druid-processing

@Override
 public Sequence<Row> run(QueryPlus<Row> queryPlus, Map<String, Object> responseContext)
 {
  QueryRunner<Row> rowQueryRunner = strategySelector.strategize((GroupByQuery) queryPlus.getQuery()).mergeRunners(
    queryExecutor,
    queryRunners
  );
  return rowQueryRunner.run(queryPlus, responseContext);
 }
};