linkrs-query 0.1.0

Query engine, parser, and executor for Linkrs
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

//! Immutable configuration for apply operators.

use std::sync::Arc;

use crate::executor::streaming::plan::types::PhysicalPlan;
use linkrs_core::types::expr::Expression;

/// Immutable config for apply operators.
#[derive(Debug, Clone)]
pub enum ApplySpec {
    Apply {
        kind: ApplyKind,
        correlated_columns: Vec<String>,
    },
    PatternApply {
        hash_keys: Vec<Expression>,
        probe_keys: Vec<Expression>,
        anti: bool,
    },
    CorrelatedApply {
        /// Self-contained right subtree (rooted at an `Argument` source),
        /// re-executed once per outer row with the outer row bound as the
        /// correlation frame.
        sub_plan: Arc<PhysicalPlan>,
        anti: bool,
    },
    RollUpApply {
        compare_columns: Vec<String>,
        collect_column: Option<String>,
    },
}

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum ApplyKind {
    Standard,
    Semi,
    Anti,
    Single,
    All,
}