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

merge rocksdb inst

This commit is contained in:
yihaoDeng 2023-04-27 14:46:33 +00:00
parent 36a4413bf1
commit 984a69671e
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/stream/src/streamStateRocksdb.c
View File

@ -431,6 +431,7 @@ int streamStateOpenBackend(void* backend, SStreamState* pState) {
// pState->pTdbState->pCompare = pCompare; // pState->pTdbState->pCompare = pCompare;
pState->pTdbState->dbOpt = handle->dbOpt; pState->pTdbState->dbOpt = handle->dbOpt;
pState->pTdbState->param = param; pState->pTdbState->param = param;
pState->pTdbState->pBackendHandle = handle;
SCfComparator compare = {.comp = pCompare, .numOfComp = cfLen}; SCfComparator compare = {.comp = pCompare, .numOfComp = cfLen};
pState->pTdbState->pComparNode = streamBackendAddCompare(handle, &compare); pState->pTdbState->pComparNode = streamBackendAddCompare(handle, &compare);