Struct MutationContext 

pub struct MutationContext {
    pub executor: Executor,
    pub writer: Arc<Writer>,
    pub prop_manager: Arc<PropertyManager>,
    pub params: HashMap<String, Value>,
    pub query_ctx: Option<QueryContext>,
    pub tx_l0_override: Option<Arc<RwLock<L0Buffer>>>,
}

Shared context for mutation operators.

Contains all resources needed to execute write operations from within DataFusion ExecutionPlan operators. The Executor is Clone with all Arc-wrapped fields, so cloning it is cheap.

Fields

executor: Executor

The query executor (cheap clone, all Arc fields).

writer: Arc<Writer>

Writer for graph mutations (vertices, edges, properties).

prop_manager: Arc<PropertyManager>

Property manager for lazy-loading vertex/edge properties.

params: HashMap<String, Value>

Query parameters (e.g., $param references in Cypher).

query_ctx: Option<QueryContext>

Query context for L0 buffer visibility.

tx_l0_override: Option<Arc<RwLock<L0Buffer>>>

When set, mutations are routed to this private L0 buffer instead of the global L0. Passed explicitly to Writer methods during mutation execution.

Trait Implementations

impl Clone for MutationContext

fn clone(&self) -> MutationContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MutationContext

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

Formats the value using the given formatter.