Struct mz_persist_client::iter::StructuredSort

pub struct StructuredSort<K: Codec, V: Codec, T, D> {
    schemas: Schemas<K, V>,
    _time_diff: PhantomData<fn(_: T, _: D)>,
}

Sort parts ordered by the codec-encoded key and value columns.

Fields

schemas: Schemas<K, V>

_time_diff: PhantomData<fn(_: T, _: D)>

Implementations

impl<K: Codec, V: Codec, T, D> StructuredSort<K, V, T, D>

pub fn new(schemas: Schemas<K, V>) -> Self

A sort for structured data with the given schema.

Trait Implementations

impl<K: Debug + Codec, V: Debug + Codec, T: Debug, D: Debug> Debug for StructuredSort<K, V, T, D>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

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>>)

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

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

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

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

fn kv_size((key, value): Self::KV<'_>) -> 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