From 7750e765b8cf156dbc15eacc51cb8fd7ffd4844b Mon Sep 17 00:00:00 2001
From: iFA <ifa@fusionsolutions.io>
Date: Sun, 19 Jul 2020 14:21:35 +0200
Subject: [PATCH] Update _rocksdb.pyx
---
rocksdb/_rocksdb.pyx | 21 ++++++++++++++++++++-
1 file changed, 20 insertions(+), 1 deletion(-)
diff --git a/rocksdb/_rocksdb.pyx b/rocksdb/_rocksdb.pyx
index b643629..374d52e 100644
--- a/rocksdb/_rocksdb.pyx
+++ b/rocksdb/_rocksdb.pyx
@@ -582,7 +582,8 @@ cdef class BlockBasedTableFactory(PyTableFactory):
block_restart_interval=None,
whole_key_filtering=None,
enable_index_compression=False,
- cache_index_and_filter_blocks=False
+ cache_index_and_filter_blocks=False,
+ format_version=2,
):
cdef table_factory.BlockBasedTableOptions table_options
@@ -644,6 +645,9 @@ cdef class BlockBasedTableFactory(PyTableFactory):
if block_cache_compressed is not None:
table_options.block_cache_compressed = block_cache_compressed.get_cache()
+ if format_version is not None:
+ table_options.format_version = format_version
+
# Set the filter_policy
self.py_filter_policy = None
if filter_policy is not None:
@@ -2090,6 +2094,21 @@ cdef class DB(object):
return ret
+ def get_column_family_meta_data(self, ColumnFamilyHandle column_family=None):
+ cdef db.ColumnFamilyMetaData metadata
+
+ cdef db.ColumnFamilyHandle* cf_handle = self.db.DefaultColumnFamily()
+ if column_family:
+ cf_handle = (<ColumnFamilyHandle?>column_family).get_handle()
+
+ with nogil:
+ self.db.GetColumnFamilyMetaData(cf_handle, cython.address(metadata))
+
+ return {
+ "size":metadata.size,
+ "file_count":metadata.file_count,
+ }
+
def compact_range(self, begin=None, end=None, ColumnFamilyHandle column_family=None, **py_options):
cdef options.CompactRangeOptions c_options
--
GitLab