Struct parquet::file::writer::SerializedPageWriter

pub struct SerializedPageWriter<'a, W: Write> { /* private fields */ }

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

SerializedPageWriter should not be used after calling close().

Implementations

impl<'a, W: Write> SerializedPageWriter<'a, W>

pub fn new(sink: &'a mut TrackedWrite<W>) -> Self

Creates new page writer.

Trait Implementations

impl<'a, W: Write + Send> PageWriter for SerializedPageWriter<'a, W>

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.