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
35
36
37
38
39
40
41

// 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 query_plan_operation;

pub use query_plan_operation::{
    CollectOp, GroupAggregateWindowOp, JoinOp, JoinWindowOp, LowerOps, ProjectionOp, UpperOps,
};

use crate::{
    expr_resolver::ExprResolver,
    pipeline::{PumpInputType, StreamName},
};

/// Query plan from which an executor can do its work deterministically.
#[derive(Clone, PartialEq, Debug, new)]
pub struct QueryPlan {
    pub upper_ops: UpperOps,
    pub lower_ops: LowerOps,

    /// to convert *Expr in *Syntax into *ExprLabel
    pub expr_resolver: ExprResolver,
}

impl QueryPlan {
    pub fn input_type(&self) -> PumpInputType {
        if self.upper_ops.has_window() || self.lower_ops.has_window() {
            PumpInputType::Window
        } else {
            PumpInputType::Row
        }
    }

    pub fn upstreams(&self) -> Vec<&StreamName> {
        match &self.lower_ops.join {
            JoinOp::Collect(collect) => vec![&collect.stream],
            JoinOp::JoinWindow(JoinWindowOp { left, right, .. }) => {
                vec![&left.stream, &right.stream]
            }
        }
    }
}