update

mllib-dal/src/main/native/CorrelationImpl.cpp

@@ -21,6 +21,13 @@
 #include "oneapi/dal/algo/covariance.hpp"
 #endif
 
+#ifndef ONEDAL_DATA_CONVERSION
+#define ONEDAL_DATA_CONVERSION
+#include "data_management/data_source/csv_feature_manager.h"
+#include "data_management/data_source/file_data_source.h"
+#undef ONEDAL_DATA_CONVERSION
+#endif
+
 #include "OneCCL.h"
 #include "com_intel_oap_mllib_stat_CorrelationDALImpl.h"
 #include "service.h"
@@ -148,6 +155,37 @@ static void doCorrelationDaalCompute(JNIEnv *env, jobject obj, size_t rankId,
     }
 }
 
+std::vector<std::string> get_file_path(const std::string& path) {
+    std::vector<std::string> result;
+    for (auto& file : fs::directory_iterator(path)){
+         if(fs::is_empty(file.path())){
+             continue;
+         }else if(file.path().extension()==".crc" || file.path().extension()==""){
+             continue;
+         }else{
+            result.push_back(file.path());
+         }
+    }
+    return result;
+}
+
+inline bool check_file(const std::string& name) {
+    return std::ifstream{ name }.good();
+}
+
+inline std::string get_data_path(const std::string& name) {
+    const std::vector<std::string> paths = { "./data", "samples/oneapi/dpc/mpi/data" };
+
+    for (const auto& path : paths) {
+        const std::string try_path = path + "/" + name;
+        if (check_file(try_path)) {
+            return try_path;
+        }
+    }
+
+    return name;
+}
+
 #ifdef CPU_GPU_PROFILE
 static void doCorrelationOneAPICompute(
     JNIEnv *env, jlong pNumTabData, long numRows, long numClos,