nautilus_serialization::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§