Trait mz_persist_client::iter::RowSort

pub(crate) trait RowSort<T, D> {
    type Updates: Debug;
    type KV<'a>: Ord + Copy + Debug;

    // Required methods
    fn desired_sort(data: &FetchData<T>) -> bool;
    fn kv_lower(part: &FetchData<T>) -> Option<Self::KV<'_>>;
    fn updates_from_blob(&self, updates: BlobTraceUpdates) -> Self::Updates;
    fn len(updates: &Self::Updates) -> usize;
    fn get(
        updates: &Self::Updates,
        index: usize,
    ) -> Option<(Self::KV<'_>, T, D)>;
    fn interleave_updates<'a>(
        updates: &[&'a Self::Updates],
        elements: impl IntoIterator<Item = ((usize, usize), Self::KV<'a>, T, D)>,
    ) -> Self::Updates;
    fn updates_to_blob(&self, updates: Self::Updates) -> BlobTraceUpdates;
}

Required Associated Types

type Updates: Debug

type KV<'a>: Ord + Copy + Debug

Required Methods

fn desired_sort(data: &FetchData<T>) -> bool

fn kv_lower(part: &FetchData<T>) -> Option<Self::KV<'_>>

fn updates_from_blob(&self, updates: BlobTraceUpdates) -> Self::Updates

fn len(updates: &Self::Updates) -> usize

fn get(updates: &Self::Updates, index: usize) -> Option<(Self::KV<'_>, T, D)>

fn interleave_updates<'a>( updates: &[&'a Self::Updates], elements: impl IntoIterator<Item = ((usize, usize), Self::KV<'a>, T, D)>, ) -> Self::Updates

fn updates_to_blob(&self, updates: Self::Updates) -> BlobTraceUpdates

Object Safety

This trait is not object safe.

Implementors

impl<K: Codec, V: Codec, T: Codec64, D: Codec64> RowSort<T, D> for StructuredSort<K, V, T, D>

type Updates = StructuredUpdates

type KV<'a> = (ArrayIdx<'a>, Option<ArrayIdx<'a>>)

impl<T: Codec64, D: Codec64> RowSort<T, D> for CodecSort<T, D>

type Updates = BlobTraceUpdates

type KV<'a> = (&'a [u8], &'a [u8])