nautilus_persistence::arrow

Trait WriteStream

source 
pub trait WriteStream {
    // Required method
    fn write(
        &mut self,
        record_batch: &RecordBatch,
    ) -> Result<(), DataStreamingError>;
}

Required Methods§

source

fn write( &mut self, record_batch: &RecordBatch, ) -> Result<(), DataStreamingError>

Implementors§