| 62 | } |
| 63 | |
| 64 | Stream Stream::line_reader_from_key( |
| 65 | const std::string& key, |
| 66 | const std::string& dst_key, |
| 67 | bool from_memory, |
| 68 | bool unzip, |
| 69 | const std::filesystem::path& local_prefix, |
| 70 | std::shared_ptr<core::FileFetcher> fetcher) const { |
| 71 | return Stream(std::make_shared<stream::LineReaderFromKey>( |
| 72 | self_, key, dst_key, from_memory, unzip, local_prefix, fetcher)); |
| 73 | } |
| 74 | |
| 75 | Stream Stream::dynamic_batch( |
| 76 | int64_t buffer_size, |
no test coverage detected