diff --git a/src/lib.rs b/src/lib.rs index e8dab082..5fd83656 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1,5 +1,4 @@ #![allow(dead_code)] -mod arrows; mod compaction; pub mod executor; pub mod fs; diff --git a/src/arrows/mod.rs b/src/ondisk/arrows.rs similarity index 100% rename from src/arrows/mod.rs rename to src/ondisk/arrows.rs diff --git a/src/ondisk/mod.rs b/src/ondisk/mod.rs index 81af4140..fa272983 100644 --- a/src/ondisk/mod.rs +++ b/src/ondisk/mod.rs @@ -1,2 +1,3 @@ +mod arrows; pub(crate) mod scan; pub(crate) mod sstable; diff --git a/src/ondisk/sstable.rs b/src/ondisk/sstable.rs index dacf8de9..de6e7ba2 100644 --- a/src/ondisk/sstable.rs +++ b/src/ondisk/sstable.rs @@ -14,9 +14,8 @@ use parquet::{ }; use tokio_util::compat::{Compat, FuturesAsyncReadCompatExt}; -use super::scan::SsTableScan; +use super::{arrows::get_range_filter, scan::SsTableScan}; use crate::{ - arrows::get_range_filter, fs::{AsyncFile, FileProvider}, record::Record, stream::record_batch::RecordBatchEntry,