Module streaming 

Streaming pipeline components for real-time data processing

This module provides streaming capabilities including windowing strategies, online model updates, incremental processing, and real-time analytics.

Structs

StreamConfig

Stream processing configuration

StreamDataPoint

Data point in a stream

StreamStats

Stream processing statistics

StreamWindow

Window of stream data points

StreamingPipeline

Streaming pipeline processor

StreamingPipelineTrained

Trained state for StreamingPipeline

Enums

StateManagement

State management strategy

UpdateStrategy

Online learning update strategy

WindowingStrategy

Windowing strategy for stream processing