| 1048 | |
| 1049 | public: |
| 1050 | ObjectAppendStream(std::shared_ptr<Blobs::BlockBlobClient> block_blob_client, |
| 1051 | const io::IOContext& io_context, const AzureLocation& location, |
| 1052 | const std::shared_ptr<const KeyValueMetadata>& metadata, |
| 1053 | const AzureOptions& options) |
| 1054 | : block_blob_client_(std::move(block_blob_client)), |
| 1055 | io_context_(io_context), |
| 1056 | location_(location), |
| 1057 | background_writes_(options.background_writes) { |
| 1058 | if (metadata && metadata->size() != 0) { |
| 1059 | ArrowMetadataToCommitBlockListOptions(metadata, commit_block_list_options_); |
| 1060 | } else if (options.default_metadata && options.default_metadata->size() != 0) { |
| 1061 | ArrowMetadataToCommitBlockListOptions(options.default_metadata, |
| 1062 | commit_block_list_options_); |
| 1063 | } |
| 1064 | } |
| 1065 | |
| 1066 | ~ObjectAppendStream() override { |
| 1067 | // For compliance with the rest of the IO stack, Close rather than Abort, |
nothing calls this directly
no test coverage detected