Struct LineageNode 

pub struct LineageNode {
    pub name: String,
    pub expression: Option<Expr>,
    pub source_name: Option<String>,
    pub source: Option<Expr>,
    pub downstream: Vec<LineageNode>,
    pub alias: Option<String>,
    pub depth: usize,
}

A node in the lineage graph representing a column or expression.

Fields

name: String

The name of this column/expression (e.g., “a”, “SUM(b)”, “t.col”).

expression: Option<Expr>

The AST expression this node represents.

source_name: Option<String>

The source table/CTE/subquery name, if applicable.

source: Option<Expr>

Reference to the source AST (for complex expressions).

downstream: Vec<LineageNode>

Child nodes (upstream lineage - where data comes from).

alias: Option<String>

The alias, if this is an aliased expression.

depth: usize

Depth in the lineage graph (0 = root output column).

Implementations

impl LineageNode

pub fn new(name: String) -> Self

Create a new lineage node.

pub fn with_source(self, source_name: String) -> Self

Create a node with source information.

pub fn with_expression(self, expr: Expr) -> Self

Create a node with an expression.

pub fn with_alias(self, alias: String) -> Self

Create a node with an alias.

pub fn with_depth(self, depth: usize) -> Self

Create a node with depth.

pub fn add_downstream(&mut self, node: LineageNode)

Add a downstream (upstream lineage) node.

pub fn walk<F>(&self, visitor: &mut F)

where F: FnMut(&LineageNode),

Walk through all nodes in the lineage graph (pre-order).

pub fn iter(&self) -> LineageIterator<'_>

Iterate over all nodes in the lineage graph.

pub fn source_columns(&self) -> Vec<&LineageNode>

Get all source columns (leaf nodes) in this lineage.

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

Get all source table names referenced in this lineage.

pub fn to_dot(&self) -> String

Generate DOT format representation for visualization.

pub fn to_mermaid(&self) -> String

Generate Mermaid diagram representation.

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.