Struct PaxStreamWriter 

pub struct PaxStreamWriter { /* private fields */ }

Streaming PAX writer: accumulates records, flushes full pages, seals with tail-index.

Implementations

impl PaxStreamWriter

pub fn new(keys: Vec<String>, sigils: Vec<u8>, page_size: u32) -> Result<Self>

pub fn from_rows( keys: &[String], rows: &[RecordRow], page_size: u32, ) -> Result<Self>

Build a writer from keys and rows (infers sigils like sealed finish_pax).

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

pub fn page_size(&self) -> u32

pub fn flushed_page_count(&self) -> usize

pub fn pending_count(&self) -> usize

pub fn data_sector_len(&self) -> usize

pub fn pages(&self) -> &[PaxPageMeta]

pub fn push_record(&mut self, row: RecordRow) -> Result<Option<Vec<u8>>>

Append a record; flushes a complete page when pending.len() == page_size.

pub fn flush_pending(&mut self) -> Result<Option<Vec<u8>>>

Emit the current pending slice as one page (partial page allowed).

pub fn write_stream_header(&self, out: &mut impl Write) -> Result<u64>

Write unsealed preamble + schema (TailPtr = 0). Returns absolute data-sector start.

pub fn write_data_sector_since( &self, out: &mut impl Write, start: usize, ) -> Result<(), Error>

Append flushed data-sector bytes since start.

pub fn finish_stream(self) -> Result<Vec<u8>>

Build a sealed in-memory .nxb (final partial page + tail-index + footer).

pub fn seal_stream(self, out: &mut impl Write) -> Result<u64>

Seal an on-disk stream: flush pending, append tail-index, patch preamble tail offset.