Struct AdvancedPipeline 

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

Advanced pipeline with caching and conditional steps

Implementations

impl<T> AdvancedPipeline<T>

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

pub fn new(config: AdvancedPipelineConfig) -> Self

pub fn add_step(self, transformer: T) -> Self

Add a simple transformation step

pub fn add_conditional_step(self, config: ConditionalStepConfig<T>) -> Self

Add a conditional step

pub fn add_parallel_branches( self, config: ParallelBranchConfig<T>, ) -> Result<Self>

Add parallel branches

pub fn add_cached_step(self, transformer: T, cache_key_prefix: String) -> Self

Add cached transformation step

pub fn add_streaming_step<S>(self, transformer: S, name: String) -> Self

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

Add a streaming transformation step

pub fn add_pca_step(self, _pca: PCA) -> Self

Add a dimensionality reduction step

pub fn cache_stats(&self) -> CacheStats

Get cache statistics

pub fn clear_cache(&self)

Clear pipeline cache

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

Incrementally fit streaming transformers in the pipeline

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

Get streaming statistics for all streaming steps

pub fn reset_streaming(&mut self)

Reset all streaming transformers in the pipeline

Trait Implementations

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

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

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

Transform the input data