Skip to main content

FormatWriter

rivet_cli::format

Trait FormatWriter 

Source 
pub trait FormatWriter {
    // Required methods
    fn write_batch(&mut self, batch: &RecordBatch) -> Result<()>;
    fn finish(self: Box<Self>) -> Result<()>;
    fn bytes_written(&self) -> u64;
}
Expand description

Streaming writer: receives one RecordBatch at a time.

Required Methods§

Source

fn write_batch(&mut self, batch: &RecordBatch) -> Result<()>

Source

fn finish(self: Box<Self>) -> Result<()>

Source

fn bytes_written(&self) -> u64

Approximate bytes written so far (for file-size splitting).

Implementors§