Struct swh_graph::utils::dataset_writer::ParallelDatasetWriter
source · pub struct ParallelDatasetWriter<W: TableWriter + Send> {
pub flush_threshold: Option<usize>,
/* private fields */
}
Expand description
Writes a set of files (called tables here) to a directory.
Fields§
§flush_threshold: Option<usize>
Implementations§
source§impl<W: TableWriter<Schema = ()> + Send> ParallelDatasetWriter<W>
impl<W: TableWriter<Schema = ()> + Send> ParallelDatasetWriter<W>
source§impl<W: TableWriter + Send> ParallelDatasetWriter<W>
impl<W: TableWriter + Send> ParallelDatasetWriter<W>
pub fn new_with_schema(path: PathBuf, schema: W::Schema) -> Result<Self>
sourcepub fn get_thread_writer(&self) -> Result<RefMut<'_, W>>
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.
sourcepub fn close(self) -> Result<Vec<W::CloseResult>>
pub fn close(self) -> Result<Vec<W::CloseResult>>
Closes all underlying writers
Trait Implementations§
source§impl<W: TableWriter + Send> Drop for ParallelDatasetWriter<W>
impl<W: TableWriter + Send> Drop for ParallelDatasetWriter<W>
Auto Trait Implementations§
impl<W> RefUnwindSafe for ParallelDatasetWriter<W>where <W as TableWriter>::Schema: RefUnwindSafe,
impl<W> Send for ParallelDatasetWriter<W>where <W as TableWriter>::Schema: Send,
impl<W> Sync for ParallelDatasetWriter<W>where <W as TableWriter>::Schema: Sync,
impl<W> Unpin for ParallelDatasetWriter<W>where <W as TableWriter>::Schema: Unpin,
impl<W> UnwindSafe for ParallelDatasetWriter<W>where W: UnwindSafe, <W as TableWriter>::Schema: UnwindSafe,
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
§impl<T, U> CastableInto<U> for Twhere
U: CastableFrom<T>,
impl<T, U> CastableInto<U> for Twhere U: CastableFrom<T>,
§impl<T> DowncastableFrom<T> for T
impl<T> DowncastableFrom<T> for T
§fn downcast_from(value: T) -> T
fn downcast_from(value: T) -> T
Truncate the current UnsignedInt to a possibly smaller size
§impl<T, U> DowncastableInto<U> for Twhere
U: DowncastableFrom<T>,
impl<T, U> DowncastableInto<U> for Twhere U: DowncastableFrom<T>,
§impl<T> Identity for Twhere
T: ?Sized,
impl<T> Identity for Twhere T: ?Sized,
§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> UpcastableFrom<T> for T
impl<T> UpcastableFrom<T> for T
§fn upcast_from(value: T) -> T
fn upcast_from(value: T) -> T
Extend the current UnsignedInt to a possibly bigger size.