| 3157 | } |
| 3158 | |
| 3159 | std::unique_ptr<ReadBuffer> IMergeTreeDataPart::readFile(const String & file_name) const |
| 3160 | { |
| 3161 | constexpr size_t size_hint = 4096; /// These files are small. |
| 3162 | auto read_settings = getReadSettings().adjustBufferSize(size_hint); |
| 3163 | /// Default read method is pread_threadpool, but there is not much point in it here. |
| 3164 | read_settings.local_fs_settings.method = LocalFSReadMethod::pread; |
| 3165 | auto res = getDataPartStorage().readFile(file_name, read_settings, size_hint); |
| 3166 | |
| 3167 | if (isCompressedFromFileName(file_name)) |
| 3168 | return std::make_unique<CompressedReadBufferFromFile>(std::move(res)); |
| 3169 | |
| 3170 | return res; |
| 3171 | } |
| 3172 | |
| 3173 | std::unique_ptr<ReadBuffer> IMergeTreeDataPart::readFileIfExists(const String & file_name) const |
| 3174 | { |
no test coverage detected