thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 15:42:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixup

Browse Source
This commit is contained in:
alesapin 2021-10-05 13:41:09 +03:00
parent 64158c011b
commit 9aab0eb0a2
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Storages/MergeTree/MergeTreeReaderWide.cpp
View File

@ -234,13 +234,12 @@ void MergeTreeReaderWide::prefetch(
serialization->enumerateStreams([&](const ISerialization::SubstreamPath & substream_path)
{
bool seek_to_start = deserialize_binary_bulk_state_map.count(name) == 0;
String stream_name = ISerialization::getFileNameForStream(name_and_type, substream_path);
if (!prefetched_streams.count(stream_name))
{
bool seek_to_mark = !continue_reading;
if (ReadBuffer * buf = getStream(seek_to_start, substream_path, streams, name_and_type, from_mark, seek_to_mark, cache))
if (ReadBuffer * buf = getStream(false, substream_path, streams, name_and_type, from_mark, seek_to_mark, cache))
buf->prefetch();
prefetched_streams.insert(stream_name);
@ -265,10 +264,7 @@ void MergeTreeReaderWide::readData(
{
deserialize_settings.getter = [&](const ISerialization::SubstreamPath & substream_path)
{
/// If data was already prefetched we don't need to seek to start
bool seek_to_start = !was_prefetched;
bool seek_to_mark = !was_prefetched && !continue_reading;
return getStream(seek_to_start, substream_path, streams, name_and_type, from_mark, seek_to_mark, cache);
return getStream(/* seek_to_start = */true, substream_path, streams, name_and_type, from_mark, /* seek_to_mark = */false, cache);
};
serialization->deserializeBinaryBulkStatePrefix(deserialize_settings, deserialize_binary_bulk_state_map[name]);
}