Struct ext_sort::sort::ExternalSorter

pub struct ExternalSorter<T, E, B = LimitedBufferBuilder, C = RmpExternalChunk<T>> where
    T: Ord + Send,
    E: Error,
    B: ChunkBufferBuilder<T>,
    C: ExternalChunk<T>,  { /* fields omitted */ }

External sorter.

Implementations

impl<T, E, B, C> ExternalSorter<T, E, B, C> where
    T: Ord + Send,
    E: Error,
    B: ChunkBufferBuilder<T>,
    C: ExternalChunk<T>, 

pub fn new(
    threads_number: Option<usize>,
    tmp_path: Option<&Path>,
    buffer_builder: B,
    rw_buf_size: Option<usize>
) -> Result<Self, SortError<C::SerializationError, C::DeserializationError, E>>

Creates a new external sorter instance.

Arguments

• threads_number - Number of threads to be used to sort data in parallel. If the parameter is None threads number will be selected based on available CPU core number.
• tmp_path - Directory to be used to store temporary data. If paramater is None default OS temporary directory will be used.
• buffer_builder - An instance of a buffer builder that will be used for chunk buffer creation.
• rw_buf_size - Chunks file read/write buffer size.

pub fn sort<I>(
    &self,
    input: I
) -> Result<BinaryHeapMerger<T, C::DeserializationError, C>, SortError<C::SerializationError, C::DeserializationError, E>> where
    I: IntoIterator<Item = Result<T, E>>, 

Sorts data from input using external sort algorithm. Returns an iterator that can be used to get sorted data stream.