xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge branch 'enh/new3.0' into enh/refactorBackend

This commit is contained in:
yihaoDeng 2023-11-06 18:08:03 +08:00
parent ba52769867
commit aee1b700a6
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/stream/src/streamBackendRocksdb.c
View File

@ -530,9 +530,6 @@ SCfFilterFactory ginitFilterDict[] = {
// pTaskDb->filterFactory = rocksdb_compactionfilterfactory_create(
// NULL, destroyCompactFilteFactory, compactFilteFactoryCreateFilter, compactFilteFactoryName);
// rocksdb_options_set_compaction_filter_factory(pTaskDb->dbOpt, pTaskDb->filterFactory);
void dbSetFilterFactory(rocksdb_options_t* opt, int32_t i, void *arg) { void dbSetFilterFactory(rocksdb_options_t* opt, int32_t i, void *arg) {
rocksdb_compactionfilterfactory_t *filterFactory = rocksdb_compactionfilterfactory_create(arg,destroyCompactFilteFactory, ginitFilterDict[i].create, ginitFilterDict[i].funcName); rocksdb_compactionfilterfactory_t *filterFactory = rocksdb_compactionfilterfactory_create(arg,destroyCompactFilteFactory, ginitFilterDict[i].create, ginitFilterDict[i].funcName);
rocksdb_options_set_compaction_filter_factory(opt, filterFactory); rocksdb_options_set_compaction_filter_factory(opt, filterFactory);
@ -1939,6 +1936,7 @@ void taskDbInitOpt(STaskDbWrapper* pTaskDb) {
pTaskDb->pCompares[i] = compare; pTaskDb->pCompares[i] = compare;
pTaskDb->pCfOpts[i] = opt; pTaskDb->pCfOpts[i] = opt;
pTaskDb->pCfParams[i].tableOpt = tableOpt; pTaskDb->pCfParams[i].tableOpt = tableOpt;
// set filter factory // set filter factory
dbSetFilterFactory(opt, i, NULL); dbSetFilterFactory(opt, i, NULL);
} }