This is an automated email from the ASF dual-hosted git repository.
sdd pushed a commit to branch feature/table-scan-delete-file-handling
in repository https://gitbox.apache.org/repos/asf/iceberg-rust.git
commit 5308d597a17ba0a025daf7afababd57874d6cf53
Author: Scott Donnelly <sc...@donnel.ly>
AuthorDate: Mon Dec 23 11:40:57 2024 +0000
style: reorder
---
crates/iceberg/src/delete_file_index.rs | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/crates/iceberg/src/delete_file_index.rs
b/crates/iceberg/src/delete_file_index.rs
index 3f1a092f..53a50865 100644
--- a/crates/iceberg/src/delete_file_index.rs
+++ b/crates/iceberg/src/delete_file_index.rs
@@ -29,6 +29,12 @@ use crate::runtime::spawn;
use crate::scan::{DeleteFileContext, FileScanTaskDeleteFile};
use crate::spec::{DataContentType, DataFile, Struct};
+/// Index of delete files
+#[derive(Clone, Debug)]
+pub(crate) struct DeleteFileIndex {
+ state: Arc<RwLock<DeleteFileIndexState>>,
+}
+
#[derive(Debug)]
enum DeleteFileIndexState {
Populating,
@@ -44,12 +50,6 @@ struct PopulatedDeleteFileIndex {
pos_deletes_by_path: HashMap<String, Vec<Arc<DeleteFileContext>>>,
}
-/// Index of delete files
-#[derive(Clone, Debug)]
-pub(crate) struct DeleteFileIndex {
- state: Arc<RwLock<DeleteFileIndexState>>,
-}
-
impl DeleteFileIndex {
/// create a new `DeleteFileIndex` along with the sender that populates it
with delete files
pub(crate) fn new() -> (DeleteFileIndex, Sender<DeleteFileContext>) {
