Struct SourceOperator 

pub struct SourceOperator {
    pub kind: SourceOperatorKind,
    pub runtime: Option<Arc<ExecutionRuntime>>,
    pub output_layout: Arc<SlotLayout>,
    pub config: OperatorConfig,
    pub frame: Option<(Arc<SlotLayout>, Vec<Value>)>,
}

Source operator.

Wraps SourceOperatorKind with the runtime context injected at open(). Lifecycle state is owned exclusively by the executor; operators never write it.

Fields

kind: SourceOperatorKind

runtime: Option<Arc<ExecutionRuntime>>

output_layout: Arc<SlotLayout>

config: OperatorConfig

frame: Option<(Arc<SlotLayout>, Vec<Value>)>

Correlation frame bound to this operator instance by a parent executor (StreamingExecutor::inject_correlation_frame). Consumed (one-shot) by Argument. Per-instance, so parallel partitions and nested subqueries never share or overwrite frames.

Implementations

impl SourceOperator

pub fn from_spec( spec: &SourceSpec, storage: Option<Arc<RwLock<dyn QueryStorage>>>, output_layout: Arc<SlotLayout>, ) -> Self

Create a SourceOperator with immutable config from an immutable spec and the per-query storage client. Mutable runtime state is created separately in SourceOperator::open and stored in the operator state arena on the execution runtime.

pub fn new(kind: SourceOperatorKind, output_layout: Arc<SlotLayout>) -> Self

pub fn set_semi_mask(&mut self, ids: Vec<u32>)

Install a join or expand semi-mask on a vertex scan. The mask decodes exactly the given global internal ids instead of enumerating the table. Must be called before open; opening without a tag fails.

pub fn inject_context( &mut self, runtime: Option<&Arc<ExecutionRuntime>>, config: OperatorConfig, )

Inject the runtime and execution config (called once by the executor before this operator produces any data).

pub fn open(&mut self) -> Result<(), QueryError>

pub fn next(&mut self) -> Result<Option<DataChunk>, QueryError>

pub fn stop(&mut self) -> Result<(), QueryError>

pub fn reset(&mut self) -> Result<bool, QueryError>

Rewind this source so it re-produces the same logical stream.

Buffered sources reset their row index; storage-backed sources re-open their cursor (the query-level snapshot guarantees identical re-reads); Argument/GetProp keep their injected frame/state and Start un-emits its single row.

pub fn close(&mut self) -> Result<(), QueryError>

Trait Implementations

impl Debug for SourceOperator

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

Formats the value using the given formatter.