rsp-rs 0.3.5

A RDF Stream Processing engine in Rust, supporting RSP-QL queries with sliding windows and real-time analytics
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

// Representing the instance of a Window.
#[derive(Debug, Clone)]
pub struct WindowInstance {
    pub open: i64,
    pub close: i64,
    pub has_triggered_and_emitted: bool,
}

// Implement PartialEq and Eq based only on open and close
impl PartialEq for WindowInstance {
    fn eq(&self, other: &Self) -> bool {
        self.open == other.open && self.close == other.close
    }
}

impl Eq for WindowInstance {}

// Implement Hash based only on open and close
impl std::hash::Hash for WindowInstance {
    fn hash<H: std::hash::Hasher>(&self, state: &mut H) {
        self.open.hash(state);
        self.close.hash(state);
    }
}

impl WindowInstance {
    pub fn new(open: i64, close: i64) -> Self {
        Self {
            open,
            close,
            has_triggered_and_emitted: false,
        }
    }

    pub fn set_triggered_and_emitted(&mut self, val: bool) {
        self.has_triggered_and_emitted = val;
    }

    pub fn is_same_window(&self, other: &WindowInstance) -> bool {
        self.open == other.open && self.close == other.close
    }
}