com.google.flatbuffers.FlatBufferBuilder.dataBuffer()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(121)

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

FlatBufferBuilder.dataBuffer介绍

[英]Get the ByteBuffer representing the FlatBuffer. Only call this after you've called finish(). The actual data starts at the ByteBuffer's current position, not necessarily at 0.
[中]获取表示FlatBuffer的ByteBuffer。只有在调用“finish（）”之后才调用此函数。实际数据从ByteBuffer的当前位置开始，不一定在“0”处。

代码示例

代码示例来源：origin: deeplearning4j/nd4j

bufferBuilder.finish(fg);
return bufferBuilder.dataBuffer();

代码示例来源：origin: davidmoten/rtree

private static <T, S extends Geometry> Node_ createNode(List<Entry<T, S>> entries,
    Func1<? super T, byte[]> serializer) {
  FlatBufferBuilder builder = new FlatBufferBuilder(0);
  builder.finish(FlatBuffersHelper.addEntries(entries, builder, serializer));
  return Node_.getRootAsNode_(builder.dataBuffer());
}

代码示例来源：origin: davidmoten/rtree

Tree_.finishTree_Buffer(builder, t);
ByteBuffer bb = builder.dataBuffer();
os.write(bb.array(), bb.position(), bb.remaining());

代码示例来源：origin: locationtech/geogig

public byte[] encode(@NonNull RevObject o) {
  FlatBufferBuilder fbb = new FlatBufferBuilder();
  encode(o, fbb);
  ByteBuffer dataBuffer = fbb.dataBuffer();
  byte[] array = new byte[dataBuffer.remaining()];
  dataBuffer.get(array);
  return array;
}

代码示例来源：origin: locationtech/geogig

public @Override @NonNull RevCommit createCommit(@NonNull ObjectId id, @NonNull ObjectId treeId,
    @NonNull List<ObjectId> parents, @NonNull RevPerson author,
    @NonNull RevPerson committer, @NonNull String message) {
  if (parents.indexOf(null) > -1) {
    throw new NullPointerException("null parent at index " + parents.indexOf(null));
  }
  FlatBufferBuilder fbb = newBuilder();
  int objOffset = encoder.writeCommit(fbb, treeId, parents, author, committer, message);
  encoder.writeRevisionObject(ObjectType.Commit, objOffset, fbb);
  return (RevCommit) encoder.decode(id, copy(fbb.dataBuffer()));
}

代码示例来源：origin: locationtech/geogig

public @Override @NonNull RevTag createTag(@NonNull ObjectId id, @NonNull String name,
    @NonNull ObjectId commitId, @NonNull String message, @NonNull RevPerson tagger) {
  FlatBufferBuilder fbb = newBuilder();
  int objOffset = encoder.writeTag(fbb, name, commitId, message, tagger);
  encoder.writeRevisionObject(ObjectType.Tag, objOffset, fbb);
  return (RevTag) encoder.decode(id, copy(fbb.dataBuffer()));
}

代码示例来源：origin: org.apache.arrow/arrow-vector

public byte[] toByteArray() {
 FlatBufferBuilder builder = new FlatBufferBuilder();
 int schemaOffset = this.getSchema(builder);
 builder.finish(schemaOffset);
 ByteBuffer bb = builder.dataBuffer();
 byte[] bytes = new byte[bb.remaining()];
 bb.get(bytes);
 return bytes;
}

代码示例来源：origin: locationtech/geogig

public @Override @NonNull RevTree createTree(final @NonNull ObjectId id, final long size,
    @NonNull List<Node> trees, @NonNull List<Node> features) {
  FlatBufferBuilder fbb = newBuilder();
  int objOffset = encoder.writeLeafTree(fbb, size, trees, features);
  encoder.writeRevisionObject(ObjectType.LeafTree, objOffset, fbb);
  return (RevTree) encoder.decode(id, copy(fbb.dataBuffer()));
}

代码示例来源：origin: locationtech/geogig

public @Override @NonNull RevTree createTree(final @NonNull ObjectId id, final long size,
    final int childTreeCount, @NonNull SortedSet<Bucket> buckets) {
  if (size < 0L) {
    throw new IllegalArgumentException("Cannot create a tree with negative size: " + size);
  }
  if (childTreeCount < 0L) {
    throw new IllegalArgumentException(
        "Cannot create a tree with negative child tree count: " + childTreeCount);
  }
  FlatBufferBuilder fbb = newBuilder();
  int objOffset = encoder.writeNodeTree(fbb, size, childTreeCount, buckets);
  encoder.writeRevisionObject(ObjectType.NodeTree, objOffset, fbb);
  return (RevTree) encoder.decode(id, copy(fbb.dataBuffer()));
}

代码示例来源：origin: locationtech/geogig

public @Override @NonNull ValueArray createValueArray(@NonNull List<Object> values) {
  FlatBufferBuilder fbb = newBuilder();
  encoder.writeValueArray(fbb, values);
  return encoder.decodeValueArray(copy(fbb.dataBuffer()));
}

代码示例来源：origin: locationtech/geogig

public @Override @NonNull RevFeature createFeature(@NonNull ObjectId id,
    @NonNull List<Object> values) {
  FlatBufferBuilder fbb = newBuilder();
  int objOffset = encoder.writeFeature(fbb, values);
  encoder.writeRevisionObject(ObjectType.Feature, objOffset, fbb);
  return (RevFeature) encoder.decode(id, copy(fbb.dataBuffer()));
}

代码示例来源：origin: locationtech/geogig

public @Override void write(@NonNull RevObject o, @NonNull OutputStream out)
    throws IOException {
  final ByteBuffer dataBuffer;
  if (o instanceof FBRevObject) {
    dataBuffer = ((FBRevObject<?>) o).getTable().getByteBuffer().duplicate();
  } else {
    FlatBufferBuilder fbb = WRITE_BUFFERS.get();
    fbb.clear();
    flatBuffers.encode(o, fbb);
    dataBuffer = fbb.dataBuffer();
  }
  byte[] array;
  int off, len = dataBuffer.remaining();
  if (dataBuffer.hasArray()) {
    array = dataBuffer.array();
    off = dataBuffer.position();
  } else {
    off = 0;
    array = new byte[len];
    dataBuffer.get(array);
  }
  if (isLengthPrefixed()) {
    // write size in little endian (FlatBuffers is LE exclusively, so follow suite)
    out.write((len >>> 0) & 0xFF);
    out.write((len >>> 8) & 0xFF);
    out.write((len >>> 16) & 0xFF);
    out.write((len >>> 24) & 0xFF);
  }
  out.write(array, off, len);
}

代码示例来源：origin: flipkart-incubator/kafka-filtering

public byte[] encode(byte[] serializedWithoutWrap, Map<String, String> tags) {
  FlatBufferBuilder fbb = new FlatBufferBuilder(1024);
  int[] tagsArr = new int[tags.size()];
  int i = 0;
  for (Map.Entry<String, String> entry : tags.entrySet()) {
    tagsArr[i] = _encodeEntry(entry, fbb);
    i++;
  }
  int tagsRef = FB_FilterWrap.createTagsVector(fbb, tagsArr);
  int dataRef = FB_FilterWrap.createDataVector(fbb, serializedWithoutWrap);
  int filterWrapRef = FB_FilterWrap.createFB_FilterWrap(fbb, tagsRef, dataRef);
  FB_FilterWrap.finishFB_FilterWrapBuffer(fbb, filterWrapRef);
  int buffer_start = fbb.dataBuffer().position();
  int buffer_length = fbb.offset();
  byte[] full_buffer = fbb.dataBuffer().array();
  return Arrays.copyOfRange(full_buffer, buffer_start, buffer_start + buffer_length);
}

代码示例来源：origin: org.apache.arrow/arrow-vector

public static ByteBuffer serialize(FBSerializable writer) {
  FlatBufferBuilder builder = new FlatBufferBuilder();
  int root = writer.writeTo(builder);
  builder.finish(root);
  return builder.dataBuffer();
 }
}

代码示例来源：origin: com.github.davidmoten/rtree

private static <T, S extends Geometry> Node_ createNode(List<Entry<T, S>> entries,
    Func1<? super T, byte[]> serializer) {
  FlatBufferBuilder builder = new FlatBufferBuilder(0);
  builder.finish(FlatBuffersHelper.addEntries(entries, builder, serializer));
  return Node_.getRootAsNode_(builder.dataBuffer());
}

代码示例来源：origin: locationtech/geogig

public @Override @NonNull RevFeatureType createFeatureType(@NonNull ObjectId id,
    @NonNull FeatureType ftype) {
  Collection<PropertyDescriptor> descriptors = ftype.getDescriptors();
  descriptors.forEach(d -> {
    Class<?> binding = d.getType().getBinding();
    Objects.requireNonNull(binding,
        "got null binding for attribute " + d.getName().getLocalPart());
    FieldType fieldType = FieldType.forBinding(binding);
    if (FieldType.NULL == fieldType || FieldType.UNKNOWN == fieldType) {
      String msg = String.format(
          "Attribute %s of FeatureType %s is of an unsupported type: %s",
          d.getName().getLocalPart(), ftype.getName().getLocalPart(),
          binding.getName());
      throw new IllegalArgumentException(msg);
    }
  });
  FlatBufferBuilder fbb = newBuilder();
  int objOffset = encoder.writeSimpleFeatureType(fbb, (SimpleFeatureType) ftype);
  encoder.writeRevisionObject(ObjectType.SimpleFeatureType, objOffset, fbb);
  return (RevFeatureType) encoder.decode(id, copy(fbb.dataBuffer()));
}

代码示例来源：origin: dremio/dremio-oss

public FragmentWritableBatch(
  final QueryId queryId,
  final int sendMajorFragmentId,
  final int sendMinorFragmentId,
  final int receiveMajorFragmentId,
  ArrowRecordBatch recordBatch,
  final int... receiveMinorFragmentId){
 this.buffers = recordBatch.getBuffers().toArray(new ByteBuf[0]);
 this.recordCount = recordBatch.getLength();
 FlatBufferBuilder fbbuilder = new FlatBufferBuilder();
 fbbuilder.finish(recordBatch.writeTo(fbbuilder));
 ByteBuffer arrowRecordBatch = fbbuilder.dataBuffer();
 final FragmentRecordBatch.Builder builder = FragmentRecordBatch.newBuilder()
   .setArrowRecordBatch(ByteString.copyFrom(arrowRecordBatch))
   .setQueryId(queryId)
   .setReceivingMajorFragmentId(receiveMajorFragmentId)
   .setSendingMajorFragmentId(sendMajorFragmentId)
   .setSendingMinorFragmentId(sendMinorFragmentId);
 for(final int i : receiveMinorFragmentId){
  builder.addReceivingMinorFragmentId(i);
 }
 this.header = builder.build();
}

代码示例来源：origin: org.apache.arrow/arrow-vector

/**
 * Serializes a message header.
 *
 * @param builder      to write the flatbuf to
 * @param headerType   headerType field
 * @param headerOffset header offset field
 * @param bodyLength   body length field
 * @return the corresponding ByteBuffer
 */
public static ByteBuffer serializeMessage(
  FlatBufferBuilder builder,
  byte headerType,
  int headerOffset,
  int bodyLength) {
 Message.startMessage(builder);
 Message.addHeaderType(builder, headerType);
 Message.addHeader(builder, headerOffset);
 Message.addVersion(builder, MetadataVersion.V4);
 Message.addBodyLength(builder, bodyLength);
 builder.finish(Message.endMessage(builder));
 return builder.dataBuffer();
}

代码示例来源：origin: WeBankFinTech/FATE

public static Operand createOperand(Bytes key, byte[] value) {
    FlatBufferBuilder fbb = new FlatBufferBuilder();
    int kVec = fbb.createByteVector(key.get());
    int vVec;
    if (value != null) {
      vVec = fbb.createByteVector(value);
    } else {
      vVec = fbb.createByteVector(new byte[0]);
    }
    Operand.startOperand(fbb);
    Operand.addKey(fbb, kVec);
    Operand.addValue(fbb, vVec);
    fbb.finish(Operand.endOperand(fbb));
    return Operand.getRootAsOperand(fbb.dataBuffer());
  }
}

代码示例来源：origin: com.github.davidmoten/rtree

Tree_.finishTree_Buffer(builder, t);
ByteBuffer bb = builder.dataBuffer();
os.write(bb.array(), bb.position(), bb.remaining());

内容来源于网络，如有侵权，请联系作者删除！

FlatBufferBuilder

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    FlatBufferBuilder类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com