Struct StreamingKoreWriter 

pub struct StreamingKoreWriter { /* private fields */ }

Implementations

impl StreamingKoreWriter

pub fn begin( columns: Vec<KColumn>, chunk_size: usize, path: &str, ) -> Result<Self, String>

Open output file and write placeholder header + schema + empty dictionary.

pub fn write_chunk(&mut self, rows: &[Vec<KVal>]) -> Result<(), String>

Compress and write one batch of rows directly to the file. Call this in a loop — each call uses only rows.len() × ncols memory.

pub fn finish(self) -> Result<String, String>

Write footer, patch header nrows/nchunks, and close the file.