Struct bed_utils::extsort::ExternalSorter

pub struct ExternalSorter { /* private fields */ }

Implementations

impl ExternalSorter

pub fn sort<I, T, E>( &self, input: I ) -> Result<BinaryHeapMerger<T, ExternalChunkError, impl Fn(&T, &T) -> Ordering + Copy, ExternalChunk<T>>, SortError<E>>

where T: Serialize + DeserializeOwned + Send + Ord, I: IntoIterator<Item = Result<T, E>>, E: Error,

Sorts data from the input. Returns an iterator that can be used to get sorted data stream.

Arguments

• input - Input stream data to be fetched from

pub fn sort_by<I, T, E, F>( &self, input: I, cmp: F ) -> Result<BinaryHeapMerger<T, ExternalChunkError, F, ExternalChunk<T>>, SortError<E>>

where T: Serialize + DeserializeOwned + Send, I: IntoIterator<Item = Result<T, E>>, E: Error, F: Fn(&T, &T) -> Ordering + Sync + Send + Copy,

Sorts a given iterator with a comparator function, returning a new iterator with items