Struct LineageNode 

pub struct LineageNode {
    pub name: String,
    pub expression: Expression,
    pub source: Expression,
    pub downstream: Vec<LineageNode>,
    pub source_name: String,
    pub reference_node_name: String,
}

A node in the column lineage graph

Fields

name: String

Name of this lineage step (e.g., “table.column”)

expression: Expression

The expression at this node

source: Expression

The source expression (the full query context)

downstream: Vec<LineageNode>

Downstream nodes that depend on this one

source_name: String

Optional source name (e.g., for derived tables)

reference_node_name: String

Optional reference node name (e.g., for CTEs)

Implementations

impl LineageNode

pub fn new( name: impl Into<String>, expression: Expression, source: Expression, ) -> Self

Create a new lineage node

pub fn walk(&self) -> LineageWalker<'_>

Iterate over all nodes in the lineage graph using DFS

pub fn downstream_names(&self) -> Vec<String>

Get all downstream column names

Trait Implementations

impl Clone for LineageNode

fn clone(&self) -> LineageNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LineageNode

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

Formats the value using the given formatter.