Struct parallel_processor::buckets::writers::compressed_binary_writer::CompressedBinaryWriter
source · pub struct CompressedBinaryWriter { /* private fields */ }Implementations§
source§impl CompressedBinaryWriter
impl CompressedBinaryWriter
pub const CHECKPOINT_SIZE_UNLIMITED: CompressedCheckpointSize = _
Trait Implementations§
source§impl LockFreeBucket for CompressedBinaryWriter
impl LockFreeBucket for CompressedBinaryWriter
type InitData = (MemoryFileMode, CompressedCheckpointSize, CompressionLevelInfo)
fn new( path_prefix: &Path, (file_mode, checkpoint_max_size, compression_level): &(MemoryFileMode, CompressedCheckpointSize, CompressionLevelInfo), index: usize ) -> Self
fn write_data(&self, bytes: &[u8])
fn get_path(&self) -> PathBuf
fn finalize(self)
impl Send for CompressedBinaryWriter
Auto Trait Implementations§
impl !Freeze for CompressedBinaryWriter
impl !RefUnwindSafe for CompressedBinaryWriter
impl Sync for CompressedBinaryWriter
impl Unpin for CompressedBinaryWriter
impl !UnwindSafe for CompressedBinaryWriter
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