diff --git a/ydb/scheme.py b/ydb/scheme.py index 6019c763..04951b5e 100644 --- a/ydb/scheme.py +++ b/ydb/scheme.py @@ -19,6 +19,7 @@ class SchemeEntryType(enum.IntEnum): RTMR_VOLUME = 5 BLOCK_STORE_VOLUME = 6 COORDINATION_NODE = 7 + COLUMN_STORE = 12 COLUMN_TABLE = 13 SEQUENCE = 15 REPLICATION = 16 @@ -54,6 +55,14 @@ def is_column_table(entry): """ return entry == SchemeEntryType.COLUMN_TABLE + @staticmethod + def is_column_store(entry): + """ + :param entry: A scheme entry to check + :return: True if scheme entry is a column store and False otherwise + """ + return entry == SchemeEntryType.COLUMN_STORE + @staticmethod def is_row_table(entry): """ @@ -128,6 +137,12 @@ def is_directory(self): """ return SchemeEntryType.is_directory(self.type) + def is_column_store(self): + """ + :return: True if scheme entry is a column store and False otherwise + """ + return SchemeEntryType.is_column_store(self.type) + def is_table(self): """ :return: True if scheme entry is a row table and False otherwise (same as is_row_table)