renamed DeleteOutOfRangeValues to OutOfRangeValueFilter

Signed-off-by: mollle <[email protected]>
amosproj · Jan 15, 2025 · be0bceb · be0bceb
1 parent c42247c
commit be0bceb
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/__init__.py b/src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/__init__.py
@@ -19,5 +19,5 @@
 from .interval_filtering import IntervalFiltering
 from .k_sigma_anomaly_detection import KSigmaAnomalyDetection
 from .missing_value_imputation import MissingValueImputation
-from .delete_out_of_range_values import DeleteOutOfRangeValues
+from .delete_out_of_range_values import FilterOutOfRangeValues
 from .flatline_filter import FlatlineFilter
diff --git a/...ation/spark/delete_out_of_range_values.py → ...lation/spark/out_of_range_value_filter.py b/...ation/spark/delete_out_of_range_values.py → ...lation/spark/out_of_range_value_filter.py
@@ -26,7 +26,7 @@
 )
 
 
-class DeleteOutOfRangeValues(DataManipulationBaseInterface):
+class OutOfRangeValueFilter(DataManipulationBaseInterface):
     """
     Filters data in a DataFrame by checking the 'Value' column against expected ranges for specified TagNames.
     Logs events when 'Value' exceeds the defined ranges for any TagName and deletes the rows.

diff --git a/...dip_sdk/pipelines/data_quality/data_manipulation/spark/test_delete_out_of_range_values.py b/...dip_sdk/pipelines/data_quality/data_manipulation/spark/test_delete_out_of_range_values.py
@@ -4,7 +4,7 @@
 
 
 from src.sdk.python.rtdip_sdk.pipelines.data_quality.data_manipulation.spark.delete_out_of_range_values import (
-    DeleteOutOfRangeValues,
+    FilterOutOfRangeValues,
 )
 
 
@@ -41,7 +41,7 @@ def test_basic(spark, test_data):
         "A2PS64V0J.:ZUX09R": {"min": 2, "max": 4, "inclusive_bounds": True},
         "Tag2": {"min": 1, "max": 5, "inclusive_bounds": False},
     }
-    manipulator = DeleteOutOfRangeValues(test_data, tag_ranges)
+    manipulator = FilterOutOfRangeValues(test_data, tag_ranges)
 
     rows_to_remove = [
         {
@@ -74,7 +74,7 @@ def test_large_dataset(spark):
     tag_ranges = {
         "value_range": {"min": 2, "max": 4, "inclusive_bounds": True},
     }
-    manipulator = DeleteOutOfRangeValues(df, tag_ranges)
+    manipulator = FilterOutOfRangeValues(df, tag_ranges)
 
     rows_to_remove = [
         {