| 278 | } |
| 279 | |
| 280 | Status DiscoverFilesFromDir(const std::shared_ptr<fs::LocalFileSystem>& local_fs, |
| 281 | const std::string& dirpath, |
| 282 | std::vector<fs::FileInfo>* rel_fpaths) { |
| 283 | // Define a selector for a recursive descent |
| 284 | fs::FileSelector selector; |
| 285 | selector.base_dir = dirpath; |
| 286 | selector.recursive = true; |
| 287 | |
| 288 | ARROW_ASSIGN_OR_RAISE(auto file_infos, local_fs->GetFileInfo(selector)); |
| 289 | for (auto& file_info : file_infos) { |
| 290 | if (file_info.IsFile()) { |
| 291 | rel_fpaths->push_back(std::move(file_info)); |
| 292 | } |
| 293 | } |
| 294 | |
| 295 | return Status::OK(); |
| 296 | } |
| 297 | |
| 298 | } // namespace |
| 299 | |