From 2ca072344e9ffa43f9801e8dd25fa9eb9de502c6 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 29 Mar 2023 06:56:14 +0000 Subject: [PATCH] add backend --- source/libs/stream/src/streamStateRocksdb.c | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c index 82a2702e6c..5c5f5020ff 100644 --- a/source/libs/stream/src/streamStateRocksdb.c +++ b/source/libs/stream/src/streamStateRocksdb.c @@ -310,15 +310,20 @@ int streamInitBackend(SStreamState* pState, char* path) { const rocksdb_options_t** cfOpt = taosMemoryCalloc(cfLen, sizeof(rocksdb_options_t*)); for (int i = 0; i < cfLen; i++) { cfOpt[i] = rocksdb_options_create_copy(opts); - rocksdb_block_based_table_options_t* tableOpt = rocksdb_block_based_options_create(); + }; - rocksdb_cache_t* cache = rocksdb_cache_create_lru(128 << 20); + { + rocksdb_block_based_table_options_t* tableOpt = rocksdb_block_based_options_create(); + rocksdb_cache_t* cache = rocksdb_cache_create_lru(128 << 20); rocksdb_block_based_options_set_block_cache(tableOpt, cache); rocksdb_filterpolicy_t* filter = rocksdb_filterpolicy_create_bloom_full(20); rocksdb_block_based_options_set_filter_policy(tableOpt, filter); - rocksdb_options_set_block_based_table_factory((rocksdb_options_t*)cfOpt[i], tableOpt); - }; + rocksdb_options_set_block_based_table_factory((rocksdb_options_t*)opts, tableOpt); + + rocksdb_slicetransform_t* trans = rocksdb_slicetransform_create_fixed_prefix(8); + rocksdb_options_set_prefix_extractor((rocksdb_options_t*)opts, trans); + } rocksdb_comparator_t** pCompare = taosMemoryCalloc(cfLen, sizeof(rocksdb_comparator_t**));