Struct QueryBindings 

pub struct QueryBindings {

    pub parameters: Arc<HashMap<String, Value>>,
    pub session_variables: Arc<HashMap<String, Value>>,
    pub parameter_frame: Option<ParameterFrame>,
    pub space_name: Option<String>,
    pub storage: Option<Arc<RwLock<dyn QueryStorage>>>,
    pub bound_snapshot: Option<SnapshotHandle>,
    pub memory_budget: MemoryBudget,
    pub max_workers: usize,
    pub chunk_size: usize,
    pub max_buffered_chunks: usize,
    pub query_id: u64,
    pub cancel_token: Option<CancelToken>,
    pub query_text: Option<String>,
    pub session_id: Option<String>,
    pub user_name: Option<String>,
    pub transaction: TransactionScope,
    pub shared_scheduler: Option<Arc<SharedScheduler>>,
    pub partition_count: usize,
    pub arena: Option<Arc<Mutex<Arena>>>,
    pub feedback_history: Option<Arc<QueryFeedbackHistory>>,
    pub columnar_policy: Option<Arc<ColumnarPolicy>>,
    pub macro_manager: Option<Arc<MacroManager>>,
    pub type_alias_manager: Option<Arc<TypeAliasManager>>,
    pub sequence_manager: Option<Arc<SequenceManager>>,
    pub search: SearchContext,
}

Per-execution bindings that parameterize a PhysicalPlan.

Unlike the plan (immutable, cacheable), QueryBindings carries data that changes per invocation: parameter values, storage handles, transaction scope, memory budget, and delivery preferences.

Multiple concurrent executions of the same plan each have their own QueryBindings, ensuring no mutable state is shared across instances.

carries a ParameterFrame for slot-based parameter access at execution time, built during validation from the plan’s parameter schema.

Fields

parameters: Arc<HashMap<String, Value>>

Prepared-statement parameter values (name → value map for validation).

session_variables: Arc<HashMap<String, Value>>

Session variable snapshot (name → value map), captured once per statement at the API layer and resolved by Expression::SessionVariable.

parameter_frame: Option<ParameterFrame>

slot-indexed parameter frame for hot-path access.

space_name: Option<String>

Target space name.

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

Storage client for this execution.

bound_snapshot: Option<SnapshotHandle>

Snapshot handle pinned by the bound storage (storage boundary).

Populated by the pipeline when the per-query storage is bound to a read/auto-commit operation context. None for unbound storage.

memory_budget: MemoryBudget

Per-query memory budget.

max_workers: usize

Maximum intra-query worker threads (1 = serial only).

chunk_size: usize

Rows per output chunk.

max_buffered_chunks: usize

Max buffered chunks per partition channel before back-pressure.

query_id: u64

Server-assigned query ID (for KILL QUERY / metrics).

cancel_token: Option<CancelToken>

Request-scoped cancellation token.

When present it is shared with the query registry and the execution runtime so QueryContext::mark_killed, KILL QUERY, and runtime cancel all flip the same underlying state.

query_text: Option<String>

Query text for diagnostics and logging.

session_id: Option<String>

Session ID for the executing session.

user_name: Option<String>

User name for the executing session.

transaction: TransactionScope

Transaction scope for this execution.

shared_scheduler: Option<Arc<SharedScheduler>>

Engine-level shared scheduler. When set, all queries share the same worker pool instead of creating per-query threads.

partition_count: usize

Number of partitions for partitioned execution. 0 = non-partitioned.

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.

When set, the execution instance records estimated-vs-actual operator feedback here after execution completes (stats feedback loop). Injected by the pipeline from the optimizer engine.

columnar_policy: Option<Arc<ColumnarPolicy>>

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

When set, the per-query columnar hit/miss counts are merged back into the policy when the query finishes (columnar auto-detection). Injected by the pipeline from the optimizer engine.

macro_manager: Option<Arc<MacroManager>>

Macro catalog manager (user-defined macros), shared engine-wide.

type_alias_manager: Option<Arc<TypeAliasManager>>

Type-alias catalog manager (user-defined types), shared engine-wide.

sequence_manager: Option<Arc<SequenceManager>>

Sequence catalog manager (named sequences), shared engine-wide.

search: SearchContext

Implementations

impl QueryBindings

pub fn from_context( context: &ExecutionContext, transaction: TransactionScope, ) -> Self

Build bindings from an [ExecutionContext] and a transaction scope.

pub fn build_parameter_frame(&mut self, schema: &ParameterSchema)

Build a ParameterFrame from the plan’s parameter schema and the binding values. Called after validation during materialization.

produces a slot-indexed frame that operators can read without string-based lookup.

Trait Implementations

impl Clone for QueryBindings

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 QueryBindings

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

Formats the value using the given formatter.