serge

Привет! На кластере реализована следующая архитектура: cronjob -> kafka -> stream table -> MV -> ReplicatedReplacingMergeTree table. В kafka могут попадать дублирующиеся запис...

Всем привет! У меня есть таблица с одним полем по которой нужно проверять входит поле в этот список или нет. Как этот фукционал лучше реализовать? Eсть ли Replicated Join Engi...

Всем привет! При создании MV c движком ReplicatedSummingMergeTree из Distributed table (shard engine: ReplacingMergeTree) часть строк суммируется 2 и более раз. Возможно ли и...

Всем привет! У меня есть таблица в которую льются метаданные и для того чтобы получить значения метаданных для каждого объекта я делаю агрегацию (group by). Как создать словар...

Всем привет! У меня есть таблица ReplicatedCollapsingMergeTree(sign) в которой хранятся метаданные. Хочу построить словарь над этими данными. Какие пути есть? Возможно ли соз...

Может кто сталкивался 🙏🏻 Как создавать таблицы с Engine=Set в кластере? Создаю так: CREATE TABLE IF NOT EXISTS table_name ON CLUSTER cluster_name (a String) Engine = Set; При...

Есть таблица с временным рядом с пропущенными значениями: 1. Как можно вставить последнее ненулевое значение, если значение поле нулевое? 2. Как можно обрезать значение по мак...

При загрузке данных в python с помощью clickhouse-sqlalchemy не загружает первую строку с данными, остальные данные приходят. Кто-нибудь сталкивался с этим? @tkostyan можешь...

Я хочу использовать эту таблицу как элемент условия (оператор IN) Таблицы с которыми работаю Distributed. Над таблицей Set тоже нужно создать таблицу Distributed?

Как красиво с использованием Join написать? У меня не всегда однаковые интервалы между значениями времени (поле date)

Какая в этом цель?