@@ -87,20 +87,20 @@ TableScan::TableScan(std::unique_ptr<ScanContext> context,
8787 std::shared_ptr<FileIO> file_io)
8888 : context_(std::move(context)), file_io_(std::move(file_io)) {}
8989
90- Result<std::vector<std::unique_ptr <FileScanTask>>> TableScan::PlanFiles () const {
90+ Result<std::vector<std::shared_ptr <FileScanTask>>> TableScan::PlanFiles () const {
9191 ICEBERG_ASSIGN_OR_RAISE (auto manifest_list_reader,
9292 CreateManifestListReader (context_->snapshot_ ->manifest_list ));
9393 ICEBERG_ASSIGN_OR_RAISE (auto manifest_files, manifest_list_reader->Files ());
9494
95- std::vector<std::unique_ptr <FileScanTask>> tasks;
95+ std::vector<std::shared_ptr <FileScanTask>> tasks;
9696 for (const auto & manifest_file : manifest_files) {
9797 ICEBERG_ASSIGN_OR_RAISE (auto manifest_reader,
9898 CreateManifestReader (manifest_file->manifest_path ));
9999 ICEBERG_ASSIGN_OR_RAISE (auto manifests, manifest_reader->Entries ());
100100
101101 for (const auto & manifest : manifests) {
102102 const auto & data_file = manifest->data_file ;
103- tasks.emplace_back (std::make_unique <FileScanTask>(
103+ tasks.emplace_back (std::make_shared <FileScanTask>(
104104 data_file.file_path , 0 , data_file.file_size_in_bytes , data_file.record_count ,
105105 data_file.content , data_file.file_format , context_->schema_ ,
106106 context_->field_ids_ , context_->filter_ ));
0 commit comments