Struct IPCWriter

pub struct IPCWriter {
    pub path: PathBuf,
    pub writer: FileWriter<File>,
    pub num_batches: usize,
    pub num_rows: usize,
    pub num_bytes: usize,
}

Write in Arrow IPC format.

Fields

path: PathBuf

Path

writer: FileWriter<File>

Inner writer

num_batches: usize

Batches written

num_rows: usize

Rows written

num_bytes: usize

Bytes written

Implementations

impl IPCWriter

pub fn new(path: &Path, schema: &Schema) -> Result<Self>

Create new writer

pub fn new_with_options( path: &Path, schema: &Schema, write_options: IpcWriteOptions, ) -> Result<Self>

Create new writer with IPC write options

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

Write one single batch

pub fn finish(&mut self) -> Result<()>

Finish the writer

pub fn path(&self) -> &Path

Path write to