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§
Sourcefn write(&mut self, batch: &RecordBatch) -> Result<(), ArrowError>
fn write(&mut self, batch: &RecordBatch) -> Result<(), ArrowError>
Write a single batch to the writer.
Sourcefn close(self) -> Result<(), ArrowError>
fn close(self) -> Result<(), ArrowError>
Write footer or termination data, then mark the writer as done.