springql-core 0.18.1

SpringQL: Open-source stream processor for IoT devices and in-vehicle computers
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

// This file is part of https://github.com/SpringQL/SpringQL which is licensed under MIT OR Apache-2.0. See file LICENSE-MIT or LICENSE-APACHE for full license details.

mod stream_shape;

pub use stream_shape::StreamShape;

use crate::pipeline::{field::ColumnReference, name::StreamName};

#[derive(Clone, Eq, PartialEq, Debug, new)]
pub struct StreamModel {
    name: StreamName,
    shape: StreamShape,
}

impl StreamModel {
    pub fn name(&self) -> &StreamName {
        &self.name
    }

    pub fn shape(&self) -> &StreamShape {
        &self.shape
    }

    pub fn column_references(&self) -> Vec<ColumnReference> {
        self.shape
            .column_names()
            .iter()
            .map(|c| ColumnReference::Column {
                stream_name: self.name.clone(),
                column_name: c.clone(),
            })
            .collect()
    }
}