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

Query.getContext介绍

暂无

代码示例

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

@Override
public void context(QueryType query)
{
 try {
  setDimension(
    "context",
    jsonMapper.writeValueAsString(query.getContext() == null ? ImmutableMap.of() : query.getContext())
  );
 }
 catch (JsonProcessingException e) {
  throw new RuntimeException(e);
 }
}

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

MDC.put("descending", Boolean.toString(query.isDescending()));
if (setContextMDC) {
 final Iterable<Map.Entry<String, Object>> entries = query.getContext() == null
                           ? ImmutableList.<Map.Entry<String, Object>>of()
                           : query.getContext().entrySet();
 for (Map.Entry<String, Object> entry : entries) {
  MDC.put(entry.getKey(), entry.getValue() == null ? "NULL" : entry.getValue().toString());

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

Sequence<T> run(final UnaryOperator<TimelineLookup<String, ServerSelector>> timelineConverter)
{
 @Nullable TimelineLookup<String, ServerSelector> timeline = serverView.getTimeline(query.getDataSource());
 if (timeline == null) {
  return Sequences.empty();
 }
 timeline = timelineConverter.apply(timeline);
 if (uncoveredIntervalsLimit > 0) {
  computeUncoveredIntervals(timeline);
 }
 final Set<ServerToSegment> segments = computeSegmentsToQuery(timeline);
 @Nullable final byte[] queryCacheKey = computeQueryCacheKey();
 if (query.getContext().get(QueryResource.HEADER_IF_NONE_MATCH) != null) {
  @Nullable final String prevEtag = (String) query.getContext().get(QueryResource.HEADER_IF_NONE_MATCH);
  @Nullable final String currentEtag = computeCurrentEtag(segments, queryCacheKey);
  if (currentEtag != null && currentEtag.equals(prevEtag)) {
   return Sequences.empty();
  }
 }
 final List<Pair<Interval, byte[]>> alreadyCachedResults = pruneSegmentsWithCachedResults(queryCacheKey, segments);
 final SortedMap<DruidServer, List<SegmentDescriptor>> segmentsByServer = groupSegmentsByServer(segments);
 return new LazySequence<>(() -> {
  List<Sequence<T>> sequencesByInterval = new ArrayList<>(alreadyCachedResults.size() + segmentsByServer.size());
  addSequencesFromCache(sequencesByInterval, alreadyCachedResults);
  addSequencesFromServer(sequencesByInterval, segmentsByServer);
  return Sequences
    .simple(sequencesByInterval)
    .flatMerge(seq -> seq, query.getResultOrdering());
 });
}

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

if (((QueryDataSource) dataSource).getQuery().getContext() != null) {
 subqueryContext.putAll(((QueryDataSource) dataSource).getQuery().getContext());