You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by yj...@apache.org on 2023/07/25 20:37:53 UTC
[arrow-rs] 01/01: debug
This is an automated email from the ASF dual-hosted git repository.
yjshen pushed a commit to branch pub_multipart_upload
in repository https://gitbox.apache.org/repos/asf/arrow-rs.git
commit 5a5f11f313f26b9c5994cc649d269d08a6f8ac26
Author: Yijie Shen <he...@gmail.com>
AuthorDate: Tue Jul 25 13:37:42 2023 -0700
debug
---
object_store/src/multipart.rs | 14 +++++++++++++-
1 file changed, 13 insertions(+), 1 deletion(-)
diff --git a/object_store/src/multipart.rs b/object_store/src/multipart.rs
index bcfe041cb6..5f9b7e6748 100644
--- a/object_store/src/multipart.rs
+++ b/object_store/src/multipart.rs
@@ -56,7 +56,6 @@ pub struct UploadPart {
}
/// Struct that manages and controls multipart uploads to a cloud storage service.
-#[derive(Debug)]
pub struct CloudMultiPartUpload<T>
where
T: CloudMultiPartUploadImpl,
@@ -269,3 +268,16 @@ where
Pin::new(completion_task).poll(cx)
}
}
+
+impl<T: CloudMultiPartUploadImpl> std::fmt::Debug for CloudMultiPartUpload<T> {
+ fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+ f.debug_struct("CloudMultiPartUpload")
+ .field("completed_parts", &self.completed_parts)
+ .field("tasks", &self.tasks)
+ .field("max_concurrency", &self.max_concurrency)
+ .field("current_buffer", &self.current_buffer)
+ .field("part_size", &self.part_size)
+ .field("current_part_idx", &self.current_part_idx)
+ .finish()
+ }
+}