coryan commented on a change in pull request #11550:
URL: https://github.com/apache/arrow/pull/11550#discussion_r743104899
##########
File path: cpp/src/arrow/filesystem/gcsfs.cc
##########
@@ -102,6 +109,42 @@ class GcsInputStream : public arrow::io::InputStream {
mutable gcs::ObjectReadStream stream_;
};
+class GcsOutputStream : public arrow::io::OutputStream {
+ public:
+ explicit GcsOutputStream(gcs::ObjectWriteStream stream) :
stream_(std::move(stream)) {}
+ ~GcsOutputStream() override = default;
+
+ Status Close() override {
+ stream_.Close();
+ return internal::ToArrowStatus(stream_.last_status());
+ }
+
+ Result<int64_t> Tell() const override {
+ if (!stream_) {
+ return Status::IOError("invalid stream");
+ }
+ return tell_;
+ }
+
+ bool closed() const override { return !stream_.IsOpen(); }
+
+ Status Write(const void* data, int64_t nbytes) override {
+ if (stream_.write(reinterpret_cast<const char*>(data), nbytes)) {
+ return Status::OK();
+ }
+ return internal::ToArrowStatus(stream_.last_status());
+ }
+
+ Status Flush() override {
+ stream_.flush();
+ return Status::OK();
+ }
+
+ private:
+ gcs::ObjectWriteStream stream_;
+ int64_t tell_ = 0;
Review comment:
Fixed. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
