nautilus_serialization::arrow

Trait WriteStream

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

Writes RecordBatch data to output streams.

Required Methods§

Source

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

Writes a RecordBatch to the implementing output stream.

§Errors

Returns a DataStreamingError if writing or finishing the stream fails.

Implementors§