Struct AvroImporter 

pub struct AvroImporter;

Parser for AVRO schema format.

Implementations

impl AvroImporter

pub fn new() -> AvroImporter

Create a new AVRO parser instance.

Example

use data_modelling_core::import::avro::AvroImporter;

let importer = AvroImporter::new();

pub fn import(&self, avro_content: &str) -> Result<ImportResult, ImportError>

Import AVRO schema content and create Table(s) (SDK interface).

Arguments

• avro_content - AVRO schema as JSON string (can be a single record or array of records)

Returns

An ImportResult containing extracted tables and any parse errors.

Example

use data_modelling_core::import::avro::AvroImporter;

let importer = AvroImporter::new();
let schema = r#"
{
  "type": "record",
  "name": "User",
  "fields": [
    {"name": "id", "type": "long"}
  ]
}
"#;
let result = importer.import(schema).unwrap();

Trait Implementations

impl Default for AvroImporter

fn default() -> AvroImporter

Returns the “default value” for a type.