diff --git a/src/processing_utils.cpp b/src/processing_utils.cpp new file mode 100644 index 0000000..0dfb889 --- /dev/null +++ b/src/processing_utils.cpp @@ -0,0 +1,11 @@ +#include "processing_utils.hpp" +#include "spdlog/spdlog.h" + +namespace processing_utils { + void process_to_eof(std::string path, std::shared_ptrclient, bool compressed){ + spdlog::info("Processing file {} ", path); + } + void process_blocking(std::string path, std::shared_ptr client){ + spdlog::info("Processing file {}", path); + } +} diff --git a/src/processing_utils.hpp b/src/processing_utils.hpp new file mode 100644 index 0000000..cf8d85f --- /dev/null +++ b/src/processing_utils.hpp @@ -0,0 +1,9 @@ +#pragma once + +#include "clickhouse/client.h" +#include +#include +namespace processing_utils { + void process_to_eof(std::string path, std::shared_ptrclient, bool compressed = true); + void process_blocking(std::string path, std::shared_ptr client); +}