Trait StreamingWriteHandle 

pub trait StreamingWriteHandle: Send + Sync {
    // Required methods
    fn write_row(&mut self, row: &[String]) -> Result<()>;
    fn rows_written(&self) -> usize;
    fn flush(&mut self) -> Result<()>;
}

Handle for streaming writes

Required Methods

fn write_row(&mut self, row: &[String]) -> Result<()>

Write a single row

fn rows_written(&self) -> usize

Get number of rows written

fn flush(&mut self) -> Result<()>

Flush buffered data

Implementors