Struct LineageTracker 

pub struct LineageTracker { /* private fields */ }

Tracks data lineage through pipeline stages.

Implementations

impl LineageTracker

pub fn new() -> Self

pub fn record( &mut self, stage: &str, operation: &str, row_count: Option<u64>, parent_ids: Vec<String>, ) -> String

Record a lineage node.

pub fn nodes(&self) -> &[LineageNode]

Get all lineage nodes.

pub fn to_dot(&self) -> String

Export lineage as DOT graph format.

pub fn to_json(&self) -> String

Export lineage as JSON.

pub fn to_text(&self) -> String

Export lineage as plain text.

Trait Implementations

impl Clone for LineageTracker

fn clone(&self) -> LineageTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LineageTracker

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

Formats the value using the given formatter.

impl Default for LineageTracker

fn default() -> LineageTracker

Returns the “default value” for a type.