ENH: Data management update to support SUA ifaces for Homogen OneDAL tables

onedal/datatypes/_data_conversion.py

@@ -21,15 +21,14 @@
 from daal4py.sklearn._utils import make2d
 from onedal import _backend, _is_dpc_backend
 
+from .._device_offload import dpctl_available, dpnp_available
 from ..utils import _is_csr
 
-try:
-    import dpctl
+if dpctl_available:
     import dpctl.tensor as dpt
 
-    dpctl_available = dpctl.__version__ >= "0.14"
-except ImportError:
-    dpctl_available = False
+if dpnp_available:
+    import dpnp
 
 
 def _apply_and_pass(func, *args):
@@ -38,20 +37,39 @@ def _apply_and_pass(func, *args):
     return tuple(map(func, args))
 
 
-def from_table(*args):
-    return _apply_and_pass(_backend.from_table, *args)
-
-
-def convert_one_to_table(arg):
-    if dpctl_available:
-        if isinstance(arg, dpt.usm_ndarray):
-            return _backend.dpctl_to_table(arg)
+# TODO:
+# add warnings if no dpc backend.
+# TODO:
+# sparse for sua data.
+# TODO:
+# update it for each of the datafrmae format.
+# TODO:
+# update func use with args and kwargs with _apply_and_pass.
+def convert_one_from_table(table, sua_iface=None, xp=None):
+    # Currently only `__sycl_usm_array_interface__` protocol used to
+    # convert into dpnp/dpctl tensors.
+    if sua_iface:
+        return xp.asarray(table)
+    return _backend.from_table(table)
+
+
+# TODO:
+# add warnings if no dpc backend.
+# TODO:
+# sparse for sua data.
+def convert_one_to_table(arg, sua_iface=None):
+    if sua_iface and _is_dpc_backend:
+        return _backend.sua_iface_to_table(arg)
 
     if not _is_csr(arg):
         arg = make2d(arg)
     return _backend.to_table(arg)
 
 
+def from_table(*args):
+    return _apply_and_pass(convert_one_from_table, *args)
+
+
 def to_table(*args):
     return _apply_and_pass(convert_one_to_table, *args)
 

onedal/datatypes/data_conversion.cpp

@@ -23,7 +23,7 @@
 #include "oneapi/dal/table/detail/homogen_utils.hpp"
 
 #include "onedal/datatypes/data_conversion.hpp"
-#include "onedal/datatypes/numpy_helpers.hpp"
+#include "onedal/datatypes/utils/numpy_helpers.hpp"
 #include "onedal/version.hpp"
 
 #if ONEDAL_VERSION <= 20230100