MCPcopy Create free account
hub / github.com/ClickHouse/ClickHouse / wrapReadBufferWithCompressionMethod

Function wrapReadBufferWithCompressionMethod

src/IO/CompressionMethod.cpp:162–168  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

160}
161
162std::unique_ptr<ReadBuffer> wrapReadBufferWithCompressionMethod(
163 std::unique_ptr<ReadBuffer> nested, CompressionMethod method, int zstd_window_log_max, size_t buf_size, char * existing_memory, size_t alignment)
164{
165 if (method == CompressionMethod::None)
166 return nested;
167 return createCompressedWrapper(std::move(nested), method, buf_size, existing_memory, alignment, zstd_window_log_max);
168}
169
170
171template<typename WriteBufferT>

Callers 15

createReadBufferFunction · 0.85
nextMethod · 0.85
generateMethod · 0.85
nextMethod · 0.85
getMetadataJSONObjectFunction · 0.85
ChangelogReaderMethod · 0.85
initializePipelineMethod · 0.85

Calls 1

createCompressedWrapperFunction · 0.85

Tested by

no test coverage detected