Skip to main content

RecordBatchWriter

Trait RecordBatchWriter 

pub trait RecordBatchWriter {
    // Required methods
    fn write(&mut self, batch: &RecordBatch) -> Result<(), ArrowError>;
    fn close(self) -> Result<(), ArrowError>;
}
Expand description

Trait for types that can write RecordBatch’s.

Required Methods§

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

Write a single batch to the writer.

fn close(self) -> Result<(), ArrowError>

Write footer or termination data, then mark the writer as done.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types§

§

impl<W, F> RecordBatchWriter for Writer<W, F>
where W: Write, F: JsonFormat,

§

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

§

fn close(self) -> Result<(), ArrowError>

§

impl<W> RecordBatchWriter for FileWriter<W>
where W: Write,

§

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

§

fn close(self) -> Result<(), ArrowError>

§

impl<W> RecordBatchWriter for StreamWriter<W>
where W: Write,

§

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

§

fn close(self) -> Result<(), ArrowError>

§

impl<W> RecordBatchWriter for Writer<W>
where W: Write,

§

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

§

fn close(self) -> Result<(), ArrowError>

Implementors§