Infinidat/infi.clickhouse_orm
1
1
Fork 0
mirror of https://github.com/Infinidat/infi.clickhouse_orm.git synced 2025-08-01 10:49:53 +03:00
Code Issues Packages Projects Releases Wiki Activity

added AggregatingMergeTree engine

Browse Source
This commit is contained in:
solebox 2024-06-03 15:17:47 +03:00
parent 45a9200ff6
commit 5f2825b9f2
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/infi/clickhouse_orm/engines.py
View File

@ -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,