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

//! Planner module for generating execution plans from AST
//! Contains the Planner trait, ExecutionPlan structure, and various specific planners
//!
//! # Planning Pipeline
//!
//! The planning process consists of:
//! 1. AST to Execution Plan conversion
//! 2. Heuristic optimization (via `optimizer::heuristic`)
//! 3. Cost-based optimization (via `optimizer::cost_based`)
//!
//! Note: The heuristic rewrite module has been moved to `optimizer::heuristic`.

// Core modules
pub mod connector;
pub mod context;
pub mod physical_mapper;
pub mod physical_planner;
pub mod plan;
pub mod planner;
pub mod template_extractor;

// Planner modules
pub mod fulltext_planner;
#[cfg(feature = "vector")]
pub mod vector_planner;

// Modules organized by function
pub mod join_order;
pub mod scan_predicate;
pub mod statements;

// DML shape normalization for plan-cache reuse.
pub mod dml_shape;

// Re-export the main types.
pub use connector::SegmentsConnector;
pub use plan::execution_plan::{ExecutionPlan, SubPlan};
pub use planner::{Planner, PlannerConfig, PlannerError};
pub use template_extractor::{ParameterizedResult, ParameterizingTransformer, TemplateExtractor};

// Re-export the JoinType from the core module.
pub use linkrs_core::types::JoinType;
pub use statements::MatchStatementPlanner;

// Export related to static registration
pub use planner::PlannerEnum;

use std::sync::atomic::{AtomicI64, Ordering};

pub struct PlanIdGenerator {
    counter: AtomicI64,
}

impl PlanIdGenerator {
    pub fn instance() -> &'static Self {
        static INSTANCE: PlanIdGenerator = PlanIdGenerator {
            counter: AtomicI64::new(0),
        };
        &INSTANCE
    }

    pub fn next_id(&self) -> i64 {
        self.counter.fetch_add(1, Ordering::SeqCst)
    }
}