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
119
120
121
122
123

//! Logical data-modification nodes.
//!
//! Zero-input leaves carrying the same payload structs as their physical
//! counterparts, so lowering is a one-to-one rebuild.
//!
//! Single-input pipe variants carry an upstream input for streamed deletion.

use crate::define_logical_plan_node;
use crate::define_logical_plan_node_with_deps;
use crate::planning::plan::core::nodes::data_modification::{
    CopyTarget, EdgeDeleteInfo, EdgeInsertInfo, IndexDeleteInfo, UpdateTargetType,
    VertexDeleteInfo, VertexInsertInfo,
};

// ============================================================================
// Insert nodes
// ============================================================================

define_logical_plan_node! {
    pub struct LogicalInsertVerticesNode {
        info: VertexInsertInfo,
    }
    enum: InsertVertices
    input: ZeroInputNode
}

define_logical_plan_node! {
    pub struct LogicalInsertEdgesNode {
        info: EdgeInsertInfo,
    }
    enum: InsertEdges
    input: ZeroInputNode
}

// ============================================================================
// Update node
// ============================================================================

define_logical_plan_node! {
    pub struct LogicalUpdateNode {
        info: UpdateTargetType,
    }
    enum: Update
    input: ZeroInputNode
}

// ============================================================================
// Delete nodes (zero-input, standalone)
// ============================================================================

define_logical_plan_node! {
    pub struct LogicalDeleteVerticesNode {
        info: VertexDeleteInfo,
    }
    enum: DeleteVertices
    input: ZeroInputNode
}

define_logical_plan_node! {
    pub struct LogicalDeleteEdgesNode {
        info: EdgeDeleteInfo,
    }
    enum: DeleteEdges
    input: ZeroInputNode
}

define_logical_plan_node! {
    pub struct LogicalDeleteIndexNode {
        info: IndexDeleteInfo,
    }
    enum: DeleteIndex
    input: ZeroInputNode
}

// ============================================================================
// Pipe delete nodes (single-input, streamed from upstream)
// ============================================================================

define_logical_plan_node_with_deps! {
    pub struct LogicalPipeDeleteVerticesNode {
        info: VertexDeleteInfo,
    }
    enum: PipeDeleteVertices
    input: SingleInputNode
}

define_logical_plan_node_with_deps! {
    pub struct LogicalPipeDeleteEdgesNode {
        info: EdgeDeleteInfo,
    }
    enum: PipeDeleteEdges
    input: SingleInputNode
}

// ============================================================================
// Copy nodes (zero-input, bulk import/export)
// ============================================================================

define_logical_plan_node! {
    pub struct LogicalCopyFromNode {
        space_name: String,
        target: CopyTarget,
        file_paths: Vec<String>,
        by_column: bool,
        header: bool,
        delimiter: char,
        batch_size: usize,
    }
    enum: CopyFrom
    input: ZeroInputNode
}

define_logical_plan_node! {
    pub struct LogicalCopyToNode {
        space_name: String,
        target: CopyTarget,
        file_path: String,
        header: bool,
        delimiter: char,
    }
    enum: CopyTo
    input: ZeroInputNode
}