io.druid.query.Query.withQuerySegmentSpec()方法的使用及代码示例

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

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

Query.withQuerySegmentSpec介绍

暂无

代码示例

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

/**
 * Equivalent of withQuery(getQuery().withQuerySegmentSpec(spec)).
 */
public QueryPlus<T> withQuerySegmentSpec(QuerySegmentSpec spec)
{
 return new QueryPlus<>(query.withQuerySegmentSpec(spec), queryMetrics);
}

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

@Override
 public QueryRunner<T> apply(SegmentDescriptor spec)
 {
  final FireChief retVal = partitionChiefs.get(spec.getPartitionNumber());
  return retVal == null
     ? new NoopQueryRunner<T>()
     : retVal.getQueryRunner(query.withQuerySegmentSpec(new SpecificSegmentSpec(spec)));
 }
}

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

@Override
public Sequence<T> run(final Query<T> input)
 final Query<T> query = input.withQuerySegmentSpec(specificSpec);

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

resultSeqToAdd = clientQueryable.run(query.withQuerySegmentSpec(segmentSpec));
} else {
 resultSeqToAdd = toolChest.mergeSequences(
   Sequences.map(
     clientQueryable.run(rewrittenQuery.withQuerySegmentSpec(segmentSpec)),
     new Function<Object, Sequence<T>>()

相关文章