Skip to main content

write_table

Function write_table 

Source
pub fn write_table(path: &Path, batch: &RecordBatch) -> Result<()>
Expand description

Write one table as a self-contained, checksummed, 64-byte-aligned IPC file and fsync it. Uncompressed on purpose: IPC body compression forces the reader to decompress into fresh allocations, which is mutually exclusive with the zero-copy mmap read path.

Never point this at a path some reader may have mapped. It truncates, and a mapping over a truncated file is a SIGBUS on the next page touched, not an error anyone can catch. Replacing a published table means staging a new file and renaming, which is what compact does.