@@ -619,6 +619,12 @@ class ObjectAppendStream final : public io::OutputStream {
619619 return DoAppend (data, nbytes);
620620 }
621621
622+ Status Flush () override {
623+ RETURN_NOT_OK (CheckClosed (" flush" ));
624+ return CommitBlockList (block_blob_client_, block_ids_, metadata_);
625+ }
626+
627+ private:
622628 Status DoAppend (const void * data, int64_t nbytes,
623629 std::shared_ptr<Buffer> owned_buffer = nullptr ) {
624630 RETURN_NOT_OK (CheckClosed (" append" ));
@@ -661,12 +667,6 @@ class ObjectAppendStream final : public io::OutputStream {
661667 return Status::OK ();
662668 }
663669
664- Status Flush () override {
665- RETURN_NOT_OK (CheckClosed (" flush" ));
666- return CommitBlockList (block_blob_client_, block_ids_, metadata_);
667- }
668-
669- private:
670670 std::shared_ptr<Azure::Storage::Blobs::BlockBlobClient> block_blob_client_;
671671 const io::IOContext io_context_;
672672 const AzureLocation location_;
@@ -957,10 +957,10 @@ class AzureFileSystem::Impl {
957957 if (truncate) {
958958 RETURN_NOT_OK (CreateEmptyBlockBlob (block_blob_client));
959959 stream = std::make_shared<ObjectAppendStream>(block_blob_client, fs->io_context (),
960- location, metadata, options_, 0 );
960+ location, metadata, options_, 0 );
961961 } else {
962962 stream = std::make_shared<ObjectAppendStream>(block_blob_client, fs->io_context (),
963- location, metadata, options_);
963+ location, metadata, options_);
964964 }
965965 RETURN_NOT_OK (stream->Init ());
966966 return stream;
0 commit comments