New cluster based drift detectors based on generic_single_movement

Fixes #1207

Author: Devindi97

src/mlpro/oa/streams/tasks/changedetectors/driftdetectors/clusterbased/size_change_detector.py

@@ -21,13 +21,14 @@
 from mlpro.oa.streams import OAStreamTask
 from mlpro.oa.streams.tasks.clusteranalyzers import ClusterAnalyzer, Cluster
 from mlpro.oa.streams.tasks.clusteranalyzers.clusters.properties.body import cprop_size_geo
-from mlpro.oa.streams.tasks.changedetectors.driftdetectors.drifts.clusterbased import DriftCBSize
+from mlpro.oa.streams.tasks.changedetectors.driftdetectors.drifts.clusterbased import DriftCBSize, DriftCBSizeGeo
 from mlpro.oa.streams.tasks.changedetectors.driftdetectors.clusterbased.generic import DriftDetectorCBGenSingleGradient
 
 
 
 # Export list for public API
-__all__ = [ 'DriftDetectorCBGenSizeChange' ]
+__all__ = [ 'DriftDetectorCBGenSizeChange',
+            'DriftDetectorCBGenGeoSizeChange' ]
 
 
 
@@ -57,6 +58,49 @@ def __init__( self,
                   p_thrs_inst : int = 0,
                   p_thrs_clusters : int = 1 ):
 
+        super().__init__( p_clusterer = p_clusterer,
+                          p_property = cprop_size_geo,
+                          p_thrs_lower = p_thrs_lower,
+                          p_thrs_upper = p_thrs_upper,
+                          p_cls_drift = p_cls_drift,
+                          p_name = p_name,
+                          p_range_max = p_range_max,
+                          p_ada = p_ada,
+                          p_duplicate_data = p_duplicate_data,
+                          p_visualize = p_visualize,
+                          p_logging = p_logging,
+                          p_drift_buffer_size = p_drift_buffer_size,
+                          p_thrs_inst = p_thrs_inst,
+                          p_thrs_clusters = p_thrs_clusters )
+        
+
+
+
+
+## -------------------------------------------------------------------------------------------------
+class DriftDetectorCBGenGeoSizeChange (DriftDetectorCBGenSingleGradient):
+    """
+    Cluster based Drift detector for the change of the cluster size.
+    """
+
+    C_NAME = 'Size'
+
+## -------------------------------------------------------------------------------------------------
+    def __init__( self,
+                  p_clusterer : ClusterAnalyzer,
+                  p_thrs_lower : float,
+                  p_thrs_upper : float,
+                  p_cls_drift : type = DriftCBSizeGeo,
+                  p_name : str = None,
+                  p_range_max = OAStreamTask.C_RANGE_THREAD,
+                  p_ada : bool = True,
+                  p_duplicate_data : bool = False,
+                  p_visualize : bool = False,
+                  p_logging=Log.C_LOG_ALL,
+                  p_drift_buffer_size : int = 100,
+                  p_thrs_inst : int = 0,
+                  p_thrs_clusters : int = 1 ):
+
         super().__init__( p_clusterer = p_clusterer,
                           p_property = cprop_size_geo,
                           p_thrs_lower = p_thrs_lower,

src/mlpro/oa/streams/tasks/changedetectors/driftdetectors/drifts/clusterbased/__init__.py

@@ -3,4 +3,5 @@
 from .deformation import *
 from .size import *
 from .density import *
-from .geometric_center import *
+from .geometric_center import *
+from .size_geo import *

src/mlpro/oa/streams/tasks/changedetectors/driftdetectors/drifts/clusterbased/size_geo.py

@@ -0,0 +1,34 @@
+## -------------------------------------------------------------------------------------------------
+## -- Project : MLPro - The integrative middleware framework for standardized machine learning
+## -- Package : mlpro.oa.tasks.driftdetectors.drifts.clusterbased
+## -- Module  : size_geo.py
+## -------------------------------------------------------------------------------------------------
+## -- History :
+## -- yyyy-mm-dd  Ver.      Auth.    Description
+## -- 2025-07-29  1.0.0     DS       Creation
+## -------------------------------------------------------------------------------------------------
+
+"""
+Ver. 1.0.0 (2025-07-29) 
+
+This module provides a sub-type of class DriftCB related to geometric cluster size.
+"""
+
+from mlpro.oa.streams.tasks.changedetectors.driftdetectors.drifts.clusterbased.basics import DriftCB
+
+
+
+# Export list for public API
+__all__ = [ 'DriftCBSizeGeo' ]
+
+
+
+
+## -------------------------------------------------------------------------------------------------
+## -------------------------------------------------------------------------------------------------
+class DriftCBSizeGeo (DriftCB):
+    """
+    Sub-type indicating the begin or end of a cluster size.
+    """
+
+    C_PLOT_ACTIVE   = True