Trait ext_sort::chunk::ExternalChunk

pub trait ExternalChunk<T>: Sized + Iterator<Item = Result<T, Self::DeserializationError>> {
    type SerializationError: Error;
    type DeserializationError: Error;
    fn new(reader: Take<BufReader<File>>) -> Self;
    fn dump(
        chunk_writer: &mut BufWriter<File>, 
        items: impl IntoIterator<Item = T>
    ) -> Result<(), Self::SerializationError>;

    fn build(
        dir: &TempDir, 
        items: impl IntoIterator<Item = T>, 
        buf_size: Option<usize>
    ) -> Result<Self, ExternalChunkError<Self::SerializationError>> { ... }
}

External chunk interface. Provides methods for creating a chunk stored on file system and reading data from it.

Associated Types

type SerializationError: Error

type DeserializationError: Error

Required methods

fn new(reader: Take<BufReader<File>>) -> Self

Creates and instance of an external chunk.

fn dump(
    chunk_writer: &mut BufWriter<File>,
    items: impl IntoIterator<Item = T>
) -> Result<(), Self::SerializationError>

Dumps items to an external file.

Provided methods

fn build(
    dir: &TempDir,
    items: impl IntoIterator<Item = T>,
    buf_size: Option<usize>
) -> Result<Self, ExternalChunkError<Self::SerializationError>>

Builds an instance of an external chunk.

Implementors

impl<T> ExternalChunk<T> for RmpExternalChunk<T> where
    T: Serialize + DeserializeOwned, 

type SerializationError = Error

type DeserializationError = Error