Struct datafusion::physical_plan::common::IPCWriter

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

Write in Arrow IPC format.

Fields

path: PathBuf

path

writer: FileWriter<File>

inner writer

num_batches: u64

batches written

num_rows: u64

rows written

num_bytes: u64

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