PipelineNode

scirs2_core::ml_pipeline

Trait PipelineNode 

Source 
pub trait PipelineNode: Send + Sync {
    // Required methods
    fn name(&self) -> &str;
    fn input_schema(&self) -> &[FeatureSchema];
    fn output_schema(&self) -> &[FeatureSchema];
    fn process(&self, batch: DataBatch) -> Result<DataBatch, MLPipelineError>;
    fn validate(&self) -> Result<(), MLPipelineError>;
    fn metrics(&self) -> HashMap<String, f64>;
}
Expand description

Pipeline node trait for processing components

Required Methods§

Source

fn name(&self) -> &str

Get node name

Source

fn input_schema(&self) -> &[FeatureSchema]

Get input schema

Source

fn output_schema(&self) -> &[FeatureSchema]

Get output schema

Source

fn process(&self, batch: DataBatch) -> Result<DataBatch, MLPipelineError>

Process a batch of data

Source

fn validate(&self) -> Result<(), MLPipelineError>

Validate configuration

Source

fn metrics(&self) -> HashMap<String, f64>

Get node metrics

Implementors§