ключ партиционирования. Есть таблица
```
CREATE TABLE smth.users_all
(
`id` UInt64,
`created_at` SimpleAggregateFunction( max, DateTime64 (6)),
`registration_country` SimpleAggregateFunction(anyLast, LowCardinality (Nullable (String))),
`device` SimpleAggregateFunction(argMin, Tuple (Nullable (String), Nullable (DateTime64 (6)))),
`device_type` SimpleAggregateFunction(argMin, Tuple (Nullable (String), Nullable (DateTime64 (6)))),
`device_reg` SimpleAggregateFunction(anyLast, LowCardinality (Nullable (String))),
`is_test` SimpleAggregateFunction( min, UInt8) DEFAULT 1,
`meta_consumed_at` SimpleAggregateFunction( max, DateTime64 (6))
) ENGINE = ReplicatedAggregatingMergeTree('/clickhouse/{cluster_name}/tables/{shard}/smth.users_all', '{replica}')
PARTITION BY intDiv(id, 1000000)
ORDER BY (id, created_at, is_test)
SETTINGS index_granularity = 8192;
```
Информация собирается из 2-х топиков.
1) id, created_at, registration_country, is_test, meta_consumed_at
2) id, device, device_type, device_reg, meta_consumed_at
meta_consumed_at - это время когда информация прилетает из топика
Не понимаю как правильно выбрать PARTITION BY в этом случае
Может есть в данном случае рекомендации или "решения из жизни" ?
PARTITION BY intDiv(id, 1000000) это миллион партиций, это не полетит. в похожих случаях, если записей ожидается немного (users - видимо тут будет меньше милиарда), я не делаю партиций, они не нужны.
ORDER BY (id, created_at, is_test) -- так делать нельзя, неправильно будет работать, не схлопнутся `created_at` SimpleAggregateFunction( max, DateTime64 (6)), `is_test` SimpleAggregateFunction( min, UInt8) DEFAULT 1, тут только ORDER BY (id )
а я так понял, что тут будет n партиций. Например 100 млн пользователей - 100 партиций (intDiv(id, 1000000)). А по-умолчанию какое партиционирование используется. Нужно же чтобы кол-во партиций было в диапазоне от 1000 до 10000.
а ну да, я перепутал. Обычно в таких случаях mod используется. >А по-умолчанию какое партиционирование используется. Нужно же чтобы кол-во партиций было в диапазоне от 1000 до 10000. нет конечно, вы путаете парты и партиции, и это не про ваш use-case, это относится к стриму событий. повторю: "в похожих случаях, если записей ожидается немного (users - видимо тут будет меньше милиарда), я не делаю партиций, они не нужны." Т.е. я предлагаю вам все валить в одну партицию. Я бы на вашем месте сделал ENGINE = ReplicatedAggregatingMergeTree('/clickhouse/{cluster_name}/tables/{shard}/smth.users_all', '{replica}') ORDER BY (id)
спасибо за совет, попробую им воспользоваться)
Обсуждают сегодня