ducklake 0.0.9

Rust SDK for DuckLake.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use indexmap::IndexMap;
use itertools::{EitherOrBoth, Itertools};

pub fn iter_index_map_diff<'a, K, V>(
    lhs: &'a IndexMap<K, V>,
    rhs: &'a IndexMap<K, V>,
) -> impl Iterator<Item = EitherOrBoth<(&'a K, &'a V)>>
where
    K: Ord,
{
    let iter_lhs = lhs.iter().sorted_by_key(|(k, _)| *k);
    let iter_rhs = rhs.iter().sorted_by_key(|(k, _)| *k);
    iter_lhs.merge_join_by(iter_rhs, |(k1, _), (k2, _)| k1.cmp(k2))
}

pub fn iter_vec_diff<'a, T, K>(
    lhs: &'a [T],
    rhs: &'a [T],
    key_fn: impl Fn(&T) -> K + 'a,
) -> impl Iterator<Item = EitherOrBoth<&'a T>>
where
    K: Ord,
{
    let iter_lhs = lhs.iter().sorted_by_key(|v| key_fn(v));
    let iter_rhs = rhs.iter().sorted_by_key(|v| key_fn(v));
    iter_lhs.merge_join_by(iter_rhs, move |v1, v2| key_fn(v1).cmp(&key_fn(v2)))
}