Как заклинание прозвучало :)

пока что так и есть, скоро будет менее хакерская функция.

А есть ли способ сгруппировать не только одинаковые массивы, но группировать массив и с теми что полностью в него входят, например: action | categories 1 | [1,2,3,4,5] 1 | [2,3] 2 | [1,2] 2 | [2,3] сгруппировать SELECT action, fn(categories) AS cat, COUNT() AS cnt FROM t GROUP BY action, cat и получить 1, [1,2,3,4,5], 2 2, [1,2], 1 2, [2,3], 1 ?

а вы это хотя бы на каком-то языке программирования можете написать?

например если у вас есть A, B, A and B, куда должна попасть третья строка, в первую группу или во вторую?

да, могу, 3-й никуда не должен попасть, вобщем если по проще то, для группировки нужно чтоб дольшие массивы включали в себя меньшие, т.е. если есть [A],[B] и [A,B] то останется [A,B]

если я правильно вас понял, то вы хотите примерно вот что. у вас есть некоторое подмножество X какого-то powerset P, и вы хотите найти в нем Xmax = {x \in X| !\E a: x \subset a }, т.е. множество "максимальных" элементов X, и потом каждый элемент округлять до максимального. во-первых у вас проблема с неоднозначностью, а во-вторых, на уровне исполнения запроса это преобразование не функция отдельной строки.

да, могу, 3-й никуда не должен попасть, вобщем если по проще то, для группировки нужно чтоб дольшие массивы включали в себя меньшие, т.е. если есть [A],[B] и [A,B] то останется [A,B]

а если есть [A], [B] и [] ?

ok, пустые не группируем

я могу непустой пример придумать.

в кх можно написать выражение включения одного массива в другой, поэтому можно просто определение которое я написал выше переписать в виде запроса, и потом на это множество еще раз поджойнить таблицу и посмотреть кто куда попадает.

Про проблемы с негативными енумами - пардон, ложная тревога, ошибка в коде создания таблицы (в значения енума при сериализации попадал какой-то непечатный символ, который не было видно describe/show create).

Здравствуйте ,как победили баг? у меня абсолютно аналогичная ситуация, понять не могу откуда ноги растут Code: 49, e.displayText() = DB::Exception: Unknown element 'umts' for type Enum8('noservice' = 1, 'gsm' = 2, 'umts' = 3, 'lte_fdd' = 4, 'lte_tdd' = 5), e.what() = DB::Exception

Всем привет, а есть в КХ функция, которые объединяет два массива в один? что-то типо union, например для SELECT arrayUnion([1, 2, 3], [4, 5, 6]) AS res вернула бы [1, 2, 3, 4, 5, 6]

В ближайшем релизе появится нормальная операция конкатенации массивов и не только.

В ближайшем релизе появится нормальная операция конкатенации массивов и не только.

Можете уточнить, когда ожидается и в какой мере более полная поддержка JOIN? Тут https://clickhouse.yandex/docs/en/roadmap.html достаточно размыто написано

@ckcnik У меня в коде, который создавал таблицы, затесался какой-то непечатный символ, пробел нулевой ширины или что то вроде. Он все и портил.

Вот запрос из доки http://joxi.ru/RmzNOePtWOkvPm (примерно тут https://clickhouse.yandex/docs/ru/query_language/queries.html#id9) Что он делает, прям по UserId агрегирует что ли?

Я так полагаю, что это было бы аналогично, если было бы написано avgIf или where userId IN

Я так полагаю, что это было бы аналогично, если было бы написано avgIf или where userId IN

Похоже, но вопрос в том, а по какому полю считается avg?

А, видимо считается доля строк по каждому userId, хотя могу ошибаться

Хотя avg все таки считает среднее

Ну да ) Там написано "за каждый день после 17 марта считаем долю хитов, сделанных посетителями, которые заходили на сайт 17 марта"

Добрый день. Помогите советом. Есть задача "обновлять" имеющиеся записи в КХ (да, знаю, что апдейтов нет) Есть таблица пользователей. У каждого есть уникальный айди и много атрибутов В момент добавления записи не все атрибуты могут быть известны. По мере поступления новых данных атрибуты надо обновлять Есть работающее решение - просто инсертить новые записи, а каждый атрибут вычислять через argMax (у каждой записи есть таймстемп) группируя по user_id. Оно работает, но не очень быстро. Пользователей не очень много (сейчас около 3 миллионов, но число будет расти). Нужны они в КХ т.к. хотим по атрибутом пользователя фильтровать события (джоинить таблицы юзером в ивентов). Есть ли варианты лучше? Еще были мысли сделать "юзеров" сделать через словарь (в mysql например) не будет ли их количество проблемой?

Попробуйте вынести агрегацию в материализированное представление и оттуда с доагрегирующим запросом вытаскивать

Данное решение сократит количество строк, так как КХ потихоньку будет их схлопывать

Можно попробовать инкрементальный лог и CollapsingMergeTree - https://clickhouse.yandex/docs/en/table_engines/collapsingmergetree.html

Добрый день. Помогите советом. Есть задача "обновлять" имеющиеся записи в КХ (да, знаю, что апдейтов нет) Есть таблица пользователей. У каждого есть уникальный айди и много атрибутов В момент добавления записи не все атрибуты могут быть известны. По мере поступления новых данных атрибуты надо обновлять Есть работающее решение - просто инсертить новые записи, а каждый атрибут вычислять через argMax (у каждой записи есть таймстемп) группируя по user_id. Оно работает, но не очень быстро. Пользователей не очень много (сейчас около 3 миллионов, но число будет расти). Нужны они в КХ т.к. хотим по атрибутом пользователя фильтровать события (джоинить таблицы юзером в ивентов). Есть ли варианты лучше? Еще были мысли сделать "юзеров" сделать через словарь (в mysql например) не будет ли их количество проблемой?

У нас похожая схема используется. Только мы используем ReplacingMergeTree и пишем данные сразу по всем колонкам. Они пересчитываются после получения новых эвентов о пользователе (посчитать, сагрегировать и пр. в КХ невозможно из-за особенностей бизнес-логики). Через словарь в КХ пробовал, но проблема словаря в том, что например на 250к строк есть определенный лаг, т.к. КХ почему то на каждый запрос лезет в MySQL и проверяет актуальность ключей (возможно я ошибаюсь и он берет из кеша, но все равно как то долго), поэтому вариант с MySQL у нас отвалился.

Лучше хранить где то старое состояние, например в redis, после вычисления новых данные, брать старое состояние, обновлять его и писать в КХ

Это будет куда быстрее, чем считать argMax

Привет! скажите всетаки, как победить такую ошибку - DDLWorker: Will not execute task query-0000000066 : There is no a local address in host list

я так понимаю от зукипера приходит задание с неправильным хостом и CH-сервер не находит себя в списке хостов. А где посмотреть эти задания сами. в консоли зукипера все как будто нормально отображается

У вас на всех узлах кластера настроен кластер?

ну да

<remote_servers> <replicator> <shard> ...

Добрый день! Я ведь правильно понимаю, что при выполнении запроса: SELECT a, any(b), any(c) FROM table GROUP BY a нет гарантии что b и c будут из одной записи?

все верно

насколько я помню, any((b,c)) = (any(b),any(c))

так что второй вариант можно использовать.

Спасибо

Добрый день. Настраиваю работу 2 шардов по 2 реплики. Странное поведение: делаю вставки в distributed таблицу на 1-ом сервере, часть данных уходит на 4-ый (шардирование работает нормально), но не все данные попдают на сервер 3 с 4-го (реплики) и ничего не пишется на 2-ой (реплика первого)

в логах ReshardingWorker: no node, path: /clickhouse/task_queue/resharding/clickhouse1

CREATE TABLE video ( ... ) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/video', '{replica}', EventDate, cityHash64(URL), 8192); CREATE TABLE video_distributed AS video ENGINE = Distributed(statistics, default, video, cityHash64(domainWithoutWWW(URL)));

в конфигах <macros incl="macros"> <shard>1</shard> <replica>clickhouse1-1</replica> </macros> <macros incl="macros"> <shard>1</shard> <replica>clickhouse1-2</replica> </macros> <macros incl="macros"> <shard>2</shard> <replica>clickhouse2-1</replica> </macros> <macros incl="macros"> <shard>2</shard> <replica>clickhouse2-2</replica> </macros>

Можете уточнить, когда ожидается и в какой мере более полная поддержка JOIN? Тут https://clickhouse.yandex/docs/en/roadmap.html достаточно размыто написано

В Q4. Можно будет делать JOIN-ы без необходимости оборачивания всего в подзапросы и с обычным синтаксисом.

Минимальной датой в DateTime тоже является 1970-01-01 как в Date ?

Добрый день, подскажите пожалуйста по внешнему словарю. complex_key_cache смотрит в постгрес. Когда не находит записи по ключу, то кидает "RecordSet contains 0 columns while 5 expected", а в постгресе вижу висит запрост PREPARE ... с этим ключем. Вопрос примерно: почему иногда он умеет доставать несуществующую запись и заполнять дефолтными значениями, а иногда отваливается?

В Q4. Можно будет делать JOIN-ы без необходимости оборачивания всего в подзапросы и с обычным синтаксисом.

Спасибо за ответ. А стоит ожидать появление этого функционала до конца года? Или Q4 - дата начала разработки?

>Результат у этого запроса непустой? Если с постгреса приходит пустой ответ (0 rows) на простой dictGetString('xxx', 'attr', tuple(guid,id)), так будет работать?

Есть дата и время, например 2017-09-11 14:44:01, ее как то функциями для работы с датами можно преобразовать в 2017-09-11 23:59:59? )

Есть дата и время, например 2017-09-11 14:44:01, ее как то функциями для работы с датами можно преобразовать в 2017-09-11 23:59:59? )

А зачем преобразовывать? Что хотите дальше с такой датой делать?

Мне нужно собрать общую продолжительность эвентов с группировкой по дням. Есть дата начала эвента и дата завершения эвента. Если эвент растянулся на пару дней, то нужно за эти несколько дней на каждый день посчитать продолжительность.

Можно проецировать на визиты. Есть время визита, например визит длился 15 минут. Начался визит 2017-09-10 23:55:00 а кончился 2017-09-11 00:10:00. И вот результат запроса должен быть типа 2017-09-10 - 300 2017-09-11 - 600

Хм, хотя я могу использовать timeSlots

Округлить до даты можно так: 1. toDate(date) 2. substring(date, 1, 10) А что такое 300 и 600 в примере? Продолжительнось в секундах?

Да

ERROR: S client not available

Мне не округлить до даты нужно ) Мне нужно зная дату поставить ей время в 23.59.59 )

toStartOfDay()

Хотя это костыль. Сейчас попробую через timeSolts попробовать

Блин, точно....забыл про них совсем! Сори, что дернул глупым вопросом!

А нормально делать представление у реплицируемой таблицы тоже реплицированным? Синхронизация от этого не поломается?

Нет, не поломается

Вобщем разобрался ) Если кому будет интересно как например растянуть эвент и посчитать время эвента по дням, учитывая время начала и время окончания эвента, то можно вот так) SELECT toDate(started) + days as date, if (started > toStartOfDay(toDateTime(date)), started, toStartOfDay(toDateTime(date))) as dateStarted, if (toStartOfDay(toDateTime(date)) + 86399 > ended, ended, toStartOfDay(toDateTime(date)) + 86399) as dateEnded, started as oStarted, ended as oEnded, if (toDate(oStarted) != toDate(dateEnded), dateEnded - dateStarted + 1, dateEnded - dateStarted) as dateDuration FROM ( SELECT toDateTime('2017-09-09 23:55:00') AS started, toDateTime('2017-09-12 14:00:00') AS ended, range(toUInt8(if(toDate(started) != toDate(ended), (toDate(ended) - toDate(started)) + 1, 1))) AS days, 223500 as duration ) ARRAY JOIN days

В финале должно получиться что-то вроде https://img.facedsid.ru/f2brp.jpg

разобрались - в конфиге реплик был не правильный порт указан. Нужен 9000, а я обычный http порт прописал

Привет! скажите всетаки, как победить такую ошибку - DDLWorker: Will not execute task query-0000000066 : There is no a local address in host list

Для истории - в конфиге были напутаны номера портов в <replica>

Привет всем, как импортитровать пустую строку из csv? Там в таком виде data,,,data, как бы два столбца пустые

Привет всем, как импортитровать пустую строку из csv? Там в таком виде data,,,data, как бы два столбца пустые

А как вы пробуете импортировать?

cat file.csv | clickhouse-client --database=test --query="INSERT INTO test FORMAT CSV";

И что пишет, когда выполняете эту команду?

И что пишет, когда выполняете эту команду?

Все нормально, со структроро не совпадало, спасибо

Добрый вечер. Наткнулся на непонятное поведение Enum. :) select * from Order where Rebill='yes'; SELECT * FROM Order WHERE Rebill = 'yes' Received exception from server: Code: 49. DB::Exception: Received from localhost:9000, 127.0.0.1. DB::Exception: Unknown element 'yes' for type Enum8('no' = 0, 'yes' = 1). 0 rows in set. Elapsed: 0.068 sec. :) select Rebill,Count(*) from Order group by Rebill; SELECT Rebill, Count(*) FROM Order GROUP BY Rebill ┌─Rebill─┬─Count()─┐ │ no │ 390136 │ │ yes │ 302973 │ └────────┴─────────┘ 2 rows in set. Elapsed: 0.011 sec. Processed 693.11 thousand rows, 693.11 KB (61.00 million rows/s., 61.00 MB/s.) Что может быть?

Добрый вечер. Наткнулся на непонятное поведение Enum. :) select * from Order where Rebill='yes'; SELECT * FROM Order WHERE Rebill = 'yes' Received exception from server: Code: 49. DB::Exception: Received from localhost:9000, 127.0.0.1. DB::Exception: Unknown element 'yes' for type Enum8('no' = 0, 'yes' = 1). 0 rows in set. Elapsed: 0.068 sec. :) select Rebill,Count(*) from Order group by Rebill; SELECT Rebill, Count(*) FROM Order GROUP BY Rebill ┌─Rebill─┬─Count()─┐ │ no │ 390136 │ │ yes │ 302973 │ └────────┴─────────┘ 2 rows in set. Elapsed: 0.011 sec. Processed 693.11 thousand rows, 693.11 KB (61.00 million rows/s., 61.00 MB/s.) Что может быть?

Уже были предложения не так давно про непечатные символы

при описании таблицы задаются значения enum. они при группировке присутсвуют. но при выборке вылетает эта ошибка. поменял поле в таблице на строку и запрос работает.

ну, таки интересно https://pastebin.com/TEu0pu42 @milovidov_an эмм, там прямо хеши разные

у меня подобная проблема и она не решилась, у меня эта бага вылетает во время инсерта через infi.clickhouse_orm, причем баг мигающий какой-то

@miptgirl @milovidov_an @the_real_jkee clean time

Всем привет! Если есть народ использующий в работе Microsoft PowerBI - создал голосвание на добавление коннектора к КХ: https://ideas.powerbi.com/forums/265200-power-bi-ideas/suggestions/31355041-add-connector-to-clickhouse p.s. если сами не используете, но знаете аналитиков которые используют - тоже киньте им ссылочку на голосование =)

Интересует по опыту, допустим, нет агрегаций в запросах и не планируется. Имеет ли смысл для репликации во избежание проблем со статическим dns использовать кафку а у подписчика будет простой инстанс КХ уже без репликаций. ( если рассмотреть для начала схему совсем утрированно, то льем данные на 2 сервера, а забираем с одного )

@milovidov_an спасибо за odbc драйвер

Доброго дня! Подскажите, пожалуйста, "testdb.test1 20170701_20170731_698330_700900_322" - первое и второе число понятно что, а остальные?

Рассмотрим по порядку имя первого куска: 20140317_20140323_2_2_0. 20140317 - минимальная дата данных куска 20140323 - максимальная дата данных куска 2 - минимальный номер блока данных 2 - максимальный номер блока данных 0 - уровень куска - глубина дерева слияний, которыми он образован (из доки)