dbsp 0.287.0

Continuous streaming analytics engine
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

use std::time::Duration;

/// A type that is partially ordered.
///
/// This trait is distinct from Rust's `PartialOrd` trait to allow for a
/// different ordering.  In particular, `PartialOrder` compares multidimensional
/// [`Timestamp`] representations for DBSP logical time, and `PartialOrd`
/// compares them for other purposes such as sorting.
///
/// [`Timestamp`]: crate::time::Timestamp
pub trait PartialOrder: Eq {
    /// Returns true if one element is strictly less than the other
    #[inline]
    fn less_than(&self, other: &Self) -> bool {
        self != other && self.less_equal(other)
    }

    /// Returns true if one element is less than or equal to the other
    fn less_equal(&self, other: &Self) -> bool;
}

pub trait TotalOrder: PartialOrder {}

macro_rules! impl_order {
    ($($type:ty),* $(,)?) => (
        $(
            impl PartialOrder for $type {
                #[inline]
                fn less_than(&self, other: &Self) -> bool {
                    self < other
                }

                #[inline]
                fn less_equal(&self, other: &Self) -> bool {
                    self <= other
                }
            }

            impl TotalOrder for $type {}
        )*
    )
}

// Implement `PartialOrder` and `TotalOrder` for primitive types
impl_order! {
    u8,
    u16,
    u32,
    u64,
    u128,
    usize,
    i8,
    i16,
    i32,
    i64,
    i128,
    isize,
    (),
    Duration,
}