Enum UnarySpec 

pub enum UnarySpec {
    Filter {
        predicate: Expression,
        subquery_runners: Vec<SubqueryRunnerSpec>,
    },
    Project {
        output_expressions: Vec<Expression>,
        output_col_names: Vec<String>,
        output_col_types: Vec<DataType>,
        subquery_runners: Vec<SubqueryRunnerSpec>,
    },
    Limit {
        offset: u32,
        limit: u32,
    },
    Assign {
        assignments: Vec<(String, Expression)>,
        subquery_runners: Vec<SubqueryRunnerSpec>,
    },
    Unwind {
        unwind_column: String,
        list_expression: Option<Expression>,
    },
    AppendVertices {
        space_name: String,
        tag: String,
        entity_var: String,
        entity_expr: Expression,
        prop_names: Vec<String>,
    },
    Sample {
        count: u64,
    },
    Flatten {
        group_pos: u32,
        group_columns: Vec<String>,
        expected_groups: Option<u32>,
    },
}

Immutable config for unary (one-input) operators.

Variants

Filter

Fields

predicate: Expression

subquery_runners: Vec<SubqueryRunnerSpec>

Expression-level subqueries compiled for this filter; the materializer turns them into a per-operator SubqueryExecutor.

Project

Fields

output_expressions: Vec<Expression>

output_col_names: Vec<String>

output_col_types: Vec<DataType>

Resolved per-column types from the planner (ProjectNode.column_types). May be empty for hand-built plans; layouts fall back to untyped slots.

subquery_runners: Vec<SubqueryRunnerSpec>

Expression-level subqueries compiled for this project.

Limit

Fields

offset: u32

limit: u32

Assign

Fields

assignments: Vec<(String, Expression)>

subquery_runners: Vec<SubqueryRunnerSpec>

Expression-level subqueries compiled for this assign.

Unwind

Fields

unwind_column: String

list_expression: Option<Expression>

AppendVertices

Storage-backed vertex property append.

Evaluates entity_expr per input row to resolve the vertex id, reads the vertex (full or projected) from storage, and appends the property columns to the row. With a non-empty prop_names the appended columns are the flat {entity_var}.{prop} names; with an empty list the whole Value::Vertex is appended under entity_var.

Fields

space_name: String

Space the vertex is read from.

tag: String

Single tag for forced single-label fetch.

entity_var: String

Binding variable of the appended vertex (flat-column prefix).

entity_expr: Expression

Expression resolved per row to the vertex id.

prop_names: Vec<String>

Property names to read; empty reads the full vertex.

Sample

Fields

count: u64

Flatten

Fields

group_pos: u32

group_columns: Vec<String>

Alias names of the flattened group snapshotted at rewrite time.

Traceability metadata only; the executor never validates these names because the schema alias namespace and the runtime column namespace are not identical.

expected_groups: Option<u32>

Group count of the child schema at rewrite time, when known.

The executor rejects a stale group_pos (group_pos must be below this count) loudly at open(). None means unknown (hand-built or legacy plan) and skips the check honestly.

Implementations

impl UnarySpec

pub fn subquery_runners(&self) -> &[SubqueryRunnerSpec]

Expression-level subquery runner specs of this operator (empty for kinds that do not host subqueries). The materializer instantiates a per-operator SubqueryExecutor from these.

Trait Implementations

impl Clone for UnarySpec

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for UnarySpec

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

Formats the value using the given formatter.