From 99e80339fcde75c397c30dceaad9001b3a06e155 Mon Sep 17 00:00:00 2001 From: Jack Del Vecchio Date: Tue, 9 Apr 2024 19:52:12 +0000 Subject: [PATCH] Make some methods, that should not have been public, private in ParquetReader. --- plugins/parquet/parquetembed.hpp | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/plugins/parquet/parquetembed.hpp b/plugins/parquet/parquetembed.hpp index 311ed707151..e011dcbc586 100644 --- a/plugins/parquet/parquetembed.hpp +++ b/plugins/parquet/parquetembed.hpp @@ -764,18 +764,21 @@ class PARQUETEMBED_PLUGIN_API ParquetReader ParquetReader(const char *option, const char *_location, int _maxRowCountInTable, const char *_partitionFields, const IThorActivityContext *_activityCtx); ParquetReader(const char *option, const char *_location, int _maxRowCountInTable, const char *_partitionFields, const IThorActivityContext *_activityCtx, const RtlRecord *_expectedRecord); ~ParquetReader(); - arrow::Status openReadFile(); + arrow::Status processReadFile(); - __int64 readColumns(__int64 currTable); - void splitTable(std::shared_ptr &table); bool shouldRead(); __int64 next(TableColumns *&nextTable); - std::shared_ptr queryCurrentTable(__int64 currTable); - arrow::Result> queryRows(); bool getCursor(MemoryBuffer & cursor); void setCursor(MemoryBuffer & cursor); +private: + arrow::Status openReadFile(); + __int64 readColumns(__int64 currTable); + void splitTable(std::shared_ptr &table); + std::shared_ptr queryCurrentTable(__int64 currTable); + arrow::Result> queryRows(); + private: // Count of processed rows and tables for both partitioned and regular files. __int64 tablesProcessed = 0; // The number of tables processed when reading parquet files.