Struct PaxStreamReader 

pub struct PaxStreamReader<'a> { /* private fields */ }

Incremental reader for unsealed or sealed PAX streams.

Implementations

impl<'a> PaxStreamReader<'a>

pub fn open(data: &'a [u8]) -> Result<Self>

pub fn is_sealed(&self) -> bool

pub fn data_start(&self) -> usize

pub fn keys(&self) -> &[String]

pub fn key_sigils(&self) -> &[u8]

pub fn complete_record_count(&self) -> usize

Number of records in all complete pages (excludes any in-progress page).

pub fn has_complete_page(&self) -> bool

True when at least one full page is available.

pub fn poll_next_page(&mut self) -> Option<PaxPageView<'a>>

Next complete page view, advancing the internal cursor.

pub fn rewind_pages(&mut self)

Reset page iteration to the data-sector start.

pub fn col_sum_f64_complete_pages(&self, key: &str) -> Option<f64>

Sum key as f64 over all complete pages (incremental column scan).

pub fn get_f64_complete(&self, global_index: usize, key: &str) -> Option<f64>

Global record index → f64 within complete pages only.