From 2680e95eced519a5ada366a5f38997dbceaa9c04 Mon Sep 17 00:00:00 2001 From: albin-antony Date: Wed, 17 Jul 2024 12:13:08 +0530 Subject: [PATCH] s3select: add output definitions to parquet (#158) Signed-off-by: Albin Antony --- include/s3select.h | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/include/s3select.h b/include/s3select.h index 6bbd0f14..73691402 100644 --- a/include/s3select.h +++ b/include/s3select.h @@ -3029,6 +3029,9 @@ class parquet_object : public base_s3object public: + class csv_definitions : public s3select_csv_definitions + {}; + parquet_object(std::string parquet_file_name, s3select *s3_query,s3selectEngine::rgw_s3select_api* rgw) : base_s3object(s3_query),object_reader(nullptr) { try{ @@ -3082,10 +3085,10 @@ class parquet_object : public base_s3object return m_s3_select != nullptr; } - void set_parquet_object(std::string parquet_file_name, s3select *s3_query,s3selectEngine::rgw_s3select_api* rgw) //TODO duplicate code + void set_parquet_object(std::string parquet_file_name, s3select *s3_query,s3selectEngine::rgw_s3select_api* rgw,csv_definitions parquet) //TODO duplicate code { try{ - + m_csv_defintion = parquet; object_reader = new parquet_file_parser(parquet_file_name,rgw); //TODO uniq ptr } catch(std::exception &e) {