Merge pull request #16 from yohplala/filters

Filters
yohplala · Apr 17, 2024 · f010a56 · f010a56
2 parents 45bdc63 + a082aab
commit f010a56
Show file tree

Hide file tree

Showing 27 changed files with 3,897 additions and 2,596 deletions.
diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml
@@ -88,12 +88,12 @@ repos:
                 tests/*.py:D103
                 oups/__init__.py:F401
                 oups/store/__init__.py:F401
-                oups/store/writer.py:C901
-                oups/streamagg/__init__.py:F401
-                oups/streamagg/jcumsegagg.py:C901
-                oups/streamagg/segmentby.py:C901
-                oups/streamagg/cumsegagg.py:C901 E203
-                oups/streamagg/streamagg.py:C901
+                oups/store/writer.py:C901 S403 S301
+                oups/aggstream/__init__.py:F401
+                oups/aggstream/jcumsegagg.py:C901
+                oups/aggstream/segmentby.py:C901
+                oups/aggstream/cumsegagg.py:C901 E203
+                oups/aggstream/aggstream.py:C901
         ]
 
   # Pydocstyle
@@ -136,3 +136,4 @@ repos:
 # RST210: Inline strong start-string without end-string (when describing **kwargs parameter)
 # S101: Use of assert detected (use of assert normal for pytest)
 # W503: Line break before binary operator
+# S403 & S301: Use of pickle to serialize / unserialize data.
diff --git a/oups/__init__.py b/oups/__init__.py
@@ -5,9 +5,9 @@
 @author: yoh
 
 """
+from .aggstream import AggStream
+from .aggstream import by_x_rows
 from .store import ParquetSet
 from .store import is_toplevel
 from .store import sublevel
 from .store import toplevel
-from .streamagg import by_x_rows
-from .streamagg import streamagg
diff --git a/oups/streamagg/__init__.py → oups/aggstream/__init__.py b/oups/streamagg/__init__.py → oups/aggstream/__init__.py
@@ -5,5 +5,5 @@
 @author: yoh
 
 """
+from .aggstream import AggStream
 from .segmentby import by_x_rows
-from .streamagg import streamagg