created file processing module
This commit is contained in:
11
src/processing_utils.cpp
Normal file
11
src/processing_utils.cpp
Normal file
@@ -0,0 +1,11 @@
|
|||||||
|
#include "processing_utils.hpp"
|
||||||
|
#include "spdlog/spdlog.h"
|
||||||
|
|
||||||
|
namespace processing_utils {
|
||||||
|
void process_to_eof(std::string path, std::shared_ptr<clickhouse::Client>client, bool compressed){
|
||||||
|
spdlog::info("Processing file {} ", path);
|
||||||
|
}
|
||||||
|
void process_blocking(std::string path, std::shared_ptr<clickhouse::Client> client){
|
||||||
|
spdlog::info("Processing file {}", path);
|
||||||
|
}
|
||||||
|
}
|
||||||
9
src/processing_utils.hpp
Normal file
9
src/processing_utils.hpp
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include "clickhouse/client.h"
|
||||||
|
#include <memory>
|
||||||
|
#include <string>
|
||||||
|
namespace processing_utils {
|
||||||
|
void process_to_eof(std::string path, std::shared_ptr<clickhouse::Client>client, bool compressed = true);
|
||||||
|
void process_blocking(std::string path, std::shared_ptr<clickhouse::Client> client);
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user