Struct DagNode 

pub struct DagNode {
    pub id: NodeId,
    pub name: String,
    pub inputs: SmallVec<[EdgeId; 4]>,
    pub outputs: SmallVec<[EdgeId; 4]>,
    pub output_schema: SchemaRef,
    pub state_partition: StatePartitionId,
    pub node_type: DagNodeType,
}

A node in the DAG represents an operator or stage.

Nodes are created during topology construction in Ring 2 and are immutable once the DAG is finalized.

Fields

id: NodeId

Unique node identifier.

name: String

Human-readable name (e.g., “normalize”, “vwap”).

inputs: SmallVec<[EdgeId; 4]>

Upstream connections (fan-in). SmallVec avoids heap alloc for <= 4 inputs.

outputs: SmallVec<[EdgeId; 4]>

Downstream connections (fan-out). SmallVec avoids heap alloc for <= 4 outputs.

output_schema: SchemaRef

Output schema for downstream type checking.

state_partition: StatePartitionId

State partition assignment (for thread-per-core routing).

node_type: DagNodeType

Node classification for ring assignment.

Trait Implementations

impl Debug for DagNode

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

Formats the value using the given formatter.