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 !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