Infinidat/infi.clickhouse_orm
1
1
Fork 0
mirror of https://github.com/Infinidat/infi.clickhouse_orm.git synced 2024-11-25 18:23:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Add support for ReplacingMergeTree (https://clickhouse.yandex/reference_en.html#ReplacingMergeTree)

Browse Source
This commit is contained in:
leenr 2017-03-04 15:29:19 +03:00
parent 9a81372fff
commit 1b8c4dbec1
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

@ -63,6 +63,19 @@ class SummingMergeTree(MergeTree):
return params return params
class ReplacingMergeTree(MergeTree):
def __init__(self, date_col, key_cols, ver_col, sampling_expr=None,
index_granularity=8192, replica_table_path=None, replica_name=None):
super(ReplacingMergeTree, self).__init__(date_col, key_cols, sampling_expr, index_granularity, replica_table_path, replica_name)
self.ver_col = ver_col
def _build_sql_params(self):
params = super(ReplacingMergeTree, self)._build_sql_params()
params.append(self.ver_col)
return params
class Buffer(Engine): class Buffer(Engine):
"""Here we define Buffer engine """Here we define Buffer engine
Read more here https://clickhouse.yandex/reference_en.html#Buffer Read more here https://clickhouse.yandex/reference_en.html#Buffer