cargo fmt

Author: westonpace

rust/lance-index/src/frag_reuse.rs

@@ -13,8 +13,8 @@ use std::sync::Arc;
 
 use arrow_array::RecordBatch;
 use async_trait::async_trait;
-use lance_core::deepsize::DeepSizeOf;
 use lance_core::Result;
+use lance_core::deepsize::DeepSizeOf;
 use lance_select::RowAddrTreeMap;
 use roaring::{RoaringBitmap, RoaringTreemap};
 use serde::Serialize;
@@ -31,7 +31,9 @@ pub struct FragReuseIndexHandle(pub Arc<FragReuseIndex>);
 
 impl std::fmt::Debug for FragReuseIndexHandle {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-        f.debug_tuple("FragReuseIndexHandle").field(&self.0).finish()
+        f.debug_tuple("FragReuseIndexHandle")
+            .field(&self.0)
+            .finish()
     }
 }
 

rust/lance-index/src/mem_wal.rs

@@ -11,8 +11,8 @@ use std::any::Any;
 use std::sync::Arc;
 
 use async_trait::async_trait;
-use lance_core::deepsize::DeepSizeOf;
 use lance_core::Result;
+use lance_core::deepsize::DeepSizeOf;
 use roaring::RoaringBitmap;
 use serde::Serialize;
 

rust/lance-namespace-impls/src/dir/manifest.rs

@@ -36,7 +36,9 @@ use lance_index::progress::noop_progress;
 use lance_index::registry::IndexPluginRegistry;
 use lance_index::scalar::lance_format::LanceIndexStore;
 use lance_index::scalar::registry::VALUE_COLUMN_NAME;
-use lance_index::scalar::{BuiltinIndexType, CreatedIndex, ScalarIndexParams, index_files_to_table};
+use lance_index::scalar::{
+    BuiltinIndexType, CreatedIndex, ScalarIndexParams, index_files_to_table,
+};
 use lance_io::object_store::{ObjectStore, ObjectStoreParams};
 use lance_io::stream::RecordBatchStream as LanceRecordBatchStream;
 use lance_namespace::LanceNamespace;

rust/lance-table/src/system_index/frag_reuse.rs

@@ -348,7 +348,6 @@ impl FragReuseIndex {
     }
 }
 
-
 #[cfg(test)]
 mod tests {
 

rust/lance-table/src/system_index/mem_wal.rs

@@ -436,4 +436,3 @@ impl MemWalIndex {
         caught_up_gen.is_none_or(|generation| generation >= merged_gen)
     }
 }
-

rust/lance/src/dataset/optimize.rs

@@ -2174,7 +2174,6 @@ mod tests {
     use crate::dataset::index::frag_reuse::cleanup_frag_reuse_index;
     use crate::dataset::optimize::remapping::{transpose_row_addrs, transpose_row_ids_from_digest};
     use crate::index::frag_reuse::{load_frag_reuse_index_details, open_frag_reuse_index};
-    use lance_index::frag_reuse::FragReuseIndexHandle;
     use crate::index::vector::{StageParams, VectorIndexParams};
     use crate::utils::test::{DatagenExt, FragmentCount, FragmentRowCount};
     use arrow_array::types::{Float32Type, Float64Type, Int32Type, Int64Type};
@@ -2193,6 +2192,7 @@ mod tests {
     use lance_datagen::Dimension;
     use lance_file::version::LanceFileVersion;
     use lance_index::frag_reuse::FRAG_REUSE_INDEX_NAME;
+    use lance_index::frag_reuse::FragReuseIndexHandle;
     use lance_index::scalar::{
         BuiltinIndexType, FullTextSearchQuery, InvertedIndexParams, ScalarIndexParams,
     };
@@ -3370,7 +3370,9 @@ mod tests {
             open_frag_reuse_index(frag_reuse_index_meta.uuid, frag_reuse_details.as_ref())
                 .await
                 .unwrap();
-        let stats = FragReuseIndexHandle(Arc::new(frag_reuse_index.clone())).statistics().unwrap();
+        let stats = FragReuseIndexHandle(Arc::new(frag_reuse_index.clone()))
+            .statistics()
+            .unwrap();
         assert_eq!(
             serde_json::to_string(&stats).unwrap(),
             dataset

rust/lance/src/index/append.rs

@@ -11,9 +11,8 @@ use lance_index::{
     optimize::OptimizeOptions,
     progress::NoopIndexBuildProgress,
     scalar::{
-        CreatedIndex, OldIndexDataFilter, ScalarIndex, index_files_to_table, table_files_to_index,
-        inverted::InvertedIndex,
-        lance_format::LanceIndexStore,
+        CreatedIndex, OldIndexDataFilter, ScalarIndex, index_files_to_table,
+        inverted::InvertedIndex, lance_format::LanceIndexStore, table_files_to_index,
     },
 };
 use lance_select::{RowAddrTreeMap, RowSetOps};

rust/lance/src/index/create.rs

@@ -25,8 +25,8 @@ use lance_index::{IndexParams, IndexType, scalar::CreatedIndex};
 use lance_index::{
     metrics::NoOpMetricsCollector,
     scalar::{
-        LANCE_SCALAR_INDEX, ScalarIndexParams, index_files_to_table, table_files_to_index,
-        inverted::tokenizer::InvertedIndexParams,
+        LANCE_SCALAR_INDEX, ScalarIndexParams, index_files_to_table,
+        inverted::tokenizer::InvertedIndexParams, table_files_to_index,
     },
 };
 use lance_table::format::{IndexMetadata, list_index_files_with_sizes};

rust/lance/src/index/scalar.rs

@@ -35,6 +35,7 @@ use lance_core::datatypes::Field;
 use lance_core::utils::tracing::{IO_TYPE_OPEN_SCALAR, TRACE_IO_EVENTS};
 use lance_core::{Error, ROW_ADDR, ROW_ID, Result};
 use lance_datafusion::exec::LanceExecutionOptions;
+use lance_index::frag_reuse::FragReuseIndexHandle;
 use lance_index::metrics::{MetricsCollector, NoOpMetricsCollector};
 use lance_index::pbold::{
     BTreeIndexDetails, BitmapIndexDetails, InvertedIndexDetails, LabelListIndexDetails,
@@ -49,7 +50,6 @@ use lance_index::scalar::label_list::{
 use lance_index::scalar::registry::{
     ScalarIndexLoad, ScalarIndexPlugin, TrainingCriteria, TrainingOrdering, VALUE_COLUMN_NAME,
 };
-use lance_index::frag_reuse::FragReuseIndexHandle;
 use lance_index::scalar::{BuiltinIndexType, CreatedIndex, InvertedIndexParams};
 use lance_index::scalar::{
     RowIdRemapper, ScalarIndex, ScalarIndexParams, bitmap::BITMAP_LOOKUP_NAME,
@@ -460,8 +460,8 @@ pub async fn open_scalar_index(
         .index_cache
         .for_index(&index.uuid, frag_reuse_index.as_ref().map(|f| &f.uuid));
 
-    let frag_reuse_index: Option<Arc<dyn RowIdRemapper>> = frag_reuse_index
-        .map(|f| Arc::new(FragReuseIndexHandle(f)) as Arc<dyn RowIdRemapper>);
+    let frag_reuse_index: Option<Arc<dyn RowIdRemapper>> =
+        frag_reuse_index.map(|f| Arc::new(FragReuseIndexHandle(f)) as Arc<dyn RowIdRemapper>);
 
     // Runs only on a cold miss, and at most once even under concurrent opens
     // (the plugin coalesces). The compat check lives here because a warm hit was

rust/lance/src/index/scalar/inverted.rs

@@ -11,10 +11,10 @@ use datafusion::physical_plan::stream::RecordBatchStreamAdapter;
 use lance_core::ROW_ID;
 use lance_index::metrics::NoOpMetricsCollector;
 use lance_index::pbold::InvertedIndexDetails;
+use lance_index::scalar::index_files_to_table;
 use lance_index::scalar::inverted::InvertedIndex;
 use lance_index::scalar::lance_format::LanceIndexStore;
 use lance_index::scalar::registry::VALUE_COLUMN_NAME;
-use lance_index::scalar::index_files_to_table;
 use lance_table::format::IndexMetadata;
 use prost::Message;
 use roaring::RoaringBitmap;