Remove ROS extention (#324)

Author: shssf

sdc/_ros.cpp

@@ -48,13 +48,6 @@
 else:
     _has_pyarrow = True
 
-try:
-    from . import ros_cpp
-except ImportError:
-    _has_ros = False
-else:
-    _has_ros = True
-
 try:
     from . import cv_wrapper
 except ImportError:

sdc/config.py

@@ -639,21 +639,6 @@ def f(connect_tp, dset_tp, col_id_tp, schema_arr_tp, start_tp, count_tp):  # pra
             out += f_block.body[:-2]
             out[-1].target = assign.target
 
-        if (sdc.config._has_ros
-                and fdef == ('read_ros_images_inner', 'sdc.ros')
-                and self._is_1D_arr(rhs.args[0].name)):
-            arr = rhs.args[0].name
-            assert len(self._array_starts[arr]) == 4, "only 4D arrs in ros"
-            start_var = self._array_starts[arr][0]
-            count_var = self._array_counts[arr][0]
-            rhs.args += [start_var, count_var]
-
-            def f(arr, bag, start, count):  # pragma: no cover
-                return sdc.ros.read_ros_images_inner_parallel(arr, bag,
-                                                               start, count)
-
-            return self._replace_func(f, rhs.args)
-
         if (func_mod == 'sdc.hiframes.api' and func_name in (
                 'to_arr_from_series', 'ts_series_to_arr_typ',
                 'to_date_series_type', 'init_series')

sdc/distributed.py

@@ -476,9 +476,6 @@ def _analyze_call(self, lhs, rhs, func_var, args, array_dists):
         if fdef == ('file_read', 'sdc.io.np_io'):
             return
 
-        if sdc.config._has_ros and fdef == ('read_ros_images_inner', 'sdc.ros'):
-            return
-
         if sdc.config._has_pyarrow and fdef == ('read_parquet', 'sdc.io.parquet_pio'):
             return
 

sdc/distributed_analysis.py

@@ -432,9 +432,6 @@ def _run_call(self, assign, label):
         if fdef == ('to_numeric', 'pandas'):
             return self._handle_pd_to_numeric(assign, lhs, rhs)
 
-        if fdef == ('read_ros_images', 'sdc.ros'):
-            return self._handle_ros(assign, lhs, rhs)
-
         if isinstance(func_mod, ir.Var) and self._is_df_var(func_mod):
             return self._run_call_df(
                 assign, lhs, rhs, func_mod, func_name, label)
@@ -1088,12 +1085,6 @@ def f(arr_list):  # pragma: no cover
             return sdc.hiframes.api.init_series(sdc.hiframes.api.concat(arr_list))
         return self._replace_func(f, rhs.args)
 
-    def _handle_ros(self, assign, lhs, rhs):
-        if len(rhs.args) != 1:  # pragma: no cover
-            raise ValueError("Invalid read_ros_images() arguments")
-        import sdc.ros
-        return sdc.ros._handle_read_images(lhs, rhs)
-
     def _fix_df_arrays(self, items_list):
         nodes = []
         new_list = []