Struct parquet::arrow::arrow_writer::ArrowWriter [−][src]
pub struct ArrowWriter<W: ParquetWriter> { /* fields omitted */ }
Expand description
Arrow writer
Writes Arrow RecordBatch
es to a Parquet writer
Implementations
impl<W: 'static + ParquetWriter> ArrowWriter<W>
[src]
impl<W: 'static + ParquetWriter> ArrowWriter<W>
[src]pub fn try_new(
writer: W,
arrow_schema: SchemaRef,
props: Option<WriterProperties>
) -> Result<Self>
[src]
pub fn try_new(
writer: W,
arrow_schema: SchemaRef,
props: Option<WriterProperties>
) -> Result<Self>
[src]Try to create a new Arrow writer
The writer will fail if:
- a
SerializedFileWriter
cannot be created from the ParquetWriter - the Arrow schema contains unsupported datatypes such as Unions
pub fn write(&mut self, batch: &RecordBatch) -> Result<()>
[src]
pub fn write(&mut self, batch: &RecordBatch) -> Result<()>
[src]Write a RecordBatch to writer
NOTE: The writer currently does not support all Arrow data types
pub fn close(&mut self) -> Result<FileMetaData>
[src]
pub fn close(&mut self) -> Result<FileMetaData>
[src]Close and finalize the underlying Parquet writer
Auto Trait Implementations
impl<W> RefUnwindSafe for ArrowWriter<W> where
W: RefUnwindSafe,
W: RefUnwindSafe,
impl<W> Send for ArrowWriter<W> where
W: Send,
W: Send,
impl<W> Sync for ArrowWriter<W> where
W: Sync,
W: Sync,
impl<W> Unpin for ArrowWriter<W> where
W: Unpin,
W: Unpin,
impl<W> UnwindSafe for ArrowWriter<W> where
W: UnwindSafe,
W: UnwindSafe,
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,