本文整理了Java中zipkin.internal.Util.toLowerHex()
方法的一些代码示例,展示了Util.toLowerHex()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Util.toLowerHex()
方法的具体详情如下:
包路径:zipkin.internal.Util
类名称:Util
方法名:toLowerHex
暂无
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
@Override public String toString() {
return "(" + table + "," + partitionKey + "," + Util.toLowerHex(traceId) + ")";
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch
@Override public ListenableFuture<List<Span>> getRawTrace(long traceIdHigh, long traceIdLow) {
String traceIdHex = Util.toLowerHex(strictTraceId ? traceIdHigh : 0L, traceIdLow);
return client.findSpans(catchAll, termQuery("traceId", traceIdHex));
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch-http
@Override
public void getRawTrace(long traceIdHigh, long traceIdLow, Callback<List<Span>> callback) {
String traceIdHex = Util.toLowerHex(strictTraceId ? traceIdHigh : 0L, traceIdLow);
SearchRequest request = SearchRequest.create(asList(allIndices), SPAN)
.term("traceId", traceIdHex);
submit(search.newCall(request, NULLABLE_SPANS), callback);
}
代码示例来源:origin: io.zipkin.sparkstreaming/zipkin-sparkstreaming
static void streamSpansToStorage(
JavaDStream<byte[]> stream,
ReadSpans readSpans,
AdjustAndConsumeSpansSharingTraceId adjustAndConsumeSpansSharingTraceId
) {
JavaDStream<Span> spans = stream.flatMap(readSpans);
// TODO: plug in some filter to drop spans regardless of trace ID
// spans = spans.filter(spanFilter);
JavaPairDStream<String, Iterable<Span>> tracesById = spans
.mapToPair(s -> new Tuple2<>(Util.toLowerHex(s.traceIdHigh, s.traceId), s))
.groupByKey();
tracesById.foreachRDD(rdd -> {
rdd.values().foreachPartition(adjustAndConsumeSpansSharingTraceId);
});
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-mysql
.traceId(toLowerHex(traceIdHi != null ? traceIdHi : 0L, traceIdLo))
.parentId(parentId != null ? toLowerHex(parentId) : null)
.id(toLowerHex(spanId));
内容来源于网络,如有侵权,请联系作者删除!