Method Write

c_glib/arrow-glib/output-stream.cpp:393–414

    }

    arrow::Status
    Write(const void *data, int64_t n_bytes) override
    {
      GError *error = NULL;
      gsize n_written_bytes;
      auto succeeded = g_output_stream_write_all(output_stream_,
                                                 data,
                                                 n_bytes,
                                                 &n_written_bytes,
                                                 NULL,
                                                 &error);
      if (succeeded) {
        position_ += n_written_bytes;
        return arrow::Status::OK();
      } else {
        std::stringstream message("[gio-output-stream][write]");
        message << "[" << n_written_bytes << "/" << n_bytes << "]";
        return garrow_error_to_status(error,
                                      arrow::StatusCode::IOError,
                                      message.str().c_str());
      }
    }

    arrow::Status
    Flush() override