Struct ParquetTableWriter 

pub struct ParquetTableWriter<Builder: Default + StructArrayBuilder> {
    pub autoflush_row_group_len: usize,
    pub autoflush_buffer_size: Option<usize>,
    /* private fields */
}

Writer to a .parquet file, usable with ParallelDatasetWriter

Builder should follow the pattern documented by arrow::builder

Fields

autoflush_row_group_len: usize

See ParquetTableWriterConfig::autoflush_row_group_len

autoflush_buffer_size: Option<usize>

See ParquetTableWriterConfig::autoflush_buffer_size

Implementations

impl<Builder: Default + StructArrayBuilder> ParquetTableWriter<Builder>

pub fn builder(&mut self) -> Result<&mut Builder>

Flushes the internal buffer is too large, then returns the array builder.

Trait Implementations

impl<Builder: Default + StructArrayBuilder> Drop for ParquetTableWriter<Builder>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<Builder: Default + StructArrayBuilder> TableWriter for ParquetTableWriter<Builder>

type Schema = (Arc<Schema>, WriterProperties)

type CloseResult = ParquetMetaData

type Config = ParquetTableWriterConfig

fn new( path: PathBuf, (schema, properties): Self::Schema, _: Self::Config, ) -> Result<Self>

fn flush(&mut self) -> Result<()>

Calls .into() on the internal builder, and writes its result to disk.

fn close(self) -> Result<ParquetMetaData>