File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -513,6 +513,8 @@ class parquet_parser {
513513 const stdfs::path &file_path, Function fn,
514514 const size_t max_num_rows_to_read,
515515 std::optional<std::vector<std::string>> columns_to_read = std::nullopt ) {
516+ m_comm.log (log_level::info,
517+ std::string (" Beginning to read file " ) + file_path.string ());
516518 size_t num_read_rows = 0 ;
517519 try {
518520 // Create a ParquetReader instance
@@ -632,7 +634,14 @@ class parquet_parser {
632634 ++num_read_rows;
633635 }
634636 }
637+ std::string msg (" Finished reading file " );
638+ m_comm.log (log_level::info, msg + file_path.string ());
639+ // m_comm.log(log_level::info, "{}", msg);
635640 } catch (const std::exception &e) {
641+ std::string msg (" Error while reading file " );
642+ m_comm.log (
643+ log_level::error,
644+ msg + file_path.string () + std::string (" : " ) + std::string (e.what ()));
636645 // rethrow the exception
637646 std::cerr << " Error reading Parquet file: " << file_path << " "
638647 << e.what () << std::endl;
You can’t perform that action at this time.
0 commit comments