Added Partition Processor

This commit is contained in:
divanik 2024-11-14 11:58:09 +00:00
parent 123a5d38e0
commit 36bbd6dae9
2 changed files with 1 additions and 8 deletions

View File

@ -702,14 +702,8 @@ IcebergMetadata::create(ObjectStoragePtr object_storage, ConfigurationObserverPt
*/
DataFileInfos IcebergMetadata::getDataFileInfos(const ActionsDAG * filter_dag) const
{
<<<<<<< HEAD
// if (!data_file_infos.empty())
// return data_file_infos;
=======
auto configuration_ptr = configuration.lock();
if (!data_files.empty())
return data_files;
>>>>>>> 7a393dc140a3da46162e3ae2a8b5ac8af2f42778
Strings manifest_files;
if (manifest_list_file.empty())
@ -1052,7 +1046,6 @@ DataFileInfos IcebergMetadata::getDataFileInfos(const ActionsDAG * filter_dag) c
return data_file_infos;
}
}
#endif

View File

@ -252,7 +252,7 @@ public:
/// Get data files. On first request it reads manifest_list file and iterates through manifest files to find all data files.
/// All subsequent calls will return saved list of files (because it cannot be changed without changing metadata file)
DataFileInfos getDataFileInfos(const ActionsDAG * filter_dag) const override;
Strings getDataFileInfos() const override;
/// Get table schema parsed from metadata.
NamesAndTypesList getTableSchema() const override { return schema; }