本文整理了Java中zipkin2.storage.QueryRequest.limit
方法的一些代码示例,展示了QueryRequest.limit
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryRequest.limit
方法的具体详情如下:
包路径:zipkin2.storage.QueryRequest
类名称: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;
内容来源于网络,如有侵权,请联系作者删除!