From ff99418b53440e1a559820c4b96a498d325754dd Mon Sep 17 00:00:00 2001
From: xinyi-xs <lihj@emqx.io>
Date: Fri, 10 Jan 2025 15:55:50 +0800
Subject: [PATCH] * FIX [parquet] remove file_system for parquet.

Signed-off-by: xinyi-xs <lihj@emqx.io>
---
 .../nanolib/parquet/parquet_file_queue.cc             | 11 +++++++++--
 src/supplemental/nanolib/parquet/parquet_file_queue.h |  2 --
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/src/supplemental/nanolib/parquet/parquet_file_queue.cc b/src/supplemental/nanolib/parquet/parquet_file_queue.cc
index ebc25cfd1..4a96b2fdb 100644
--- a/src/supplemental/nanolib/parquet/parquet_file_queue.cc
+++ b/src/supplemental/nanolib/parquet/parquet_file_queue.cc
@@ -2,6 +2,7 @@
 #include <unistd.h>
 
 #include <unistd.h>
+#include <sys/stat.h>
 
 // Constructor
 parquet_file_queue::parquet_file_queue(conf_parquet *node)
@@ -152,18 +153,24 @@ parquet_file_queue::has_md5_sum(const string &file_name)
 	return file_name.find("_") != string::npos;
 }
 
+
 bool
 parquet_file_queue::directory_exists(const std::string &directory_path)
 {
-	return fs::exists(directory_path) && fs::is_directory(directory_path);
+	struct stat buffer;
+	return (stat(directory_path.c_str(), &buffer) == 0 &&
+	    S_ISDIR(buffer.st_mode));
 }
 
 bool
 parquet_file_queue::create_directory(const std::string &directory_path)
 {
-	return fs::create_directory(directory_path);
+	int status = mkdir(
+	    directory_path.c_str(), S_IRWXU | S_IRWXG | S_IROTH | S_IXOTH);
+	return (status == 0);
 }
 
+
 int
 parquet_file_queue::remove_old_file(CircularQueue &queue)
 {
diff --git a/src/supplemental/nanolib/parquet/parquet_file_queue.h b/src/supplemental/nanolib/parquet/parquet_file_queue.h
index 567ae736d..6aa5ca4e3 100644
--- a/src/supplemental/nanolib/parquet/parquet_file_queue.h
+++ b/src/supplemental/nanolib/parquet/parquet_file_queue.h
@@ -9,13 +9,11 @@
 #include <algorithm>
 #include <cstdlib>
 #include <dirent.h>
-#include <filesystem>
 #include <iostream>
 #include <memory>
 #include <regex>
 #include <string>
 #include <vector>
-namespace fs = std::filesystem;
 
 using namespace std;