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

dbms: clarification [#METR-2944].

Browse Source
This commit is contained in:
Alexey Milovidov 2015-09-22 01:33:20 +03:00
parent 726443131b
commit 5df201add2
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
dbms/src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -2399,6 +2399,14 @@ BlockInputStreams StorageReplicatedMergeTree::read(
const size_t max_block_size,
const unsigned threads)
{
/** У таблицы может быть два вида данных:
* - реплицируемые данные;
* - старые, нереплицируемые данные - они лежат отдельно и их целостность никак не контролируется.
* А ещё движок таблицы предоставляет возможность использовать "виртуальные столбцы".
* Один из них - _replicated позволяет определить, из какой части прочитаны данные,
* или, при использовании в WHERE - выбрать данные только из одной части.
*/
Names virt_column_names;
Names real_column_names;
for (const auto & it : column_names)
@ -2421,7 +2429,7 @@ BlockInputStreams StorageReplicatedMergeTree::read(
column->getData()[1] = 1;
virtual_columns_block.insert(ColumnWithTypeAndName(column_ptr, new DataTypeUInt8, "_replicated"));
/// Если запрошен хотя бы один виртуальный столбец, пробуем индексировать
/// Если запрошен столбец _replicated, пробуем индексировать.
if (!virt_column_names.empty())
VirtualColumnUtils::filterBlockWithQuery(query, virtual_columns_block, context);
@ -2431,6 +2439,12 @@ BlockInputStreams StorageReplicatedMergeTree::read(
size_t part_index = 0;
/** Настройки parallel_replica_offset и parallel_replicas_count позволяют читать с одной реплики одну часть данных, а с другой - другую.
* Для реплицируемых, данные разбиваются таким же механизмом, как работает секция SAMPLE.
* А для нереплицируемых данных, так как их целостность между репликами не контролируется,
* с первой (settings.parallel_replica_offset == 0) реплики выбираются все данные, а с остальных - никакие.
*/
if ((settings.parallel_replica_offset == 0) && unreplicated_reader && values.count(0))
{
res = unreplicated_reader->read(real_column_names, query,