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()
+    }
+}