Enum SourceOperatorKind 

pub enum SourceOperatorKind {
    ScanVertices {
        buffer: Vec<Vec<Value>>,
        current_index: usize,
        col_names: Vec<String>,
    },
    CteScan {
        cte_name: String,
        col_names: Vec<String>,
        buffer: Vec<Vec<Value>>,
        current_index: usize,
    },
    StandaloneValues {
        values: Vec<Vec<ContextualExpression>>,
        buffer: Vec<Vec<Value>>,
        current_index: usize,
        col_names: Vec<String>,
    },
    StorageScanVertices {

        storage: Option<Arc<RwLock<dyn QueryStorage>>>,
        space_name: String,
        limit: Option<usize>,
        partition_range: Option<Range<i64>>,
        shard_slice: Option<ShardSlice>,
        col_names: Vec<String>,
        projected_properties: Vec<Arc<str>>,
        identity_only: bool,
        skip_rows: bool,
        predicate: Vec<ScanPredicate>,
        tag: Option<String>,
        semi_mask: Option<Vec<u32>>,
        cursor: Option<Box<dyn VertexCursor>>,
    
},
    ScanEdges {
        buffer: Vec<Vec<Value>>,
        current_index: usize,
        col_names: Vec<String>,
    },
    StorageScanEdges {
        storage: Option<Arc<RwLock<dyn QueryStorage>>>,
        space_name: String,
        limit: Option<usize>,
        edge_type: Option<String>,
        shard_slice: Option<ShardSlice>,
        col_names: Vec<String>,
        projected_properties: Vec<Arc<str>>,
        identity_only: bool,
        predicate: Vec<ScanPredicate>,
        cursor: Option<Box<dyn EdgeCursor>>,
    },
    GetVertices {
        storage: Option<Arc<RwLock<dyn QueryStorage>>>,
        space_name: String,
        tag: String,
        vertex_ids: Option<Vec<Value>>,
        cached_ids: Vec<VertexId>,
        projected_properties: Vec<Arc<str>>,
    },
    GetEdges {
        storage: Option<Arc<RwLock<dyn QueryStorage>>>,
        space_name: String,
        edge_type: Option<String>,
        src: Option<String>,
        dst: Option<String>,
        rank: i64,
        projected_properties: Vec<Arc<str>>,
        cursor: Option<Box<dyn EdgeCursor>>,
    },
    GetNeighbors {
        storage: Option<Arc<RwLock<dyn QueryStorage>>>,
        space_name: String,
        tag: String,
        direction: String,
        projected_properties: Vec<Arc<str>>,
        state: NeighborScanState,
    },
    IndexScan {
        storage: Option<Arc<RwLock<dyn QueryStorage>>>,
        space_name: String,
        index_name: String,
        index_id: u64,
        tag: String,
        predicate: BoundIndexPredicate,
        projection: IndexProjection,
        output_layout: Arc<SlotLayout>,
        partition_range: Option<Range<i64>>,
        cursor: Option<Box<dyn IndexCursor<Row = IndexRow>>>,
        edge_type_names: HashMap<u32, String>,
    },
    Argument,
    GetProp {
        storage: Option<Arc<RwLock<dyn QueryStorage>>>,
        space_name: String,
        entity_slot: usize,
        prop_names: Vec<String>,
        is_vertex: bool,
        output_layout: Arc<SlotLayout>,
    },
    Start,
}

Source operator kind with arena-based state for counters.

Heavy mutable resources (cursors) are kept inline for practical lifetime management; simple counters and state machines live in the SourceState arena on the execution runtime.

Variants

ScanVertices

Buffered vertex scan — rows come from the spec.

Fields

buffer: Vec<Vec<Value>>

current_index: usize

col_names: Vec<String>

CteScan

Recursive-CTE working-table scan — rows are snapshotted from the enclosing fixpoint operator’s published table at open()/reset() (once per step iteration) and served from the in-kind buffer.

Fields

cte_name: String

col_names: Vec<String>

buffer: Vec<Vec<Value>>

current_index: usize

StandaloneValues

Standalone DML values. Expressions are evaluated once in open() (i.e. once per execution) so volatile expressions such as now() are resolved at execution time.

Fields

values: Vec<Vec<ContextualExpression>>

buffer: Vec<Vec<Value>>

current_index: usize

col_names: Vec<String>

StorageScanVertices

Storage-backed vertex scan — rows come from a storage cursor.

Fields

storage: Option<Arc<RwLock<dyn QueryStorage>>>

space_name: String

limit: Option<usize>

partition_range: Option<Range<i64>>

shard_slice: Option<ShardSlice>

Shard slice dividing enumeration across partitions (see the spec field): forwarded into the storage scan options at open.

col_names: Vec<String>

projected_properties: Vec<Arc<str>>

identity_only: bool

Identity mode (from the scan annotation): emit Value::VertexId in the entity column and skip the per-row property map.

skip_rows: bool

Rowless mode: skip the row view, emit typed columns only. Honored only when the columnar path is on.

predicate: Vec<ScanPredicate>

Scan predicates pushed into the storage layer.

tag: Option<String>

Tag-restricted scan: only rows of this tag are scanned at the storage layer.

semi_mask: Option<Vec<u32>>

Optional semi-mask pushed from join or expand: decode exactly these global internal ids instead of enumerating the table.

cursor: Option<Box<dyn VertexCursor>>

ScanEdges

Buffered edge scan — rows come from the spec.

Fields

buffer: Vec<Vec<Value>>

current_index: usize

col_names: Vec<String>

StorageScanEdges

Storage-backed edge scan — rows come from a storage cursor.

Fields

storage: Option<Arc<RwLock<dyn QueryStorage>>>

space_name: String

limit: Option<usize>

edge_type: Option<String>

shard_slice: Option<ShardSlice>

col_names: Vec<String>

projected_properties: Vec<Arc<str>>

identity_only: bool

Identity mode (from the scan annotation): emit Value::EdgeHeader in the entity column and skip the per-row property map.

predicate: Vec<ScanPredicate>

Scan predicates pushed into the storage layer.

cursor: Option<Box<dyn EdgeCursor>>

GetVertices

Fetch vertices by ID.

Fields

storage: Option<Arc<RwLock<dyn QueryStorage>>>

space_name: String

tag: String

vertex_ids: Option<Vec<Value>>

cached_ids: Vec<VertexId>

projected_properties: Vec<Arc<str>>

GetEdges

Fetch edges by src/dst/type/rank.

Fields

storage: Option<Arc<RwLock<dyn QueryStorage>>>

space_name: String

edge_type: Option<String>

src: Option<String>

dst: Option<String>

rank: i64

projected_properties: Vec<Arc<str>>

cursor: Option<Box<dyn EdgeCursor>>

GetNeighbors

Traverse neighbors of each input vertex.

Fields

storage: Option<Arc<RwLock<dyn QueryStorage>>>

space_name: String

tag: String

direction: String

projected_properties: Vec<Arc<str>>

state: NeighborScanState

IndexScan

Index scan with typed predicate and projection.

Fields

storage: Option<Arc<RwLock<dyn QueryStorage>>>

space_name: String

index_name: String

index_id: u64

tag: String

predicate: BoundIndexPredicate

projection: IndexProjection

output_layout: Arc<SlotLayout>

partition_range: Option<Range<i64>>

cursor: Option<Box<dyn IndexCursor<Row = IndexRow>>>

edge_type_names: HashMap<u32, String>

Argument

GetProp

Property retrieval as a zero-input source (prefer the unary GetV).

Fields

storage: Option<Arc<RwLock<dyn QueryStorage>>>

space_name: String

entity_slot: usize

prop_names: Vec<String>

is_vertex: bool

output_layout: Arc<SlotLayout>

Start

Trait Implementations

impl Debug for SourceOperatorKind

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

Formats the value using the given formatter.