Minor tweaks to import style

Author: westonpace

rust/lance-index/src/scalar/lance_format.rs

@@ -14,7 +14,7 @@ use lance_core::{Error, Result, cache::LanceCache};
 use lance_encoding::decoder::{DecoderPlugins, FilterExpression};
 use lance_encoding::version::LanceFileVersion;
 use lance_file::previous::reader::FileReader as PreviousFileReader;
-use lance_file::reader::{self as current_reader, FileReaderOptions, ReaderProjection};
+use lance_file::reader::{FileReader as CurrentFileReader, FileReaderOptions, ReaderProjection};
 use lance_file::writer as current_writer;
 use lance_io::scheduler::{ScanScheduler, SchedulerConfig};
 use lance_io::utils::CachedFileSize;
@@ -203,8 +203,8 @@ impl IndexReader for PreviousIndexReader {
     }
 }
 
-/// Newtype wrapper to allow implementing IndexReader for current_reader::FileReader (a foreign type)
-struct CurrentIndexReader(current_reader::FileReader);
+/// Newtype wrapper to allow implementing IndexReader for CurrentFileReader (a foreign type)
+struct CurrentIndexReader(CurrentFileReader);
 
 #[async_trait]
 impl IndexReader for CurrentIndexReader {
@@ -216,7 +216,7 @@ impl IndexReader for CurrentIndexReader {
     }
 
     async fn read_global_buffer(&self, n: u32) -> Result<Bytes> {
-        current_reader::FileReader::read_global_buffer(&self.0, n).await
+        CurrentFileReader::read_global_buffer(&self.0, n).await
     }
 
     async fn read_range(
@@ -368,15 +368,15 @@ impl IndexReader for CurrentIndexReader {
     // V2 format has removed the row group concept,
     // so here we assume each batch is with 4096 rows.
     async fn num_batches(&self, batch_size: u64) -> u32 {
-        current_reader::FileReader::num_rows(&self.0).div_ceil(batch_size) as u32
+        CurrentFileReader::num_rows(&self.0).div_ceil(batch_size) as u32
     }
 
     fn num_rows(&self) -> usize {
-        current_reader::FileReader::num_rows(&self.0) as usize
+        CurrentFileReader::num_rows(&self.0) as usize
     }
 
     fn schema(&self) -> &lance_core::datatypes::Schema {
-        current_reader::FileReader::schema(&self.0)
+        CurrentFileReader::schema(&self.0)
     }
 
     fn file_size_bytes(&self) -> Option<u64> {
@@ -443,7 +443,7 @@ impl IndexStore for LanceIndexStore {
             .scheduler
             .open_file_with_priority(&path, self.io_priority, &cached_size)
             .await?;
-        match current_reader::FileReader::try_open(
+        match CurrentFileReader::try_open(
             file_scheduler,
             None,
             Arc::<DecoderPlugins>::default(),