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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

//! Logical traversal nodes: Expand, ExpandAll, Traverse, AppendVertices, BiExpand, BiTraverse.

use crate::define_logical_binary_input_node;
use crate::define_logical_plan_node;
use crate::define_logical_plan_node_with_deps;
use crate::planning::plan::core::common::{EdgeProp, TagProp};
use linkrs_core::types::expr::contextual::ContextualExpression;
use linkrs_core::types::EdgeDirection;
use linkrs_core::Value;

define_logical_plan_node! {
    pub struct LogicalExpandNode {
        space_id: u64,
        edge_types: Vec<String>,
        direction: EdgeDirection,
        step_limit: Option<u32>,
        filter: Option<ContextualExpression>,
        dst_tag: Option<String>,
    }
    enum: Expand
    input: MultipleInputNode
}

define_logical_plan_node! {
    pub struct LogicalExpandAllNode {
        space_id: u64,
        edge_types: Vec<String>,
        direction: String,
        any_edge_type: bool,
        step_limit: Option<u32>,
        step_limits: Option<Vec<u32>>,
        join_input: bool,
        sample: bool,
        edge_props: Vec<EdgeProp>,
        vertex_props: Vec<TagProp>,
        filter: Option<ContextualExpression>,
        src_vids: Vec<Value>,
        include_empty_paths: bool,
        input_var: Option<String>,
        path_semantic: Option<crate::parser::ast::pattern::PathSemantic>,
        dst_tag: Option<String>,
    }
    enum: ExpandAll
    input: MultipleInputNode
}

define_logical_plan_node_with_deps! {
    pub struct LogicalTraverseNode {
        space_id: u64,
        start_vids: String,
        end_vids: Option<String>,
        edge_types: Vec<String>,
        direction: EdgeDirection,
        min_steps: u32,
        max_steps: u32,
        edge_alias: Option<String>,
        vertex_alias: Option<String>,
        e_filter: Option<ContextualExpression>,
        v_filter: Option<ContextualExpression>,
        first_step_filter: Option<ContextualExpression>,
        path_semantic: Option<crate::parser::ast::pattern::PathSemantic>,
        dst_tag: Option<String>,
    }
    enum: Traverse
    input: SingleInputNode
}

define_logical_plan_node! {
    pub struct LogicalAppendVerticesNode {
        space_id: u64,
        vertex_tag: String,
        vertex_props: Vec<TagProp>,
        filter: Option<ContextualExpression>,
        input_var: Option<String>,
        src_expression: Option<ContextualExpression>,
        dedup: bool,
        need_fetch_prop: bool,
        vids: Vec<String>,
        tag_ids: Vec<i32>,
        v_filter: Option<ContextualExpression>,
        node_alias: Option<String>,
    }
    enum: AppendVertices
    input: MultipleInputNode
}

define_logical_binary_input_node! {
    pub struct LogicalBiExpandNode {
        space_id: u64,
        left_direction: EdgeDirection,
        right_direction: EdgeDirection,
        edge_types: Vec<String>,
        max_hops: usize,
        meeting_point_var: Option<String>,
        dst_tag: Option<String>,
    }
    enum: BiExpand
    input: BinaryInputNode
}

define_logical_binary_input_node! {
    pub struct LogicalBiTraverseNode {
        space_id: u64,
        left_src_var: String,
        right_src_var: String,
        edge_types: Vec<String>,
        left_direction: EdgeDirection,
        right_direction: EdgeDirection,
        min_hops: usize,
        max_hops: usize,
        path_var: String,
        edge_alias: Option<String>,
        vertex_alias: Option<String>,
        dst_tag: Option<String>,
    }
    enum: BiTraverse
    input: BinaryInputNode
}