Struct SerializedPageWriter

pub struct SerializedPageWriter<'a, W: Write> {
    sink: &'a mut TrackedWrite<W>,
    page_encryptor: Option<PageEncryptor>,
}

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

SerializedPageWriter should not be used after calling close().

Fields

sink: &'a mut TrackedWrite<W>

page_encryptor: Option<PageEncryptor>

Implementations

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

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

Creates new page writer.

fn serialize_page_header(&mut self, header: PageHeader) -> Result<usize>

Serializes page header into Thrift. Returns number of bytes that have been written into the sink.

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

fn with_page_encryptor(self, page_encryptor: Option<PageEncryptor>) -> Self

Set the encryptor to use to encrypt page data

fn page_encryptor_mut(&mut self) -> Option<&mut PageEncryptor>

fn page_encryptor_and_sink_mut( &mut self, ) -> Option<(&mut PageEncryptor, &mut &'a mut TrackedWrite<W>)>

Trait Implementations

impl<W: Write + Send> PageWriter for SerializedPageWriter<'_, 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 close(&mut self) -> Result<()>

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