Struct ODPSImporter 

pub struct ODPSImporter { /* private fields */ }

ODPS importer for parsing ODPS YAML files

Implementations

impl ODPSImporter

pub fn new() -> ODPSImporter

Create a new ODPS importer instance

pub fn with_table_ids(table_ids: Vec<String>) -> ODPSImporter

Create a new ODPS importer with known table IDs for contractId validation

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

Import ODPS YAML content and create ODPSDataProduct

Arguments

• yaml_content - ODPS YAML content as a string

Returns

A ODPSDataProduct parsed from the YAML content

Example

use data_modelling_core::import::odps::ODPSImporter;

let importer = ODPSImporter::new();
let yaml = r#"
apiVersion: v1.0.0
kind: DataProduct
id: 550e8400-e29b-41d4-a716-446655440000
name: customer-data-product
version: 1.0.0
status: active
"#;
let product = importer.import(yaml).unwrap();
assert_eq!(product.name, Some("customer-data-product".to_string()));

Trait Implementations

impl Default for ODPSImporter

fn default() -> ODPSImporter

Returns the “default value” for a type.