я просто скинул как создавал, ну вот вам create table но он ничем не отличается почти

CREATE MATERIALIZED VIEW hits_view (event_date Date, webmaster_id UInt32, advertiser_id UInt32,
                                             campaign_id UInt32, stream_id UInt32, installs Int64,
                                             impressions Int64, clicks Int64,debit Decimal(38, 9), credit Decimal(38, 9)) ENGINE =
           ReplicatedSummingMergeTree('/clickhouse/tables/{shard}/hits_view',
           '{replica}') PARTITION BY toYYYYMMDD(event_date) ORDER BY (event_date, webmaster_id, advertiser_id,
                                                                      campaign_id, stream_id) SETTINGS index_granularity = 8192 AS
SELECT event_date,
      webmaster_id,
      advertiser_id,
      campaign_id,
      stream_id,
      sum(installs)      as installs,
      sum(impressions)   as impressions,
      sum(clicks)        as clicks,
      sum(debit)         as debit,
      sum(credit)        as credit
FROM hit
GROUP BY event_date, webmaster_id, advertiser_id, campaign_id, stream_id

красивая цифра

интересно, старый КХ ?

Просто новые умеют

create table X (A Int64) Engine=MergeTree order by tuple()
create materialized view B Engine =MergeTree order by tuple() as select * from X
alter  table B drop partition tuple();
OK

Или ругаются DB::Exception: MATERIALIZED VIEW targets existing table T Execute the statement directly on it..

И почему ошибка про distributed ?

В общем вам действительно тогда надо

ALTER TABLE `.inner.hits_view` ON CLUSTER {cluster}
    DROP PARTITION '20190913'

ALTER TABLE `.inner.hits_view` ON CLUSTER {cluster}
    DROP PARTITION '20190913'

Так тоже не работает(

СH version 19.11.6.31 (official build)

ругается как ?

А не, рабатает))) Обманул, до этого запускал когда парень выше посоветовал не сработало, что писало не помню но есть подозрение что table not exists потому что кавычки забыл

Спасибо)

Ребят, кто контрибьютит в кх, есть задачка :) за вознаграждение! Нужна функция, которая будет возвращать query_id который был передан в кх. (В кх такая фича есть) За подробностями можно в личку! Спасибо :)

я думаю вам лучше посмотреть в github и попробовать найти контакты и напрямую спросить

и лучше всего feature request оформить на github

Сюда обратился потому что, тут могут быть и не контрибьюторы готовые подзаработать :)

А в целом спасибо за советы!

мне кажется вы ошибаетесь, query_id нельзя передать.

вам проще сделать

select /* q_id=UUID */ .... (добавлять уникальный id в тект запроса)
потом селектом по system.processes выбирать like '%UUID%'

и если вы не в курсе то http тоже умеет возвращать прогресс
curl -vv 'http://localhost:8123/?send_progress_in_http_headers=1' --data-binary @testa3.sql
< X-ClickHouse-Progress: {"read_rows":"24 996 720","read_bytes":"204755840","total_rows":"38 308 864"}
< X-ClickHouse-Progress: {"read_rows":"22 941 868","read_bytes":"233006776","total_rows":"36 059 136"}

Опишу задачу. Нам не для прогресса 😊

Мы вставляем данные в таблицу, но из-за особенностей вставки не можем отслеживать все ли вставилось, если процесс вставки упал. Дубли недопустимы. Поэтому пришла мысль добавить в таблицу колонку queryId и в качестве дефолтного выражения держать использовать например getQueryId(). Соответственно мы будем видеть в таблице какой запрос какие данные записал. И если он отвалился, то просто вычищаем все данные по этому queryId, либо делаем diff с тем, что записалось и дописываем то, что не записалось.

У нас данные лежат в подготовленных файлах, в одном файле может быть одна строка, а может быть и 1000. Мы собираем файлы в поток и просто кормим поток через http в КХ.

Дописывать queryId в каждую строку тоже не можем по объективным причинам 😊

все это ненужные велосипеды. Надо просто делать атомарные инсерты и использовать дедупликацию КХ и делать ретрай, при таймауте.