KS
INSERT в MV синхронный. То есть, делается при INSERT в таблицу, над которой он создан. Клиент получил Ок - значит данные вставлены и в основную таблицу и во все materialized views.
а синхронность справделива для каскадных MV?
Size: a a a
2019 November 25
AM
а синхронность справделива для каскадных MV?
Да.
AM
Всем привет. Подскажите за репликацию через ReplicatedMergeTree.
Можно ли не зашивать название базы данных при указании ReplicatedMergeTree? В разных окружениях разное название используется
Можно ли не зашивать название базы данных при указании ReplicatedMergeTree? В разных окружениях разное название используется
Да, можно не указывать название базы данных.
KS
а если MV будет смотреть предыдующю MV + JOIN на исходную таблицу? это будет работать?
AM
Алексей, спасибо. я просто еще с прошлой недели пытаюсь сделать странное =)
я вставляю в MergeTree поток событий, на этот поток смотрит MV (AggregatingMergeTree) которая считает статистики, хочется сделать 3ю сущность которая должна взять изначальный поток событий и сделать к нему JOIN уже агрегированных данных, т.е. для каждого события присоединять текущее состояние агрегатов (может сумбурно несколько объяснил), мне уже писали что вроде на КХ не стоит /нельзя такого делать, но так хочется попробовать)
я вставляю в MergeTree поток событий, на этот поток смотрит MV (AggregatingMergeTree) которая считает статистики, хочется сделать 3ю сущность которая должна взять изначальный поток событий и сделать к нему JOIN уже агрегированных данных, т.е. для каждого события присоединять текущее состояние агрегатов (может сумбурно несколько объяснил), мне уже писали что вроде на КХ не стоит /нельзя такого делать, но так хочется попробовать)
Там будет трудно, так как на каждый INSERT будет заново создаваться структура данных для JOIN (как будто вы каждый раз делаете SELECT запрос с этим JOIN). То есть, будет весьма медленно и избыточно (зачем делать одинаковую работу на каждый INSERT). Но этого можно избежать с помощью таблиц типа Join. Они будут постоянно держать структуру данных для JOIN в памяти. И тогда есть шанс, что будет хорошо работать.
AM
> а если MV будет смотреть предыдующю MV + JOIN на исходную таблицу? это будет работать?
Да.
Для каскадных MV указывайте .inner. таблицу для SELECT.
Да.
Для каскадных MV указывайте .inner. таблицу для SELECT.
PL
Да, можно не указывать название базы данных.
Ну тогда могут быть коллизии же
PL
Ну, то есть я понимаю, что путь в zk связан с таблицей косвенно, но всё равно
S
Ну тогда могут быть коллизии же
если не ошибаюсь, тогда берется дефолтная база. Либо же можно задать default_database для реплики в remote_servers.
PL
Я вижу в документации
В macros можно указать любые подстановки, так? Могу я сделать "переменную"
<macros>
<layer>05</layer>
<shard>02</shard>
<replica>example05-02-1.yandex.ru</replica>
</macros>
В macros можно указать любые подстановки, так? Могу я сделать "переменную"
database и заиспользовать в пути?A
Я вижу в документации
В macros можно указать любые подстановки, так? Могу я сделать "переменную"
<macros>
<layer>05</layer>
<shard>02</shard>
<replica>example05-02-1.yandex.ru</replica>
</macros>
В macros можно указать любые подстановки, так? Могу я сделать "переменную"
database и заиспользовать в пути?Оно хранится в system.macros . Можно конечно захадкодить, но кто-то захочет свою для другой базы в этом же ch.
KS
> а если MV будет смотреть предыдующю MV + JOIN на исходную таблицу? это будет работать?
Да.
Для каскадных MV указывайте .inner. таблицу для SELECT.
Да.
Для каскадных MV указывайте .inner. таблицу для SELECT.
я пробовал вот такую схему, но без .inner. Тогда начинались проскальзывания в финальной MV. Это из за того что .inner. не использовалось?
PL
Не очень понял. Вот есть у меня миграция, в которой создаётся таблица. Я могу сделать так:
@inv2004
...а уже у админов будет xml с указанием, что
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{db_name}.some_table_name')
db_name = ...@inv2004
DC
Eugene Ivlev
Добрый день,
подскажите как определить в какой релиз вошел/не вошел тикет https://github.com/ClickHouse/ClickHouse/issues/6337 ?
Требуется использование больше/меньше в JOIN
подскажите как определить в какой релиз вошел/не вошел тикет https://github.com/ClickHouse/ClickHouse/issues/6337 ?
Требуется использование больше/меньше в JOIN
Это asof join. Там последнее поле только < >
AS
всем привет!
а в кх такого вида запросы не работают (хз как они называються, когда в филде запрос)?
DB::Exception: Missing columns: 'x.a' 'a' while processing query: 'SELECT sum(c) FROM y_test AS y WHERE a = x.a', required columns: 'x.a' 'c' 'a', source columns: 'd' 'c' (version 19.14.3.3 (official build))
а в кх такого вида запросы не работают (хз как они называються, когда в филде запрос)?
сreate table x_test (
a Int,
b Int
) engine = Null;
create table y_test (
a Int,
c Int
) engine = Null;
select a, (select sum(c) from y_test y where y.a = x.a) from x_test x;DB::Exception: Missing columns: 'x.a' 'a' while processing query: 'SELECT sum(c) FROM y_test AS y WHERE a = x.a', required columns: 'x.a' 'c' 'a', source columns: 'd' 'c' (version 19.14.3.3 (official build))
RK
Подскажите пожалуйста как в clickhouse-client выполнить multiline-запрос?
PL
Подскажите пожалуйста как в clickhouse-client выполнить multiline-запрос?
-mRK
Спасибо.
AZ
Aleh Sauko
всем привет!
а в кх такого вида запросы не работают (хз как они называються, когда в филде запрос)?
DB::Exception: Missing columns: 'x.a' 'a' while processing query: 'SELECT sum(c) FROM y_test AS y WHERE a = x.a', required columns: 'x.a' 'c' 'a', source columns: 'd' 'c' (version 19.14.3.3 (official build))
а в кх такого вида запросы не работают (хз как они называються, когда в филде запрос)?
сreate table x_test (
a Int,
b Int
) engine = Null;
create table y_test (
a Int,
c Int
) engine = Null;
select a, (select sum(c) from y_test y where y.a = x.a) from x_test x;DB::Exception: Missing columns: 'x.a' 'a' while processing query: 'SELECT sum(c) FROM y_test AS y WHERE a = x.a', required columns: 'x.a' 'c' 'a', source columns: 'd' 'c' (version 19.14.3.3 (official build))
Проблема не в том, что сабселект не там, а в том что вы хотите x.a из внешнего запроса (x определена снаружи) заюзать во внутреннем. Это коррелированные подзапросы, они (пока) не поддерживаются.