zipkin.internal.Nullable.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.7k)|赞(0)|评价(0)|浏览(106)

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

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);
}

相关文章

Nullable类方法