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

//! Immutable configuration for sink (data modification) operators.

use linkrs_core::types::expr::Expression;

/// Copy target type for COPY FROM
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum CopyTarget {
    Vertex(String),
    Edge(String),
}

/// Immutable config for sink (data modification) operators.
#[derive(Debug, Clone)]
pub enum SinkSpec {
    InsertVertices {
        space_name: String,
        vertex_properties: Vec<(String, Expression)>,
        tag: String,
        /// Property column names for the single tag.
        tag_property_names: Vec<String>,
        if_not_exists: bool,
    },
    InsertEdges {
        space_name: String,
        src_col: String,
        dst_col: String,
        rank_col: String,
        edge_type: String,
        edge_properties: Vec<(String, Expression)>,
        if_not_exists: bool,
    },
    UpdateVertices {
        space_name: String,
        tag_name: String,
        updates: Vec<(String, Expression)>,
        condition: Option<Expression>,
        is_upsert: bool,
        replace_properties: bool,
    },
    UpdateEdges {
        space_name: String,
        src_col: String,
        dst_col: String,
        rank_col: String,
        edge_type: String,
        updates: Vec<(String, Expression)>,
        condition: Option<Expression>,
        is_upsert: bool,
        replace_properties: bool,
    },
    DeleteVertices {
        space_name: String,
        tag: String,
        vertex_id_col: String,
        cascade: bool,
    },
    DeleteEdges {
        space_name: String,
        src_col: String,
        dst_col: String,
        rank_col: String,
        edge_type: String,
    },
    PipeDeleteVertices {
        space_name: String,
        vertex_id_col: String,
        cascade: bool,
        vertex_id_is_literal: bool,
    },
    PipeDeleteEdges {
        space_name: String,
        src_col: String,
        dst_col: String,
        rank_col: String,
        edge_type: String,
    },
    CopyFrom {
        space_name: String,
        target: CopyTarget,
        file_paths: Vec<String>,
        by_column: bool,
        header: bool,
        delimiter: u8,
        batch_size: usize,
    },
    CopyTo {
        space_name: String,
        target: CopyTarget,
        file_path: String,
        header: bool,
        delimiter: u8,
    },
}