thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-25 03:00:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Finalize CompressedWriteBuffer in TemporaryFileStream

Browse Source
This commit is contained in:
vdimir 2021-05-11 12:23:35 +03:00
parent 066d02dd2f
commit adb5fe2f30
No known key found for this signature in database
GPG Key ID: F57B3E10A21DBB31
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/DataStreams/TemporaryFileStream.h
View File

@ -19,7 +19,7 @@ struct TemporaryFileStream
CompressedReadBuffer compressed_in; CompressedReadBuffer compressed_in;
BlockInputStreamPtr block_in; BlockInputStreamPtr block_in;
TemporaryFileStream(const std::string & path) explicit TemporaryFileStream(const std::string & path)
: file_in(path) : file_in(path)
, compressed_in(file_in) , compressed_in(file_in)
, block_in(std::make_shared<NativeBlockInputStream>(compressed_in, DBMS_TCP_PROTOCOL_VERSION)) , block_in(std::make_shared<NativeBlockInputStream>(compressed_in, DBMS_TCP_PROTOCOL_VERSION))
@ -39,6 +39,7 @@ struct TemporaryFileStream
CompressedWriteBuffer compressed_buf(file_buf, CompressionCodecFactory::instance().get(codec, {})); CompressedWriteBuffer compressed_buf(file_buf, CompressionCodecFactory::instance().get(codec, {}));
NativeBlockOutputStream output(compressed_buf, 0, header); NativeBlockOutputStream output(compressed_buf, 0, header);
copyData(input, output, is_cancelled); copyData(input, output, is_cancelled);
compressed_buf.finalize();
} }
}; };