Struct parallel_processor::buckets::readers::generic_binary_reader::GenericChunkedBinaryReader

pub struct GenericChunkedBinaryReader<D: ChunkDecoder> { /* private fields */ }

Implementations

impl<D: ChunkDecoder> GenericChunkedBinaryReader<D>

pub fn new(
    name: impl AsRef<Path>,
    remove_file: RemoveFileMode,
    prefetch_amount: Option<usize>
) -> Self

pub fn get_length(&self) -> usize

pub fn get_chunks_count(&self) -> usize

pub fn is_finished(&self) -> bool

pub fn get_single_stream<'a>(&'a mut self) -> impl Read + 'a

pub fn get_read_parallel_stream(&self) -> Option<impl Read>

pub fn decode_bucket_items_parallel<E: BucketItem, F: for<'a> FnMut(E::ReadType<'a>, &mut E::ExtraDataBuffer)>(
    &self,
    buffer: E::ReadBuffer,
    extra_buffer: E::ExtraDataBuffer,
    func: F
) -> bool

Trait Implementations

impl<D: ChunkDecoder> BucketReader for GenericChunkedBinaryReader<D>

fn decode_all_bucket_items<E: BucketItem, F: for<'a> FnMut(E::ReadType<'a>, &mut E::ExtraDataBuffer)>(
    self,
    buffer: E::ReadBuffer,
    extra_buffer: &mut E::ExtraDataBuffer,
    func: F
)

fn get_name(&self) -> PathBuf

impl<D: ChunkDecoder> Drop for GenericChunkedBinaryReader<D>

fn drop(&mut self)

Executes the destructor for this type.

impl<D: ChunkDecoder> Sync for GenericChunkedBinaryReader<D>