refactor: TableScan retrieves manifests concurrently and process thei…

…r entries in parallel
apache · Jul 18, 2024 · 2801f0a · 2801f0a
1 parent dfb6356
commit 2801f0a
Show file tree

Hide file tree

Showing 4 changed files with 468 additions and 299 deletions.
diff --git a/crates/iceberg/src/error.rs b/crates/iceberg/src/error.rs
@@ -337,6 +337,12 @@ define_from_err!(
     "Failed to send a message to a channel"
 );
 
+define_from_err!(
+    tokio::task::JoinError,
+    ErrorKind::Unexpected,
+    "Failed to join a task"
+);
+
 define_from_err!(std::io::Error, ErrorKind::Unexpected, "IO Operation failed");
 
 /// Helper macro to check arguments.