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

more code

This commit is contained in:
Hongze Cheng 2023-03-29 17:34:36 +08:00
parent a29785df4c
commit 0404810252
2 changed files with 34 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
source/dnode/vnode/src/tsdb/dev/tsdbSttFWriter.c
View File

@ -21,14 +21,25 @@ extern int32_t tsdbWriteFile(STsdbFD *pFD, int64_t offset, const uint8_t *pBuf,
extern int32_t tsdbReadFile(STsdbFD *pFD, int64_t offset, uint8_t *pBuf, int64_t size);
extern int32_t tsdbFsyncFile(STsdbFD *pFD);
typedef struct {
struct {
int64_t offset;
int64_t size;
} dict[4]; // 0:bloom filter, 1:SSttBlk, 2:SDelBlk, 3:STbStatisBlk
uint8_t reserved[32];
} SFSttFooter;
struct SSttFWriter {
struct SSttFWriterConf config;
// time-series data
SBlockData bData;
SArray *aSttBlk; // SArray<SSttBlk>
// tombstone data
SDelBlock dData;
SArray *aDelBlk; // SArray<SDelBlk>
// data
SBlockData bData;
SDelBlock dData;
STbStatisBlock sData;
SArray *aSttBlk; // SArray<SSttBlk>
SArray *aDelBlk; // SArray<SDelBlk>
SArray *aStatisBlk; // SArray<STbStatisBlk>
void *bloomFilter;
SFSttFooter footer;
// helper data
SSkmInfo skmTb;
SSkmInfo skmRow;

19
source/dnode/vnode/src/tsdb/dev/tsdbUtil.h
View File

@ -23,8 +23,10 @@ extern "C" {
#endif
/* Exposed Handle */
typedef struct SDelBlock SDelBlock;
typedef struct SDelBlk SDelBlk;
typedef struct SDelBlock SDelBlock;
typedef struct SDelBlk SDelBlk;
typedef struct STbStatisBlock STbStatisBlock;
typedef struct STbStatisBlk STbStatisBlk;
/* Exposed APIs */
int32_t tDelBlockCreate(SDelBlock *pDelBlock, int32_t capacity);
@ -51,6 +53,19 @@ struct SDelBlk {
int64_t verMax;
int64_t verMin;
};
struct STbStatisBlock {
int32_t capacity;
int32_t nRow;
int64_t *aData[7]; // [suid, uid, skey, sver, ekey, ever, count]
};
struct STbStatisBlk {
int64_t suidMax;
int64_t suidMin;
int64_t uidMax;
int64_t uidMin;
int64_t offset;
int64_t size;
};
#ifdef __cplusplus
}