Struct DataPipeline 

pub struct DataPipeline { /* private fields */ }

Data pipeline

Implementations

impl DataPipeline

pub fn new() -> Self

pub fn initialize(&mut self) -> Result<(), MLError>

pub fn register_data_source(&mut self, source: DataSource)

Register a data source under its source id.

pub fn get_data_source(&self, source_id: &str) -> Option<&DataSource>

Get a registered data source by id.

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

List the ids of all registered data sources.

pub fn register_transformer(&mut self, transformer: DataTransformer)

Register a data transformer under its transformer id.

pub fn get_transformer(&self, transformer_id: &str) -> Option<&DataTransformer>

Get a registered data transformer by id.

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

List the ids of all registered data transformers.

pub fn register_loader(&mut self, loader: DataLoader)

Register a data loader under its loader id.

pub fn get_loader(&self, loader_id: &str) -> Option<&DataLoader>

Get a registered data loader by id.

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

List the ids of all registered data loaders.

pub fn register_augmenter(&mut self, augmenter: DataAugmenter)

Register a data augmenter under its augmenter id.

pub fn get_augmenter(&self, augmenter_id: &str) -> Option<&DataAugmenter>

Get a registered data augmenter by id.

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

List the ids of all registered data augmenters.