zipkin2.storage.QueryRequest.limit()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(2.4k)|赞(0)|评价(0)|浏览(76)

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

QueryRequest.limit介绍

[英]Maximum number of traces to return. Defaults to 10
[中]要返回的最大记录道数。默认为10

代码示例

代码示例来源:origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

SelectTracesByIds(Factory factory, QueryRequest request) {
 this.factory = factory;
 this.limit = request.limit();
 // Cassandra always looks up traces by 64-bit trace ID, so we have to unconditionally filter
 // when strict trace ID is enabled.
 this.filter = factory.strictTraceId ? FilterTraces.create(request) : null;
}

代码示例来源:origin: io.zipkin.zipkin2/zipkin-storage-cassandra

SelectSpansByTraceIds(Factory factory, QueryRequest request) {
 this.factory = factory;
 this.limit = request.limit();
 // Cassandra always looks up traces by 64-bit trace ID, so we have to unconditionally filter
 // when strict trace ID is enabled.
 this.filter = factory.strictTraceId ? FilterTraces.create(request) : null;
}

代码示例来源:origin: io.zipkin.zipkin2/zipkin

synchronized Call<List<List<Span>>> getTraces(QueryRequest request, boolean strictTraceId) {
 Set<String> traceIdsInTimerange = traceIdsDescendingByTimestamp(request);
 if (traceIdsInTimerange.isEmpty()) return Call.emptyList();
 List<List<Span>> result = new ArrayList<>();
 for (Iterator<String> lowTraceId = traceIdsInTimerange.iterator();
  lowTraceId.hasNext() && result.size() < request.limit(); ) {
  List<Span> next = spansByTraceId(lowTraceId.next());
  if (!request.test(next)) continue;
  if (!strictTraceId) {
   result.add(next);
   continue;
  }
  // re-run the query as now spans are strictly grouped
  for (List<Span> strictTrace : strictByTraceId(next)) {
   if (request.test(strictTrace)) result.add(strictTrace);
  }
 }
 return Call.create(result);
}

代码示例来源:origin: io.github.jeqo.zipkin/zipkin-storage-kafka

groupingSearch.setGroupSort(sort);
TopGroups<BytesRef> docs =
  groupingSearch.search(indexSearcher, query, 0, queryRequest.limit());

代码示例来源:origin: io.zipkin.zipkin2/zipkin-storage-cassandra

final int traceIndexFetchSize = request.limit() * indexFetchMultiplier;
List<Call<Map<String, Long>>> callsToIntersect = new ArrayList<>();

代码示例来源:origin: io.zipkin.zipkin2/zipkin-storage-cassandra-v1

"getTraces with duration is unsupported. Upgrade to the new cassandra3 schema.");
final int traceIndexFetchSize = request.limit() * indexFetchMultiplier;

相关文章