Add decomposition methods OnlineSVD, OnlinePCA, OnlineDMD/wC + Hankelizer

docs/unreleased.md

@@ -0,0 +1,21 @@
+# Unreleased
+
+## drift
+
+- Added `FHDDM` drift detector.
+- Added a `iter_polars` function to iterate over the rows of a polars DataFrame.
+
+## neighbors
+
+- Simplified `neighbors.SWINN` to avoid recursion limit and pickling issues.
+
+## decomposition
+
+- Added `decomposition.OnlineSVD` class to perform Singular Value Decomposition.
+- Added `decomposition.OnlinePCA` class to perform Principal Component Analysis.
+- Added `decomposition.OnlineDMD` class to perform Dynamic Mode Decomposition.
+- Added `decomposition.OnlineDMDwC` class to perform Dynamic Mode Decomposition with Control.
+
+## preprocessing
+
+- Added `preprocessing.Hankelizer` class to perform Hankelization of data stream.

river/compose/pipeline.py

@@ -471,11 +471,11 @@ def learn_one(self, x: dict, y=None, **params):
             # Here the step is not a transformer, and it's supervised, such as a LinearRegression.
             # This is usually the last step of the pipeline.
             elif step._supervised:
-                step.learn_one(x=x, y=y)
+                step.learn_one(x=x, y=y, **params)
             # Here the step is not a transformer, and it's unsupervised, such as a KMeans. This
             # is also usually the last step of the pipeline.
             else:
-                step.learn_one(x=x)
+                step.learn_one(x=x, **params)
 
     def _transform_one(self, x: dict):
         """This methods takes care of applying the first n - 1 steps of the pipeline, which are

river/decomposition/__init__.py

@@ -0,0 +1,16 @@
+"""Decomposition.
+
+"""
+from __future__ import annotations
+
+from .odmd import OnlineDMD, OnlineDMDwC
+from .opca import OnlinePCA
+from .osvd import OnlineSVD, OnlineSVDZhang
+
+__all__ = [
+    "OnlineSVD",
+    "OnlineSVDZhang",
+    "OnlineDMD",
+    "OnlineDMDwC",
+    "OnlinePCA",
+]