Expand description
Streaming executor — processes data in chunks through fitted filters.
Respects each filter’s StreamMode: FixedState processes chunks
independently, Evolving updates state per chunk with checkpoints,
Barrier accumulates all chunks before processing.
Structs§
- Fitted
Filter - A fitted filter with its learned state, ready for streaming.
- Stream
Executor - Processes a stream of chunks through a sequence of fitted filters.