Module streaming 

Streaming transformations for continuous data Streaming transformations for continuous data processing

This module provides utilities for processing data streams in real-time, maintaining running statistics and transforming data incrementally.

Structs

StreamingFeatureSelector

Streaming feature selector based on variance or correlation thresholds

StreamingMinMaxScaler

Streaming min-max scaler that tracks min and max values

StreamingOutlierDetector

Streaming outlier detector using statistical methods

StreamingPCA

Streaming Principal Component Analysis using incremental SVD

StreamingQuantileTracker

Streaming quantile tracker using P² algorithm

StreamingStandardScaler

Streaming standard scaler that maintains running statistics

WindowedStreamingTransformer

Window-based streaming transformer that maintains a sliding window

Enums

OutlierMethod

Methods for outlier detection in streaming data

Traits

StreamingTransformer

Trait for transformers that support streaming/incremental updates