Struct parquet::file::writer::SerializedPageWriter
source · pub struct SerializedPageWriter<'a, W: Write> { /* private fields */ }
Expand description
A serialized implementation for Parquet PageWriter
.
Writes and serializes pages and metadata into output stream.
SerializedPageWriter
should not be used after calling close()
.
Implementations§
source§impl<'a, W: Write> SerializedPageWriter<'a, W>
impl<'a, W: Write> SerializedPageWriter<'a, W>
sourcepub fn new(sink: &'a mut TrackedWrite<W>) -> Self
pub fn new(sink: &'a mut TrackedWrite<W>) -> Self
Creates new page writer.
Trait Implementations§
source§impl<'a, W: Write + Send> PageWriter for SerializedPageWriter<'a, W>
impl<'a, W: Write + Send> PageWriter for SerializedPageWriter<'a, W>
source§fn write_page(&mut self, page: CompressedPage) -> Result<PageWriteSpec>
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. Read moresource§fn write_metadata(&mut self, metadata: &ColumnChunkMetaData) -> Result<()>
fn write_metadata(&mut self, metadata: &ColumnChunkMetaData) -> Result<()>
Writes column chunk metadata into the output stream/sink. Read more
Auto Trait Implementations§
impl<'a, W> Freeze for SerializedPageWriter<'a, W>
impl<'a, W> RefUnwindSafe for SerializedPageWriter<'a, W>where
W: RefUnwindSafe,
impl<'a, W> Send for SerializedPageWriter<'a, W>where
W: Send,
impl<'a, W> Sync for SerializedPageWriter<'a, W>where
W: Sync,
impl<'a, W> Unpin for SerializedPageWriter<'a, W>
impl<'a, W> !UnwindSafe for SerializedPageWriter<'a, W>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more