Struct StreamingTransformerWrapper 

pub struct StreamingTransformerWrapper { /* private fields */ }

Wrapper for streaming transformers to work in regular pipelines

Implementations

impl StreamingTransformerWrapper

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

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

Create a new wrapper for a streaming transformer

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

Incrementally fit the streaming transformer

pub fn is_fitted(&self) -> bool

Check if the wrapper is fitted

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

Get streaming statistics

pub fn reset(&mut self)

Reset the streaming transformer

pub fn name(&self) -> &str

Get the name of the streaming transformer

Trait Implementations

impl Clone for StreamingTransformerWrapper

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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

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

Transform the input data