From 5f2825b9f20d8612b22709db3dca52b60035250f Mon Sep 17 00:00:00 2001 From: solebox Date: Mon, 3 Jun 2024 15:17:47 +0300 Subject: [PATCH] added AggregatingMergeTree engine --- src/infi/clickhouse_orm/engines.py | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/infi/clickhouse_orm/engines.py b/src/infi/clickhouse_orm/engines.py index 7fb83be..294f384 100644 --- a/src/infi/clickhouse_orm/engines.py +++ b/src/infi/clickhouse_orm/engines.py @@ -135,6 +135,19 @@ class CollapsingMergeTree(MergeTree): return params +class AggregatingMergeTree(MergeTree): + + def __init__(self, date_col=None, order_by=(), sampling_expr=None, + index_granularity=8192, replica_table_path=None, replica_name=None, partition_key=None, + primary_key=None): + super(AggregatingMergeTree, self).__init__(date_col, order_by, sampling_expr, index_granularity, + replica_table_path, replica_name, partition_key, primary_key) + + def _build_sql_params(self, db): + params = super(AggregatingMergeTree, self)._build_sql_params(db) + return params + + class SummingMergeTree(MergeTree): def __init__(self, date_col=None, order_by=(), summing_cols=None, sampling_expr=None,