Struct DataFlowImporter 

pub struct DataFlowImporter;

Data Flow format importer

Implementations

impl DataFlowImporter

pub fn new() -> Self

Create a new Data Flow importer instance.

Example

use data_modelling_sdk::import::dataflow::DataFlowImporter;

let importer = DataFlowImporter::new();

pub fn import(&self, yaml_content: &str) -> Result<DataModel, ImportError>

Import Data Flow format YAML content and create DataModel.

Arguments

• yaml_content - Data Flow format YAML content as a string

Returns

A DataModel containing the extracted nodes and relationships.

Example

use data_modelling_sdk::import::dataflow::DataFlowImporter;

let importer = DataFlowImporter::new();
let yaml = r#"
nodes:
  - name: user_events
    metadata:
      owner: "Data Engineering Team"
      infrastructure_type: "Kafka"
"#;
let model = importer.import(yaml).unwrap();

Trait Implementations

impl Default for DataFlowImporter

fn default() -> Self

Returns the “default value” for a type.