Struct AdvancedPipelineBuilder 

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

Builder for creating advanced pipelines

Implementations

impl<T> AdvancedPipelineBuilder<T>

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

pub fn new() -> Self

pub fn with_cache_config(self, cache_config: CacheConfig) -> Self

pub fn with_error_strategy(self, strategy: ErrorHandlingStrategy) -> Self

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

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

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

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

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

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

pub fn build(self) -> AdvancedPipeline<T>

Trait Implementations

impl<T> Default for AdvancedPipelineBuilder<T>

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

fn default() -> Self

Returns the “default value” for a type.