Method Write

bolt/serializers/ArrowSerializer.cpp:124–133

  }

  ::arrow::Status Write(const void* data, int64_t nbytes) override {
    if (closed_)
      return ::arrow::Status::IOError("write on closed");
    if (nbytes <= 0)
      return ::arrow::Status::OK();
    out_->write(
        reinterpret_cast<const char*>(data),
        static_cast<std::streamsize>(nbytes));
    return ::arrow::Status::OK();
  }

  ::arrow::Status Write(const std::shared_ptr<::arrow::Buffer>& buf) override {
    return Write(buf->data(), buf->size());