Struct DedupEntry 

pub struct DedupEntry<K, V> {
    pub key: K,
    pub value: V,
}

Fields

key: K

value: V

Implementations

impl<K, V> DedupEntry<K, V>

pub fn new(key: K, value: V) -> Self

Examples found in repository

examples/perf_features.rs (line 466)

fn dedup_streams(n: usize) -> Vec<std::vec::IntoIter<DedupEntry<u64, u64>>> {
    let per = n / STREAMS;
    (0..STREAMS)
        .map(|s| {
            (0..per)
                .map(move |i| {
                    let key = ((s + i * STREAMS) as u64) / 2;
                    DedupEntry::new(key, key)
                })
                .collect::<Vec<_>>()
                .into_iter()
        })
        .collect()
}

examples/sample_app.rs (line 189)

fn compact_last_prices() {
    use subms_merge_iterator::{DedupEntry, DedupMergeIterator};
    println!("\n== dedup: compact the last-price rows ==");
    let flushed = PRICE_FLUSHED
        .iter()
        .map(|&(k, v)| DedupEntry::new(k, v))
        .collect::<Vec<_>>();
    let memtable = PRICE_MEMTABLE
        .iter()
        .map(|&(k, v)| DedupEntry::new(k, v))
        .collect::<Vec<_>>();

    let compacted: Vec<(&str, i64)> =
        DedupMergeIterator::new([flushed.into_iter(), memtable.into_iter()])
            .map(|e| (e.key, e.value))
            .collect();
    println!("  compacted last prices: {compacted:?}");
    assert_eq!(compacted, vec![("AAPL", 152), ("MSFT", 300)]);
}

Trait Implementations

impl<K: Clone, V: Clone> Clone for DedupEntry<K, V>

fn clone(&self) -> DedupEntry<K, V>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<K: Debug, V: Debug> Debug for DedupEntry<K, V>

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

Formats the value using the given formatter.

impl<K: Eq, V: Eq> Eq for DedupEntry<K, V>

impl<K: PartialEq, V: PartialEq> PartialEq for DedupEntry<K, V>

fn eq(&self, other: &DedupEntry<K, V>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<K: PartialEq, V: PartialEq> StructuralPartialEq for DedupEntry<K, V>