pub struct SegmentReader<'a> { /* private fields */ }Expand description
Reads and decodes columns from a segment byte buffer.
Supports column projection (only decode requested columns) and block predicate pushdown (skip blocks whose stats prove no match).
Implementations§
Source§impl<'a> SegmentReader<'a>
impl<'a> SegmentReader<'a>
Sourcepub fn open(data: &'a [u8]) -> Result<Self, ColumnarError>
pub fn open(data: &'a [u8]) -> Result<Self, ColumnarError>
Open a segment from a byte buffer. Validates header and footer CRC.
Access the footer metadata.
Sourcepub fn column_count(&self) -> usize
pub fn column_count(&self) -> usize
Number of columns in the segment.
Sourcepub fn read_column(
&self,
col_idx: usize,
) -> Result<DecodedColumn, ColumnarError>
pub fn read_column( &self, col_idx: usize, ) -> Result<DecodedColumn, ColumnarError>
Read a single column, decoding all blocks.
col_idx is the column index in the footer’s column metadata.
Sourcepub fn read_column_filtered(
&self,
col_idx: usize,
predicates: &[ScanPredicate],
) -> Result<DecodedColumn, ColumnarError>
pub fn read_column_filtered( &self, col_idx: usize, predicates: &[ScanPredicate], ) -> Result<DecodedColumn, ColumnarError>
Read a single column with predicate pushdown.
Blocks whose stats satisfy the predicates are skipped. For skipped blocks, null/zero-fill rows are emitted to preserve row alignment across projected columns.
Sourcepub fn read_columns(
&self,
col_indices: &[usize],
predicates: &[ScanPredicate],
) -> Result<Vec<DecodedColumn>, ColumnarError>
pub fn read_columns( &self, col_indices: &[usize], predicates: &[ScanPredicate], ) -> Result<Vec<DecodedColumn>, ColumnarError>
Read multiple columns with shared predicate pushdown.
All columns share the same block skip decisions so row alignment is maintained across the result set.
Sourcepub fn read_column_with_deletes(
&self,
col_idx: usize,
predicates: &[ScanPredicate],
deletes: &DeleteBitmap,
) -> Result<DecodedColumn, ColumnarError>
pub fn read_column_with_deletes( &self, col_idx: usize, predicates: &[ScanPredicate], deletes: &DeleteBitmap, ) -> Result<DecodedColumn, ColumnarError>
Read a column with both predicate pushdown and delete bitmap masking.
Deleted rows have their validity set to false in the output. Fully deleted blocks are skipped entirely (no decompression).
Sourcepub fn read_columns_with_deletes(
&self,
col_indices: &[usize],
predicates: &[ScanPredicate],
deletes: &DeleteBitmap,
) -> Result<Vec<DecodedColumn>, ColumnarError>
pub fn read_columns_with_deletes( &self, col_indices: &[usize], predicates: &[ScanPredicate], deletes: &DeleteBitmap, ) -> Result<Vec<DecodedColumn>, ColumnarError>
Read multiple columns with predicate pushdown and delete bitmap.
Auto Trait Implementations§
impl<'a> Freeze for SegmentReader<'a>
impl<'a> RefUnwindSafe for SegmentReader<'a>
impl<'a> Send for SegmentReader<'a>
impl<'a> Sync for SegmentReader<'a>
impl<'a> Unpin for SegmentReader<'a>
impl<'a> UnsafeUnpin for SegmentReader<'a>
impl<'a> UnwindSafe for SegmentReader<'a>
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
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> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
out indicating that a T is niched.