diff --git a/source/dnode/vnode/src/tsdb/dev/inc/tsdbSttFReaderWriter.h b/source/dnode/vnode/src/tsdb/dev/inc/tsdbSttFReaderWriter.h index ab6e9c97ab..3c76a4289f 100644 --- a/source/dnode/vnode/src/tsdb/dev/inc/tsdbSttFReaderWriter.h +++ b/source/dnode/vnode/src/tsdb/dev/inc/tsdbSttFReaderWriter.h @@ -27,9 +27,21 @@ typedef struct SSttFSegReader SSttFSegReader; typedef struct SSttFileReader SSttFileReader; typedef struct SSttFileReaderConfig SSttFileReaderConfig; +// SSttFileReader int32_t tsdbSttFReaderOpen(const SSttFileReaderConfig *config, SSttFileReader **ppReader); int32_t tsdbSttFReaderClose(SSttFileReader **ppReader); +// SSttFSegReader +int32_t tsdbSttFSegReaderOpen(SSttFileReader *pReader, SSttFSegReader **ppSegReader, int32_t nSegment); +int32_t tsdbSttFSegReaderClose(SSttFSegReader **ppSegReader); +int32_t tsdbSttFSegReadBloomFilter(SSttFSegReader *pSegReader, const void *pFilter); +int32_t tsdbSttFSegReadStatisBlk(SSttFSegReader *pSegReader, const SArray *pStatis); +int32_t tsdbSttFSegReadDelBlk(SSttFSegReader *pSegReader, const SArray *pDelBlk); +int32_t tsdbSttFSegReadSttBlk(SSttFSegReader *pSegReader, const SArray *pSttBlk); +int32_t tsdbSttFSegReadStatisBlock(SSttFSegReader *pSegReader, const void *pBlock); +int32_t tsdbSttFSegReadDelBlock(SSttFSegReader *pSegReader, const void *pBlock); +int32_t tsdbSttFSegReadSttBlock(SSttFSegReader *pSegReader, const void *pBlock); + // SSttFWriter ========================================== typedef struct SSttFileWriter SSttFileWriter; typedef struct SSttFileWriterConfig SSttFileWriterConfig; diff --git a/source/dnode/vnode/src/tsdb/dev/tsdbSttFReaderWriter.c b/source/dnode/vnode/src/tsdb/dev/tsdbSttFReaderWriter.c index fd0127bd49..75b3a5837e 100644 --- a/source/dnode/vnode/src/tsdb/dev/tsdbSttFReaderWriter.c +++ b/source/dnode/vnode/src/tsdb/dev/tsdbSttFReaderWriter.c @@ -27,6 +27,7 @@ struct SSttFileReader { // TODO }; +// SSttFileReader int32_t tsdbSttFReaderOpen(const SSttFileReaderConfig *config, SSttFileReader **ppReader) { int32_t code = 0; // TODO @@ -39,6 +40,61 @@ int32_t tsdbSttFReaderClose(SSttFileReader **ppReader) { return code; } +// SSttFSegReader +int32_t tsdbSttFSegReaderOpen(SSttFileReader *pReader, SSttFSegReader **ppSegReader, int32_t nSegment) { + int32_t code = 0; + // TODO + return code; +} + +int32_t tsdbSttFSegReaderClose(SSttFSegReader **ppSegReader) { + int32_t code = 0; + // TODO + return code; +} + +int32_t tsdbSttFSegReadBloomFilter(SSttFSegReader *pSegReader, const void *pFilter) { + int32_t code = 0; + // TODO + return code; +} + +int32_t tsdbSttFSegReadStatisBlk(SSttFSegReader *pSegReader, const SArray *pStatis) { + int32_t code = 0; + // TODO + return code; +} + +int32_t tsdbSttFSegReadDelBlk(SSttFSegReader *pSegReader, const SArray *pDelBlk) { + int32_t code = 0; + // TODO + return code; +} + +int32_t tsdbSttFSegReadSttBlk(SSttFSegReader *pSegReader, const SArray *pSttBlk) { + int32_t code = 0; + // TODO + return code; +} + +int32_t tsdbSttFSegReadStatisBlock(SSttFSegReader *pSegReader, const void *pBlock) { + int32_t code = 0; + // TODO + return code; +} + +int32_t tsdbSttFSegReadDelBlock(SSttFSegReader *pSegReader, const void *pBlock) { + int32_t code = 0; + // TODO + return code; +} + +int32_t tsdbSttFSegReadSttBlock(SSttFSegReader *pSegReader, const void *pBlock) { + int32_t code = 0; + // TODO + return code; +} + // SSttFWriter ============================================================ struct SSttFileWriter { SSttFileWriterConfig config;