Struct DynamicPipeline 

pub struct DynamicPipeline<T> { /* private fields */ }

Dynamic pipeline that can be modified at runtime

Implementations

impl<T> DynamicPipeline<T>

where T: Transform<Array2<f64>, Array2<f64>> + Clone + Send + Sync,

pub fn new(config: AdvancedPipelineConfig) -> Self

pub fn add_step_runtime(&self, transformer: T) -> Result<()>

Add step at runtime

pub fn add_streaming_step_runtime<S>( &self, transformer: S, name: String, ) -> Result<()>

where S: StreamingTransformer + Send + Sync + 'static,

Add streaming step at runtime

pub fn remove_step(&self, index: usize) -> Result<()>

Remove step by index

pub fn len(&self) -> usize

Get number of steps

pub fn is_empty(&self) -> bool

Check if pipeline is empty

pub fn partial_fit(&self, data: &Array2<f64>) -> Result<()>

Incrementally fit streaming transformers in the dynamic pipeline

pub fn get_streaming_stats( &self, ) -> Result<Vec<(String, Option<StreamingStats>)>>

Get streaming statistics for all streaming steps

pub fn reset_streaming(&self) -> Result<()>

Reset all streaming transformers in the dynamic pipeline

Trait Implementations

impl<T> Transform<ArrayBase<OwnedRepr<f64>, Dim<[usize; 2]>>> for DynamicPipeline<T>

where T: Transform<Array2<f64>, Array2<f64>> + Clone + Send + Sync,

fn transform(&self, data: &Array2<f64>) -> Result<Array2<f64>>

Transform the input data