Struct SetPropertyOperator 

pub struct SetPropertyOperator { /* private fields */ }

Operator that sets properties on nodes or edges.

This operator reads node/edge IDs from a column and sets the specified properties on each entity.

Implementations

impl SetPropertyOperator

pub fn new_for_node( store: Arc<dyn GraphStoreMut>, input: Box<dyn Operator>, node_column: usize, properties: Vec<(String, PropertySource)>, output_schema: Vec<LogicalType>, ) -> Self

Creates a new set property operator for nodes.

pub fn new_for_edge( store: Arc<dyn GraphStoreMut>, input: Box<dyn Operator>, edge_column: usize, properties: Vec<(String, PropertySource)>, output_schema: Vec<LogicalType>, ) -> Self

Creates a new set property operator for edges.

pub fn with_replace(self, replace: bool) -> Self

Sets whether this operator replaces all properties (for map assignment).

pub fn with_validator(self, validator: Arc<dyn ConstraintValidator>) -> Self

Sets the constraint validator for schema enforcement.

pub fn with_labels(self, labels: Vec<String>) -> Self

Sets the entity labels (for node constraint validation).

pub fn with_edge_type(self, edge_type: String) -> Self

Sets the edge type name (for edge constraint validation).

pub fn with_transaction_context( self, epoch: EpochId, transaction_id: Option<TransactionId>, ) -> Self

Sets the transaction context for versioned property mutations.

When a transaction ID is provided, property changes are recorded in an undo log so they can be restored on rollback.

pub fn with_write_tracker(self, tracker: SharedWriteTracker) -> Self

Sets the write tracker for conflict detection.

Trait Implementations

impl Operator for SetPropertyOperator

fn next(&mut self) -> OperatorResult

Pulls the next batch of data. Returns None when exhausted.

fn reset(&mut self)

Resets to initial state so you can iterate again.

fn name(&self) -> &'static str

Returns a name for debugging/explain output.