pub struct FileWriter<W: Write> { /* private fields */ }
Expand description
An interface to write a parquet to a Write
Implementations§
source§impl<W: Write> FileWriter<W>
impl<W: Write> FileWriter<W>
sourcepub fn options(&self) -> WriteOptions
pub fn options(&self) -> WriteOptions
The options assigned to the file
sourcepub fn parquet_schema(&self) -> &SchemaDescriptor
pub fn parquet_schema(&self) -> &SchemaDescriptor
The SchemaDescriptor
assigned to this file
source§impl<W: Write> FileWriter<W>
impl<W: Write> FileWriter<W>
sourcepub fn try_new(writer: W, schema: Schema, options: WriteOptions) -> Result<Self>
pub fn try_new(writer: W, schema: Schema, options: WriteOptions) -> Result<Self>
sourcepub fn write(&mut self, row_group: RowGroupIter<'_, Error>) -> Result<()>
pub fn write(&mut self, row_group: RowGroupIter<'_, Error>) -> Result<()>
Writes a row group to the file.
sourcepub fn end(&mut self, key_value_metadata: Option<Vec<KeyValue>>) -> Result<u64>
pub fn end(&mut self, key_value_metadata: Option<Vec<KeyValue>>) -> Result<u64>
Writes the footer of the parquet file. Returns the total size of the file.
sourcepub fn into_inner(self) -> W
pub fn into_inner(self) -> W
Consumes this writer and returns the inner writer
sourcepub fn into_inner_and_metadata(self) -> (W, ThriftFileMetaData)
pub fn into_inner_and_metadata(self) -> (W, ThriftFileMetaData)
Returns the underlying writer and ThriftFileMetaData
§Panics
This function panics if Self::end
has not yet been called
Auto Trait Implementations§
impl<W> Freeze for FileWriter<W>where
W: Freeze,
impl<W> !RefUnwindSafe for FileWriter<W>
impl<W> Send for FileWriter<W>where
W: Send,
impl<W> Sync for FileWriter<W>where
W: Sync,
impl<W> Unpin for FileWriter<W>where
W: Unpin,
impl<W> !UnwindSafe for FileWriter<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