pub struct FileTuples { /* private fields */ }Expand description
Handle to the merged external sort file for sequential buffered access.
Unlike the previous MmapTuples, this does NOT mmap the file. Instead,
each access pass opens a fresh BufReader, reading tuples sequentially
with a ~4 MB buffer. This keeps RSS proportional to the buffer size
instead of the file size (~8-10 GB for large datasets).
Implementations§
Source§impl FileTuples
impl FileTuples
Sourcepub fn num_tuples(&self) -> usize
pub fn num_tuples(&self) -> usize
Total number of tuples in the merged file.
Sourcepub fn bucket_iter(&self) -> Result<FileBucketIter>
pub fn bucket_iter(&self) -> Result<FileBucketIter>
Create an iterator that yields one BucketScan per unique minimizer,
scanning the file sequentially via buffered I/O.
Each call opens a fresh BufReader — no state is retained between
passes, and no mmap pages linger in memory.
Sourcepub fn sequential_reader(&self) -> Result<SequentialTupleReader>
pub fn sequential_reader(&self) -> Result<SequentialTupleReader>
Create a sequential tuple reader for forward-only access.
Returns tuples one at a time via read_next(). Used by the
sparse/skew index builder for its sequential pass over all tuples.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for FileTuples
impl RefUnwindSafe for FileTuples
impl Send for FileTuples
impl Sync for FileTuples
impl Unpin for FileTuples
impl UnsafeUnpin for FileTuples
impl UnwindSafe for FileTuples
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T, U> CastableInto<U> for Twhere
U: CastableFrom<T>,
impl<T, U> CastableInto<U> for Twhere
U: CastableFrom<T>,
Source§impl<T> DowncastableFrom<T> for T
impl<T> DowncastableFrom<T> for T
Source§fn downcast_from(value: T) -> T
fn downcast_from(value: T) -> T
Source§impl<T, U> DowncastableInto<U> for Twhere
U: DowncastableFrom<T>,
impl<T, U> DowncastableInto<U> for Twhere
U: DowncastableFrom<T>,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more