Struct ProcedureCallOperator 

pub struct ProcedureCallOperator { /* private fields */ }

Physical operator that executes a graph algorithm and yields its results.

On the first call to next(), the algorithm is executed and the full result is cached. Subsequent calls yield rows in chunks of CHUNK_SIZE until exhausted.

Implementations

impl ProcedureCallOperator

pub fn new( store: Arc<LpgStore>, algorithm: Arc<dyn GraphAlgorithm>, params: Parameters, yield_columns: Option<Vec<(String, Option<String>)>>, canonical_columns: Vec<String>, ) -> Self

Creates a new procedure call operator.

pub fn output_columns(&self) -> &[String]

Returns the output column names (available after first next() call).

Trait Implementations

impl Operator for ProcedureCallOperator

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.