• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

Java SpanId类的典型用法和代码示例

java 1次浏览

本文整理汇总了Java中org.apache.htrace.core.SpanId的典型用法代码示例。如果您正苦于以下问题:Java SpanId类的具体用法?Java SpanId怎么用?Java SpanId使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

SpanId类属于org.apache.htrace.core包,在下文中一共展示了SpanId类的23个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getFromOneDataNode

点赞 3

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
private Callable<ByteBuffer> getFromOneDataNode(final DNAddrPair datanode,
    final LocatedBlock block, final long start, final long end,
    final ByteBuffer bb,
    final Map<ExtendedBlock, Set<DatanodeInfo>> corruptedBlockMap,
    final int hedgedReadId) {
  final SpanId parentSpanId = Tracer.getCurrentSpanId();
  return new Callable<ByteBuffer>() {
    @Override
    public ByteBuffer call() throws Exception {
      byte[] buf = bb.array();
      int offset = bb.position();
      try (TraceScope ignored = dfsClient.getTracer().
          newScope("hedgedRead" + hedgedReadId, parentSpanId)) {
        actualGetFromOneDataNode(datanode, block, start, end, buf,
            offset, corruptedBlockMap);
        return bb;
      }
    }
  };
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:21,
代码来源:DFSInputStream.java

示例2: getTraceParents

点赞 3

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
/**
 * Get the trace parent spans for this packet.<p/>
 *
 * Will always be non-null.<p/>
 *
 * Protected by the DFSOutputStream dataQueue lock.
 */
public SpanId[] getTraceParents() {
  // Remove duplicates from the array.
  int len = traceParentsUsed;
  Arrays.sort(traceParents, 0, len);
  int i = 0, j = 0;
  SpanId prevVal = SpanId.INVALID;
  while (true) {
    if (i == len) {
      break;
    }
    SpanId val = traceParents[i];
    if (!val.equals(prevVal)) {
      traceParents[j] = val;
      j++;
      prevVal = val;
    }
    i++;
  }
  if (j < traceParents.length) {
    traceParents = Arrays.copyOf(traceParents, j);
    traceParentsUsed = traceParents.length;
  }
  return traceParents;
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:32,
代码来源:DFSPacket.java

示例3: testAddParentsGetParents

点赞 3

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Test
public void testAddParentsGetParents() throws Exception {
  DFSPacket p = new DFSPacket(null, maxChunksPerPacket,
                              0, 0, checksumSize, false);
  SpanId parents[] = p.getTraceParents();
  Assert.assertEquals(0, parents.length);
  p.addTraceParent(new SpanId(0, 123));
  p.addTraceParent(new SpanId(0, 123));
  parents = p.getTraceParents();
  Assert.assertEquals(1, parents.length);
  Assert.assertEquals(new SpanId(0, 123), parents[0]);
  parents = p.getTraceParents(); // test calling 'get' again.
  Assert.assertEquals(1, parents.length);
  Assert.assertEquals(new SpanId(0, 123), parents[0]);
  p.addTraceParent(new SpanId(0, 1));
  p.addTraceParent(new SpanId(0, 456));
  p.addTraceParent(new SpanId(0, 789));
  parents = p.getTraceParents();
  Assert.assertEquals(4, parents.length);
  Assert.assertEquals(new SpanId(0, 1), parents[0]);
  Assert.assertEquals(new SpanId(0, 123), parents[1]);
  Assert.assertEquals(new SpanId(0, 456), parents[2]);
  Assert.assertEquals(new SpanId(0, 789), parents[3]);
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:25,
代码来源:TestDFSPacket.java

示例4: testSimpleTraces

点赞 3

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Test
public void testSimpleTraces() throws IOException, InterruptedException {
  FakeZipkinTransport transport = new FakeZipkinTransport();
  Tracer tracer = newTracer(transport);
  Span rootSpan = new MilliSpan.Builder().
      description("root").
      spanId(new SpanId(100, 100)).
      tracerId("test").
      begin(System.currentTimeMillis()).
      build();
  TraceScope rootScope = tracer.newScope("root");
  TraceScope innerOne = tracer.newScope("innerOne");
  TraceScope innerTwo = tracer.newScope("innerTwo");
  innerTwo.close();
  Assert.assertTrue(transport.nextMessageAsSpan().getName().contains("innerTwo"));
  innerOne.close();
  Assert.assertTrue(transport.nextMessageAsSpan().getName().contains("innerOne"));
  rootSpan.addKVAnnotation("foo", "bar");
  rootSpan.addTimelineAnnotation("timeline");
  rootScope.close();
  Assert.assertTrue(transport.nextMessageAsSpan().getName().contains("root"));
  tracer.close();
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:24,
代码来源:TestZipkinSpanReceiver.java

示例5: testHTraceToZipkin

点赞 3

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Test
public void testHTraceToZipkin() throws IOException {
  Span rootSpan = new MilliSpan.Builder().
          description(ROOT_SPAN_DESC).
          parents(new SpanId[] { } ).
          spanId(new SpanId(100, 100)).
          tracerId("test").
          begin(System.currentTimeMillis()).
          build();
  Span innerOne = rootSpan.child("Some good work");
  Span innerTwo = innerOne.child("Some more good work");
  innerTwo.stop();
  innerOne.stop();
  rootSpan.addKVAnnotation("foo", "bar");
  rootSpan.addTimelineAnnotation("timeline");
  rootSpan.stop();

  for (Span s : new Span[] {rootSpan, innerOne, innerTwo}) {
    com.twitter.zipkin.gen.Span zs =
        new HTraceToZipkinConverter(12345, (short) 12).convert(s);
    assertSpansAreEquivalent(s, zs);
  }
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:24,
代码来源:TestHTraceSpanToZipkinSpan.java

示例6: testSimpleTraces

点赞 3

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Test(timeout=120000)
public void testSimpleTraces() throws IOException, InterruptedException {
  Tracer tracer = newTracer();
  Span rootSpan = new MilliSpan.Builder().
      description("root").
      spanId(new SpanId(100, 100)).
      tracerId("test").
      begin(System.currentTimeMillis()).
      build();
  TraceScope rootScope = tracer.newScope("root");
  TraceScope innerOne = tracer.newScope("innerOne");
  TraceScope innerTwo = tracer.newScope("innerTwo");
  innerTwo.close();
  Assert.assertTrue(flumeServer.nextEventBodyAsString().contains("innerTwo"));
  innerOne.close();
  Assert.assertTrue(flumeServer.nextEventBodyAsString().contains("innerOne"));
  rootSpan.addKVAnnotation("foo", "bar");
  rootSpan.addTimelineAnnotation("timeline");
  rootScope.close();
  Assert.assertTrue(flumeServer.nextEventBodyAsString().contains("root"));
  tracer.close();
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:23,
代码来源:TestFlumeSpanReceiver.java

示例7: releaseShortCircuitFds

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Override
public void releaseShortCircuitFds(SlotId slotId) throws IOException {
  ReleaseShortCircuitAccessRequestProto.Builder builder =
      ReleaseShortCircuitAccessRequestProto.newBuilder().
          setSlotId(PBHelperClient.convert(slotId));
  SpanId spanId = Tracer.getCurrentSpanId();
  if (spanId.isValid()) {
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder().
        setTraceId(spanId.getHigh()).
        setParentId(spanId.getLow()));
  }
  ReleaseShortCircuitAccessRequestProto proto = builder.build();
  send(out, Op.RELEASE_SHORT_CIRCUIT_FDS, proto);
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:15,
代码来源:Sender.java

示例8: requestShortCircuitShm

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Override
public void requestShortCircuitShm(String clientName) throws IOException {
  ShortCircuitShmRequestProto.Builder builder =
      ShortCircuitShmRequestProto.newBuilder().
          setClientName(clientName);
  SpanId spanId = Tracer.getCurrentSpanId();
  if (spanId.isValid()) {
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder().
        setTraceId(spanId.getHigh()).
        setParentId(spanId.getLow()));
  }
  ShortCircuitShmRequestProto proto = builder.build();
  send(out, Op.REQUEST_SHORT_CIRCUIT_SHM, proto);
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:15,
代码来源:Sender.java

示例9: buildBaseHeader

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
static BaseHeaderProto buildBaseHeader(ExtendedBlock blk,
    Token<BlockTokenIdentifier> blockToken) {
  BaseHeaderProto.Builder builder =  BaseHeaderProto.newBuilder()
      .setBlock(PBHelperClient.convert(blk))
      .setToken(PBHelperClient.convert(blockToken));
  SpanId spanId = Tracer.getCurrentSpanId();
  if (spanId.isValid()) {
    builder.setTraceInfo(DataTransferTraceInfoProto.newBuilder()
        .setTraceId(spanId.getHigh())
        .setParentId(spanId.getLow()));
  }
  return builder.build();
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:14,
代码来源:DataTransferProtoUtil.java

示例10: fromProto

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
public static SpanId fromProto(DataTransferTraceInfoProto proto) {
  if ((proto != null) && proto.hasTraceId() &&
        proto.hasParentId()) {
    return new SpanId(proto.getTraceId(), proto.getParentId());
  }
  return null;
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:8,
代码来源:DataTransferProtoUtil.java

示例11: addTraceParent

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
public void addTraceParent(SpanId id) {
  if (!id.isValid()) {
    return;
  }
  if (traceParentsUsed == traceParents.length) {
    int newLength = (traceParents.length == 0) ? 8 :
        traceParents.length * 2;
    traceParents = Arrays.copyOf(traceParents, newLength);
  }
  traceParents[traceParentsUsed] = id;
  traceParentsUsed++;
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:13,
代码来源:DFSPacket.java

示例12: continueTraceSpan

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
private TraceScope continueTraceSpan(DataTransferTraceInfoProto proto,
                                     String description) {
  TraceScope scope = null;
  SpanId spanId = fromProto(proto);
  if (spanId != null) {
    scope = tracer.newScope(description, spanId);
  }
  return scope;
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:10,
代码来源:Receiver.java

示例13: testCongestionBackoff

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Test
public void testCongestionBackoff() throws IOException {
  DfsClientConf dfsClientConf = mock(DfsClientConf.class);
  DFSClient client = mock(DFSClient.class);
  when(client.getConf()).thenReturn(dfsClientConf);
  when(client.getTracer()).thenReturn(FsTracer.get(new Configuration()));
  client.clientRunning = true;
  DataStreamer stream = new DataStreamer(
      mock(HdfsFileStatus.class),
      mock(ExtendedBlock.class),
      client,
      "foo", null, null, null, null, null);

  DataOutputStream blockStream = mock(DataOutputStream.class);
  doThrow(new IOException()).when(blockStream).flush();
  Whitebox.setInternalState(stream, "blockStream", blockStream);
  Whitebox.setInternalState(stream, "stage",
                            BlockConstructionStage.PIPELINE_CLOSE);
  @SuppressWarnings("unchecked")
  LinkedList<DFSPacket> dataQueue = (LinkedList<DFSPacket>)
      Whitebox.getInternalState(stream, "dataQueue");
  @SuppressWarnings("unchecked")
  ArrayList<DatanodeInfo> congestedNodes = (ArrayList<DatanodeInfo>)
      Whitebox.getInternalState(stream, "congestedNodes");
  congestedNodes.add(mock(DatanodeInfo.class));
  DFSPacket packet = mock(DFSPacket.class);
  when(packet.getTraceParents()).thenReturn(new SpanId[] {});
  dataQueue.add(packet);
  stream.run();
  Assert.assertTrue(congestedNodes.isEmpty());
}
 

开发者ID:aliyun-beta,
项目名称:aliyun-oss-hadoop-fs,
代码行数:32,
代码来源:TestDFSOutputStream.java

示例14: randomSpan

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
public static Span randomSpan(Random rand) {
  MilliSpan.Builder builder = new MilliSpan.Builder();
  builder.spanId(
        new SpanId(nonZeroRandomLong(rand), nonZeroRandomLong(rand)));
  builder.begin(positiveRandomLong(rand));
  builder.end(positiveRandomLong(rand));
  builder.description(randomString(rand));
  builder.tracerId(randomString(rand));
  int numParents = rand.nextInt(4);
  SpanId[] parents = new SpanId[numParents];
  for (int i = 0; i < numParents; i++) {
    parents[i] =
        new SpanId(nonZeroRandomLong(rand), nonZeroRandomLong(rand));
  }
  builder.parents(parents);
  int numTraceInfos = rand.nextInt(4);
  Map<String, String> traceInfo = new HashMap<String, String>(numTraceInfos);
  for (int i = 0; i < numTraceInfos; i++) {
    traceInfo.put(randomString(rand), randomString(rand));
  }
  builder.traceInfo(traceInfo);
  int numTimelineAnnotations = rand.nextInt(4);
  List<TimelineAnnotation> timeline =
      new LinkedList<TimelineAnnotation>();
  for (int i = 0; i < numTimelineAnnotations; i++) {
    timeline.add(new TimelineAnnotation(positiveRandomLong(rand),
          randomString(rand)));
  }
  builder.timeline(timeline);
  return builder.build();
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:32,
代码来源:TestUtil.java

示例15: readSpanId

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
static SpanId readSpanId(MessageUnpacker unpacker) throws IOException {
  int alen = unpacker.unpackBinaryHeader();
  if (alen != SPAN_ID_BYTE_LENGTH) {
    throw new IOException("Invalid length given for spanID array.  " +
        "Expected " + SPAN_ID_BYTE_LENGTH + "; got " + alen);
  }
  byte[] payload = new byte[SPAN_ID_BYTE_LENGTH];
  unpacker.readPayload(payload);
  return new SpanId(
      ((payload[ 7] & 0xffL) <<  0) |
      ((payload[ 6] & 0xffL) <<  8) |
      ((payload[ 5] & 0xffL) << 16) |
      ((payload[ 4] & 0xffL) << 24) |
      ((payload[ 3] & 0xffL) << 32) |
      ((payload[ 2] & 0xffL) << 40) |
      ((payload[ 1] & 0xffL) << 48) |
      ((payload[ 0] & 0xffL) << 56),
      ((payload[15] & 0xffL) <<  0) |
      ((payload[14] & 0xffL) <<  8) |
      ((payload[13] & 0xffL) << 16) |
      ((payload[12] & 0xffL) << 24) |
      ((payload[11] & 0xffL) << 32) |
      ((payload[10] & 0xffL) << 40) |
      ((payload[ 9] & 0xffL) << 48) |
      ((payload[ 8] & 0xffL) << 56)
    );
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:28,
代码来源:PackedBuffer.java

示例16: getSpan

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
public Span getSpan(SpanId spanId) throws Exception {
  ContentResponse response = httpClient.GET(
      new URI(String.format("http://%s/span/%s",
          httpAddr, spanId.toString())));
  Assert.assertEquals("application/json", response.getMediaType());
  String responseJson = response.getContentAsString().trim();
  if (responseJson.isEmpty()) {
    return null;
  }
  return MilliSpan.fromJson(responseJson);
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:12,
代码来源:HTracedProcess.java

示例17: find

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
public List<Span> find(SpanId parentId) {
  LinkedList<Span> spans = parentToSpans.get(parentId);
  if (spans == null) {
    return new LinkedList<Span>();
  }
  return spans;
}
 

开发者ID:apache,
项目名称:hbase,
代码行数:8,
代码来源:TraceTree.java

示例18: getParents

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Override
public SpanId[] getParents() {
  return (span.getParentId() == 0L) ?
    (new SpanId[] {}) :
    (new SpanId[] { new SpanId(span.getTraceId(), span.getParentId()) });
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:7,
代码来源:TestHBaseSpanReceiver.java

示例19: setParents

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Override
public void setParents(SpanId[] parents) {
  throw new UnsupportedOperationException();
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:5,
代码来源:TestHBaseSpanReceiver.java

示例20: getSpanId

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Override
public SpanId getSpanId() {
  return new SpanId(span.getTraceId(), span.getSpanId());
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:5,
代码来源:TestHBaseSpanReceiver.java

示例21: testHTraceAnnotationTimestamp

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
@Test
public void testHTraceAnnotationTimestamp() throws IOException, InterruptedException {

  String tracerId = "testHTraceAnnotationTimestamp";
  long startTime = System.currentTimeMillis() * 1000;
  Span ms = new MilliSpan.Builder().
      description(tracerId).parents(new SpanId[] { }).
      spanId(new SpanId(2L, 2L)).
      tracerId(tracerId).
      begin(System.currentTimeMillis()).
      build();

  Thread.sleep(500);
  long annoStartTime = System.currentTimeMillis() * 1000;
  Thread.sleep(500);
  ms.addTimelineAnnotation("anno");
  Thread.sleep(500);
  long annoEndTime = System.currentTimeMillis() * 1000;
  Thread.sleep(500);
  ms.stop();
  long endTime = System.currentTimeMillis() * 1000;



  com.twitter.zipkin.gen.Span zs = new HTraceToZipkinConverter(12345, (short) -1).convert(ms);

  // Check to make sure that all times are in the proper order.
  for (com.twitter.zipkin.gen.Annotation annotation : zs.getAnnotations()) {
    // CS and SR should be before the annotation
    // the annotation should be in between annotationStart and annotationEnd times
    // SS and CR should be after annotationEnd and before endtime.
    if (annotation.getValue().equals(zipkinCoreConstants.CLIENT_SEND)
        || annotation.getValue().equals(zipkinCoreConstants.SERVER_RECV)) {
      assertTrue(startTime <= annotation.getTimestamp());
      assertTrue(annotation.getTimestamp() <= annoStartTime);
    } else if (annotation.getValue().equals(zipkinCoreConstants.CLIENT_RECV)
        || annotation.getValue().equals(zipkinCoreConstants.SERVER_SEND)) {
      assertTrue(annoEndTime <= annotation.getTimestamp());
      assertTrue(annotation.getTimestamp() <= endTime);
    } else {
      assertTrue(annoStartTime <= annotation.getTimestamp());
      assertTrue(annotation.getTimestamp() <= annoEndTime);
      assertTrue(annotation.getTimestamp() <= endTime);
    }
  }
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:47,
代码来源:TestHTraceSpanToZipkinSpan.java

示例22: writeSpanId

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
private void writeSpanId(SpanId spanId) throws IOException {
  longToBigEndian(temp, 0, spanId.getHigh());
  longToBigEndian(temp, 8, spanId.getLow());
  packer.packBinaryHeader(SPAN_ID_BYTE_LENGTH);
  packer.writePayload(temp, 0, SPAN_ID_BYTE_LENGTH);
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:7,
代码来源:PackedBuffer.java

示例23: readSpan

点赞 2

import org.apache.htrace.core.SpanId; //导入依赖的package包/类
/**
 * Read a span.  Used in unit tests.  Not optimized.
 */
static Span readSpan(MessageUnpacker unpacker) throws IOException {
  int numEntries = unpacker.unpackMapHeader();
  MilliSpan.Builder builder = new MilliSpan.Builder();
  while (--numEntries >= 0) {
    String key = unpacker.unpackString();
    if (key.length() != 1) {
      throw new IOException("Unknown key " + key);
    }
    switch (key.charAt(0)) {
      case 'a':
        builder.spanId(readSpanId(unpacker));
        break;
      case 'b':
        builder.begin(unpacker.unpackLong());
        break;
      case 'e':
        builder.end(unpacker.unpackLong());
        break;
      case 'd':
        builder.description(unpacker.unpackString());
        break;
      case 'r':
        builder.tracerId(unpacker.unpackString());
        break;
      case 'p':
        int numParents = unpacker.unpackArrayHeader();
        SpanId[] parents = new SpanId[numParents];
        for (int i = 0; i < numParents; i++) {
          parents[i] = readSpanId(unpacker);
        }
        builder.parents(parents);
        break;
      case 'n':
        int mapEntries = unpacker.unpackMapHeader();
        HashMap<String, String> entries =
            new HashMap<String, String>(mapEntries);
        for (int i = 0; i < mapEntries; i++) {
          String k = unpacker.unpackString();
          String v = unpacker.unpackString();
          entries.put(k, v);
        }
        builder.traceInfo(entries);
        break;
      case 't':
        int listEntries = unpacker.unpackArrayHeader();
        ArrayList<TimelineAnnotation> list =
            new ArrayList<TimelineAnnotation>(listEntries);
        for (int i = 0; i < listEntries; i++) {
          int timelineObjectSize = unpacker.unpackMapHeader();
          long time = 0;
          String msg = "";
          for (int j = 0; j < timelineObjectSize; j++) {
            String tlKey = unpacker.unpackString();
            if (tlKey.length() != 1) {
              throw new IOException("Unknown timeline map key " + tlKey);
            }
            switch (tlKey.charAt(0)) {
              case 't':
                time = unpacker.unpackLong();
                break;
              case 'm':
                msg = unpacker.unpackString();
                break;
              default:
                throw new IOException("Unknown timeline map key " + tlKey);
            }
          }
          list.add(new TimelineAnnotation(time, msg));
        }
        builder.timeline(list);
        break;
      default:
        throw new IOException("Unknown key " + key);
    }
  }
  return builder.build();
}
 

开发者ID:apache,
项目名称:incubator-htrace,
代码行数:81,
代码来源:PackedBuffer.java


版权声明:本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。
喜欢 (0)