Struct ParallelDatasetWriter 

pub struct ParallelDatasetWriter<W: TableWriter + Send> {
    pub config: W::Config,
    /* private fields */
}

Writes a set of files (called tables here) to a directory.

Fields

config: W::Config

Implementations

impl<W: TableWriter<Schema = ()> + Send> ParallelDatasetWriter<W>

where W::Config: Default,

pub fn new(path: PathBuf) -> Result<Self>

impl<W: TableWriter + Send> ParallelDatasetWriter<W>

where W::Config: Default,

pub fn with_schema(path: PathBuf, schema: W::Schema) -> Result<Self>

pub fn get_thread_writer(&self) -> Result<RefMut<'_, W>>

Returns a new sequential writer.

Panics

When called from a thread holding another reference to a sequential writer of this dataset.

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

Flushes all underlying writers

pub fn close(self) -> Result<Vec<W::CloseResult>>

Closes all underlying writers

Trait Implementations

impl<W: TableWriter + Send> Drop for ParallelDatasetWriter<W>

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.