Struct WriterPool 

pub struct WriterPool { /* private fields */ }

Pool of per-table writers, creating files on demand.

Implementations

impl WriterPool

pub fn new(output_dir: PathBuf) -> Self

Create a new writer pool targeting the given output directory.

pub fn ensure_output_dir(&self) -> Result<()>

Create the output directory if it does not exist.

pub fn get_writer(&mut self, table_name: &str) -> Result<&mut TableWriter>

Get or create a writer for the given table name.

pub fn write_statement(&mut self, table_name: &str, stmt: &[u8]) -> Result<()>

Write a statement to the file for the given table.

pub fn write_statement_with_suffix( &mut self, table_name: &str, stmt: &[u8], suffix: &[u8], ) -> Result<()>

Write a statement with suffix to the file for the given table.

pub fn close_all(&mut self) -> Result<()>

Flush and close all writers.