Struct CreateNodeOperator 

pub struct CreateNodeOperator { /* private fields */ }

Operator that creates new nodes.

For each input row, creates a new node with the specified labels and properties, then outputs the row with the new node.

Implementations

impl CreateNodeOperator

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

Creates a new node creation operator.

Arguments

• store - The graph store to modify.
• input - Optional input operator (None for standalone CREATE).
• labels - Labels to assign to created nodes.
• properties - Properties to set on created nodes.
• output_schema - Schema of the output.
• output_column - Column index where the created node ID goes.

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

Sets the transaction context for MVCC versioning.

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

Sets the constraint validator for schema enforcement.

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

Sets the write tracker for conflict detection.

Trait Implementations

impl Operator for CreateNodeOperator

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.