From ffd272597ce50a42c534e044653b653248cb046b Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sun, 26 Mar 2023 06:32:10 +0000 Subject: [PATCH] add backend --- source/libs/stream/src/streamStateRocksdb.c | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c index c4ee4a0b98..f1d7606805 100644 --- a/source/libs/stream/src/streamStateRocksdb.c +++ b/source/libs/stream/src/streamStateRocksdb.c @@ -746,16 +746,25 @@ int32_t streamStateFillGetKVByCur_rocksdb(SStreamStateCur* pCur, SWinKey* pKey, if (!pCur) { return -1; } - SWinKey winKey; - SWinKey* pKTmp = &winKey; + SWinKey winKey; if (rocksdb_iter_valid(pCur->iter)) { size_t tlen; char* keyStr = (char*)rocksdb_iter_key(pCur->iter, &tlen); winKeyDecode(&winKey, keyStr); + + size_t vlen = 0; + const char* valStr = rocksdb_iter_value(pCur->iter, &vlen); + if (pVal != NULL) { + char* dst = taosMemoryCalloc(1, vlen); + memcpy(dst, valStr, vlen); + *pVal = dst; + } + if (pVLen != NULL) *pVLen = vlen; + } else { return -1; } - *pKey = *pKTmp; + *pKey = winKey; return 0; } int32_t streamStateGetGroupKVByCur_rocksdb(SStreamStateCur* pCur, SWinKey* pKey, const void** pVal, int32_t* pVLen) {