Struct CypherQueryOperator 

pub struct CypherQueryOperator {
    pub graph_store: Arc<RwLock<MemoryGraphStore>>,
    pub query: CypherQuery,
    pub graph_name: String,
    pub params: BTreeMap<String, Value>,
}

CypherQueryOperator — execute a parsed openCypher query against a named graph and project the resulting (start, end) vertex pairs into a posting list for downstream operator composition.

Routes through CypherWriter because it covers the full clause set, including CREATE/MERGE/SET/DELETE/UNWIND. Read-only queries still flow through the same path; the writer leaves the store untouched when the query is read-only.

Fields

graph_store: Arc<RwLock<MemoryGraphStore>>

query: CypherQuery

graph_name: String

params: BTreeMap<String, Value>

Implementations

impl CypherQueryOperator

pub fn new( graph_store: Arc<RwLock<MemoryGraphStore>>, query: CypherQuery, graph_name: impl Into<String>, ) -> Self

pub fn with_params(self, params: BTreeMap<String, Value>) -> Self

Trait Implementations

impl Operator for CypherQueryOperator

fn execute(&self, _ctx: &ExecutionContext) -> OperatorResult

fn cost_estimate(&self, stats: &IndexStats) -> f64