本文整理了Java中zipkin.internal.Nullable.<init>()
方法的一些代码示例,展示了Nullable.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Nullable.<init>()
方法的具体详情如下:
包路径:zipkin.internal.Nullable
类名称:Nullable
方法名:<init>
暂无
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
/**
* Name of the datacenter that will be considered "local" for latency load balancing. When
* unset, load-balancing is round-robin.
*/
public Builder localDc(@Nullable String localDc) {
this.localDc = localDc;
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
/** Will throw an exception on startup if authentication fails. No default. */
public Builder password(@Nullable String password) {
this.password = password;
return this;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
public Factory(Session session, @Nullable Integer indexTtl,
@Nullable ConcurrentMap<PartitionKeyToTraceId, Pair<Long>> sharedState) {
this.session = session;
this.indexTtl = indexTtl;
this.sharedState = sharedState;
}
代码示例来源:origin: io.zipkin.java/spanstore-guava
/**
* Version of {@link zipkin.SpanStore#getDependencies} that returns {@link ListenableFuture}.
*/
ListenableFuture<List<DependencyLink>> getDependencies(long endTs, @Nullable Long lookback);
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-mysql
DependencyLinkV2SpanIterator(PeekingIterator<Record> delegate, @Nullable Long traceIdHi,
long traceIdLo) {
this.delegate = delegate;
this.traceIdHi = traceIdHi;
this.traceIdLo = traceIdLo;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch-http
@Override
public void toJson(JsonWriter writer, @Nullable BinaryAnnotation value) throws IOException {
throw new UnsupportedOperationException();
}
};
代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch-http
@Override
public void toJson(JsonWriter writer, @Nullable Endpoint value) throws IOException {
throw new UnsupportedOperationException();
}
}.nullSafe();
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
@Override public Set<Object> apply(@Nullable List<Map<Object, ?>> input) {
Set<Object> traceIds = Sets.newLinkedHashSet(input.get(0).keySet());
for (int i = 1; i < input.size(); i++) {
traceIds.retainAll(input.get(i).keySet());
}
return traceIds;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
@Override public List<String> apply(@Nullable ResultSet input) {
Set<String> spanNames = new HashSet<>();
for (Row row : input) {
spanNames.add(row.getString("span_name"));
}
return Ordering.natural().sortedCopy(spanNames);
}
}
代码示例来源:origin: io.servicecomb/handler-tracing-zipkin
@Nullable
@Override
public Integer statusCode(@Nonnull Response response) {
return response.getStatusCode();
}
}
代码示例来源:origin: io.servicecomb/handler-tracing-zipkin
@Nullable
@Override
public Integer statusCode(@Nonnull Response response) {
return response.getStatusCode();
}
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
@Override public Map<Long, Long> apply(@Nullable ResultSet input) {
Map<Long, Long> traceIdsToTimestamps = new LinkedHashMap<>();
for (Row row : input) {
traceIdsToTimestamps.put(row.getLong("trace_id"),
timestampCodec.deserialize(row, "ts"));
}
return traceIdsToTimestamps;
}
}
代码示例来源:origin: io.servicecomb/handler-tracing-zipkin
@Nullable
@Override
public String method(@Nonnull Invocation invocation) {
return invocation.getOperationMeta().getHttpMethod();
}
代码示例来源:origin: io.servicecomb/handler-tracing-zipkin
@Nullable
@Override
public String method(@Nonnull Invocation invocation) {
return invocation.getOperationMeta().getHttpMethod();
}
代码示例来源:origin: io.servicecomb/handler-tracing-zipkin
@Nullable
@Override
public String path(@Nonnull Invocation request) {
return request.getOperationMeta().getOperationPath();
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
@Override public List<DependencyLink> apply(@Nullable ResultSet rs) {
ImmutableList.Builder<DependencyLink> unmerged = ImmutableList.builder();
for (Row row : rs) {
ByteBuffer encodedDayOfDependencies = row.getBytes("dependencies");
for (DependencyLink link : Dependencies.fromThrift(encodedDayOfDependencies).links) {
unmerged.add(link);
}
}
return DependencyLinker.merge(unmerged.build());
}
代码示例来源:origin: io.zipkin.java/storage-guava
@Override public ListenableFuture<List<DependencyLink>> getDependencies(long endTs,
@Nullable Long lookback) {
CallbackListenableFuture<List<DependencyLink>> result = new CallbackListenableFuture<>();
delegate.getDependencies(endTs, lookback, result);
return result;
}
代码示例来源:origin: io.zipkin.java/spanstore-guava
@Override public ListenableFuture<List<DependencyLink>> getDependencies(long endTs,
@Nullable Long lookback) {
CallbackListenableFuture<List<DependencyLink>> result = new CallbackListenableFuture<>();
asyncSpanStore.getDependencies(endTs, lookback, result);
return result;
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-cassandra
@Override public List<Span> apply(@Nullable ResultSet input) {
List<Span> result = new ArrayList<>(input.getAvailableWithoutFetching());
for (Row row : input) {
result.add(Codec.THRIFT.readSpan(row.getBytes("span")));
}
return result;
}
}
代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch-http
@Override public void onSuccess(@Nullable List<String> value) {
if (!value.isEmpty()) callback.onSuccess(value);
// Special cased code until sites update their collectors. What this does is do a more
// expensive nested query to get service names when the servicespan type returns nothing.
SearchRequest.Filters filters = new SearchRequest.Filters();
filters.addRange("timestamp_millis", beginMillis, endMillis);
SearchRequest request = SearchRequest.create(indices, SPAN).filters(filters)
.addAggregation(Aggregation.nestedTerms("annotations.endpoint.serviceName"))
.addAggregation(Aggregation.nestedTerms("binaryAnnotations.endpoint.serviceName"));
submit(search.newCall(request, KEYS), callback);
}
内容来源于网络,如有侵权,请联系作者删除!