Trait RecordBatchWriter

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

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.

Implementations on Foreign Types

impl<W> RecordBatchWriter for Writer<W>

where W: Write,

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, F> RecordBatchWriter for Writer<W, F>

where W: Write, F: JsonFormat,

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

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

Implementors