Struct parquet::file::writer::SerializedPageWriter

pub struct SerializedPageWriter<T: Write + Position> { /* fields omitted */ }

A serialized implementation for Parquet PageWriter. Writes and serializes pages and metadata into output stream.

SerializedPageWriter should not be used after calling close().

Methods

impl<T: Write + Position> SerializedPageWriter<T>

pub fn new(sink: T) -> Self

Creates new page writer.

Trait Implementations

impl<T: Write + Position> PageWriter for SerializedPageWriter<T>

fn write_page(&mut self, page: CompressedPage) -> Result<PageWriteSpec>

Writes a page into the output stream/sink. Returns PageWriteSpec that contains information about written page metrics, including number of bytes, size, number of values, offset, etc.

fn write_metadata(&mut self, metadata: &ColumnChunkMetaData) -> Result<()>

Writes column chunk metadata into the output stream/sink.

fn close(&mut self) -> Result<()>

Closes resources and flushes underlying sink. Page writer should not be used after this method is called.