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

add api

This commit is contained in:
yihaoDeng 2024-03-13 12:58:05 +00:00
parent a5eebc90cb
commit cc7d5ce484
5 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/dnode/vnode/src/tsdb/tsdbDataFileRW.c
View File

@ -842,6 +842,7 @@ static int32_t tsdbDataFileDoWriteBlockData(SDataFileWriter *writer, SBlockData
.count = 1, .count = 1,
}}; }};
for (int32_t i = 1; i < bData->nRow; ++i) { for (int32_t i = 1; i < bData->nRow; ++i) {
if (bData->aTSKEY[i] != bData->aTSKEY[i - 1]) { if (bData->aTSKEY[i] != bData->aTSKEY[i - 1]) {
record->count++; record->count++;

1
source/dnode/vnode/src/tsdb/tsdbDataFileRW.h
View File

@ -85,6 +85,7 @@ typedef struct SDataFileWriterConfig {
} files[TSDB_FTYPE_MAX]; } files[TSDB_FTYPE_MAX];
SSkmInfo *skmTb; SSkmInfo *skmTb;
SSkmInfo *skmRow; SSkmInfo *skmRow;
SHashObj *pColCmpr;
uint8_t **bufArr; uint8_t **bufArr;
} SDataFileWriterConfig; } SDataFileWriterConfig;

4
source/dnode/vnode/src/tsdb/tsdbFSetRW.c
View File

@ -14,6 +14,7 @@
*/ */
#include "tsdbFSetRW.h" #include "tsdbFSetRW.h"
#include "meta.h"
// SFSetWriter ================================================== // SFSetWriter ==================================================
struct SFSetWriter { struct SFSetWriter {
@ -32,6 +33,7 @@ struct SFSetWriter {
int32_t blockDataIdx; int32_t blockDataIdx;
SDataFileWriter *dataWriter; SDataFileWriter *dataWriter;
SSttFileWriter *sttWriter; SSttFileWriter *sttWriter;
SHashObj *pColCmprObj;
}; };
static int32_t tsdbFSetWriteTableDataBegin(SFSetWriter *writer, const TABLEID *tbid) { static int32_t tsdbFSetWriteTableDataBegin(SFSetWriter *writer, const TABLEID *tbid) {
@ -42,6 +44,8 @@ static int32_t tsdbFSetWriteTableDataBegin(SFSetWriter *writer, const TABLEID *t
writer->ctx->tbid->uid = tbid->uid; writer->ctx->tbid->uid = tbid->uid;
code = tsdbUpdateSkmTb(writer->config->tsdb, writer->ctx->tbid, writer->skmTb); code = tsdbUpdateSkmTb(writer->config->tsdb, writer->ctx->tbid, writer->skmTb);
code = metaGetColCmpr(writer->config->tsdb->pVnode->pMeta, writer->ctx->tbid->suid, &writer->pColCmprObj);
TSDB_CHECK_CODE(code, lino, _exit); TSDB_CHECK_CODE(code, lino, _exit);
writer->blockDataIdx = 0; writer->blockDataIdx = 0;

1
source/dnode/vnode/src/tsdb/tsdbFSetRW.h
View File

@ -41,6 +41,7 @@ typedef struct {
bool exist; bool exist;
STFile file; STFile file;
} files[TSDB_FTYPE_MAX]; } files[TSDB_FTYPE_MAX];
SHashObj *pColCmpr;
} SFSetWriterConfig; } SFSetWriterConfig;
int32_t tsdbFSetWriterOpen(SFSetWriterConfig *config, SFSetWriter **writer); int32_t tsdbFSetWriterOpen(SFSetWriterConfig *config, SFSetWriter **writer);

1
source/dnode/vnode/src/tsdb/tsdbUtil2.c
View File

@ -189,3 +189,4 @@ int32_t tsdbUpdateSkmRow(STsdb *pTsdb, const TABLEID *tbid, int32_t sver, SSkmIn
tDestroyTSchema(pSkmRow->pTSchema); tDestroyTSchema(pSkmRow->pTSchema);
return metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, tbid->suid, tbid->uid, sver, &pSkmRow->pTSchema); return metaGetTbTSchemaEx(pTsdb->pVnode->pMeta, tbid->suid, tbid->uid, sver, &pSkmRow->pTSchema);
} }
int32_t tsdbUpdateColCmprObj(STsdb *pTsdb, const TABLEID *tbid, SHashObj **ppColCmpr) { return 0; }