Struct ExecutionContext 

pub struct ExecutionContext {

    pub results: Arc<RwLock<HashMap<String, ExecutionResult>>>,
    pub variables: Arc<RwLock<HashMap<String, Value>>>,
    pub expression_context: Arc<ExpressionAnalysisContext>,
    pub search: SearchContext,
    pub storage: Option<Arc<RwLock<dyn QueryStorage>>>,
    pub bound_snapshot: Option<SnapshotHandle>,
    pub space_name: Option<String>,
    pub parameters: Arc<HashMap<String, Value>>,
    pub session_variables: Arc<HashMap<String, Value>>,
    pub memory_budget: MemoryBudget,
    pub max_workers: usize,
    pub query_id: u64,
    pub cancel_token: Option<CancelToken>,
    pub chunk_size: usize,
    pub max_buffered_chunks: usize,
    pub shared_scheduler: Option<Arc<SharedScheduler>>,
    pub arena: Option<Arc<Mutex<Arena>>>,
    pub feedback_history: Option<Arc<QueryFeedbackHistory>>,
    pub columnar_policy: Option<Arc<ColumnarPolicy>>,
    pub join_algorithms: HashMap<i64, JoinAlgorithm>,
    pub isolation_level: Option<TransactionIsolationLevel>,
    pub ryw_config: Option<ReadYourWritesConfig>,
    pub sequence_manager: Option<Arc<SequenceManager>>,
    pub macro_manager: Option<Arc<MacroManager>>,
    pub type_alias_manager: Option<Arc<TypeAliasManager>>,
}

Fields

results: Arc<RwLock<HashMap<String, ExecutionResult>>>

variables: Arc<RwLock<HashMap<String, Value>>>

expression_context: Arc<ExpressionAnalysisContext>

search: SearchContext

Aggregated search backends (fulltext, vector, etc.).

storage: Option<Arc<RwLock<dyn QueryStorage>>>

bound_snapshot: Option<SnapshotHandle>

Snapshot handle pinned by the bound storage, when the storage was bound to a read/auto-commit operation context (storage boundary).

Populated by the pipeline when it binds the per-query storage; lets the execution layer observe which snapshot the query reads at.

space_name: Option<String>

parameters: Arc<HashMap<String, Value>>

session_variables: Arc<HashMap<String, Value>>

Session variable snapshot for this query (resolves Expression::SessionVariable); captured once per statement.

memory_budget: MemoryBudget

Per-query memory budget for blocking operators.

max_workers: usize

Maximum intra-query workers. 1 = serial only.

query_id: u64

Server-assigned query ID for KILL QUERY / cancellation support.

cancel_token: Option<CancelToken>

Request-scoped cancellation token threaded to the runtime/registry.

chunk_size: usize

Streaming chunk size (rows per chunk).

max_buffered_chunks: usize

Maximum buffered chunks before back-pressure.

shared_scheduler: Option<Arc<SharedScheduler>>

Engine-level shared scheduler.

arena: Option<Arc<Mutex<Arena>>>

Optional thread-safe bumpalo arena for executor temporary allocations.

feedback_history: Option<Arc<QueryFeedbackHistory>>

Shared query feedback history for collecting execution statistics.

Injected from the optimizer engine by the pipeline; the execution instance records estimated-vs-actual feedback here after execution.

columnar_policy: Option<Arc<ColumnarPolicy>>

Shared cross-query policy for the typed columnar chunk layout.

Injected from the optimizer engine by the pipeline; each query merges its columnar hit/miss counts back into the policy at completion.

join_algorithms: HashMap<i64, JoinAlgorithm>

Cost-based join algorithm decisions keyed by planner node id (CBO join-order decision channel).

Populated by the optimizer from the join reorder walker and consumed by the arena builder when converting InnerJoin/LeftJoin nodes. Absent keys fall back to the default heuristic (hash join for valid equi keys).

isolation_level: Option<TransactionIsolationLevel>

Transaction isolation level for this execution, when running inside an explicit transaction. Execution-time knob threaded from the API layer through crate::QueryContext; None = auto-commit.

ryw_config: Option<ReadYourWritesConfig>

Consistency requirement for secondary-index reads. None = eventual; Some(cfg) = read-your-writes with timeout and optional LSN.

sequence_manager: Option<Arc<SequenceManager>>

Sequence manager for curr_val/next_val functions.

macro_manager: Option<Arc<MacroManager>>

Macro catalog manager for user-defined macros (expansion + DDL).

type_alias_manager: Option<Arc<TypeAliasManager>>

Type-alias catalog manager for user-defined types.

Implementations

impl ExecutionContext

pub const DEFAULT_CHUNK_SIZE: usize = 2048

pub const DEFAULT_MAX_BUFFERED_CHUNKS: usize = 10

pub fn new(expression_context: Arc<ExpressionAnalysisContext>) -> Self

pub fn with_parameters( expression_context: Arc<ExpressionAnalysisContext>, parameters: HashMap<String, Value>, ) -> Self

pub fn with_memory_limit( expression_context: Arc<ExpressionAnalysisContext>, max_memory_per_query: u64, ) -> Self

Create a context with memory limit configured from a config value.

When max_memory_per_query is non-zero it overrides the default 512 MiB budget; otherwise the default is used.

pub fn set_result(&self, name: String, result: ExecutionResult)

pub fn get_result(&self, name: &str) -> Option<ExecutionResult>

pub fn set_variable(&self, name: String, value: Value)

pub fn get_variable(&self, name: &str) -> Option<Value>

pub fn expression_context(&self) -> &Arc<ExpressionAnalysisContext>

pub fn get_param(&self, name: &str) -> Option<&Value>

pub fn current_space_id(&self) -> Option<u64>

pub fn set_space_id(&self, space_id: u64)

pub fn sequence_manager(&self) -> Option<&Arc<SequenceManager>>

pub fn set_sequence_manager(&mut self, manager: Arc<SequenceManager>)

pub fn macro_manager(&self) -> Option<&Arc<MacroManager>>

pub fn set_macro_manager(&mut self, manager: Arc<MacroManager>)

pub fn type_alias_manager(&self) -> Option<&Arc<TypeAliasManager>>

pub fn set_type_alias_manager(&mut self, manager: Arc<TypeAliasManager>)

Trait Implementations

impl Clone for ExecutionContext

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ExecutionContext

fn default() -> Self

Returns the “default value” for a type.

impl ExpressionContext for ExecutionContext

fn get_variable(&self, name: &str) -> Option<Value>

Obtain the value of the variable

fn set_variable(&mut self, name: String, value: Value)

Setting variable values

fn get_function(&self, name: &str) -> Option<OwnedFunctionRef>

Obtain a function reference

fn get_sequence_manager(&self) -> Option<Arc<SequenceManager>>

Obtain the sequence catalog manager for curr_val / next_val. Default implementation returns None — contexts without sequence support report the functions’ missing-context error.

fn get_parameter(&self, _name: &str) -> Option<Value>

Obtain the value of a query parameter (@name). Default implementation returns None — contexts without parameter support simply ignore parameter references.

fn get_session_variable(&self, name: &str) -> Result<Value, ExpressionError>

Obtain the value of a session variable ($name).

fn get_variable_by_slot(&self, _slot: SlotId) -> Option<Value>

Obtain the value of a variable by slot ID (fast path). Default implementation falls back to name-based lookup.

fn get_graph_storage(&self) -> Option<GraphStorageRef>

Obtain the graph storage accessor for graph algorithm functions

fn supports_cache(&self) -> bool

Check whether the context supports caching.

fn get_cache(&mut self) -> Option<&mut ()>

Obtain the cache manager (if available).

fn execute_subquery( &mut self, body: &SubqueryBody, ) -> Result<Vec<Value>, ExpressionError>

Execute a subquery body and return the result values.

fn execute_exists( &mut self, body: &SubqueryBody, ) -> Result<bool, ExpressionError>

EXISTS semantics: whether the subquery produces at least one row.

fn contains_subquery( &mut self, body: &SubqueryBody, value: &Value, ) -> Result<Value, ExpressionError>

IN semantics: whether value occurs in the subquery result.

fn execute_scalar_subquery( &mut self, body: &SubqueryBody, ) -> Result<Value, ExpressionError>

Scalar-subquery semantics: the first result value, or NULL when the subquery returns no rows. Streaming contexts override this to dispatch through the hosting operator’s subquery executor.

fn evaluate_label(&self, label: &str) -> Result<Value, ExpressionError>

Evaluate a :Label expression against the current row binding.

fn evaluate_list_comprehension( &mut self, variable: &str, source: &Expression, filter: Option<&Expression>, map: Option<&Expression>, ) -> Result<Value, ExpressionError>

where Self: Sized,

Evaluate a list comprehension [variable IN source WHERE filter | map].

fn evaluate_label_tag_property( &mut self, tag: &Expression, property: &str, ) -> Result<Value, ExpressionError>

where Self: Sized,

Evaluate a dynamic tag-property access tag.property where tag is itself an expression.

fn evaluate_predicate( &mut self, func: &str, args: &[Expression], ) -> Result<Value, ExpressionError>

where Self: Sized,

Evaluate a predicate expression func(variable IN list WHERE predicate) with func in {ALL, ANY, SINGLE, NONE}.

fn evaluate_reduce( &mut self, accumulator: &str, initial: &Expression, variable: &str, source: &Expression, mapping: &Expression, ) -> Result<Value, ExpressionError>

where Self: Sized,

Evaluate a REDUCE expression reduce(acc = initial, variable IN source | mapping).

fn evaluate_path_build( &mut self, items: &[Expression], ) -> Result<Value, ExpressionError>

where Self: Sized,

Evaluate a path construction expression path(v1, e1, v2, e2, v3).