Struct datafusion_physical_plan::common::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