Proposed addition: MemStream anomaly detection for River

[NicolasNoya]

Hi maintainers,

I would like to propose the addition of a MemStream implementation to the River library.

This work was carried out as part of a Data Streaming course, with the goal of implementing and integrating a state-of-the-art streaming anomaly detection method into an existing online learning framework. Given River’s focus on streaming and incremental learning, I believe MemStream is a strong conceptual and practical fit for the library.

Summary of the contribution

The implementation follows River’s coding standards, API conventions, and dependency constraints. It is based on the original code released by the authors of the MemStream paper and has been adapted to ensure full compatibility with River.

The contribution includes:

• A new module under river.anomaly introducing MemStream
• An abstract base class capturing the core MemStream pipeline
• Documentation and usage examples

Two concrete implementations:

• a denoising autoencoder–based MemStream
• a PCA-based MemStream

Documentation and usage examples

Before submitting or finalizing a pull request, I would greatly appreciate your feedback on whether this contribution would be suitable for inclusion in River, on the proposed placement of the implementation within the river.anomaly module, and on any modifications that may be required to better align the implementation with River’s conventions. I would be very happy to revise the contribution in response to your suggestions. Here is the link to the code: https://github.com/NicolasNoya/river/blob/feature/memStream/river/anomaly/memstream.py

Thank you for your time and for maintaining River.

Best regards,
NicolasNoya

P.S.: I have also included a notebook to illustrate and experiment with the model.
test_search.ipynb