From 3808abf4921e5252389e23141fdf270859521284 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 28 Feb 2024 12:16:22 +0000 Subject: [PATCH] add compress dict --- include/util/tcompression.h | 13 ++++++++++++- source/util/src/tcompression.c | 5 +++++ 2 files changed, 17 insertions(+), 1 deletion(-) diff --git a/include/util/tcompression.h b/include/util/tcompression.h index 5d42cd79cd..7e3073dfde 100644 --- a/include/util/tcompression.h +++ b/include/util/tcompression.h @@ -156,7 +156,6 @@ int32_t tCompressStart(SCompressor *pCmprsor, int8_t type, int8_t cmprAlg); int32_t tCompressEnd(SCompressor *pCmprsor, const uint8_t **ppOut, int32_t *nOut, int32_t *nOrigin); int32_t tCompress(SCompressor *pCmprsor, const void *pData, int64_t nData); - typedef int32_t (*__data_compress_init)(char *lossyColumns, float fPrecision, double dPrecision, uint32_t maxIntervals, uint32_t intervals, int32_t ifAdtFse, const char *compressor); typedef int32_t (*__data_compress_l1_fn_t)(const char *const input, const int32_t nelements, char *const output, @@ -169,6 +168,18 @@ typedef int32_t (*__data_compress_l2_fn_t)(const char *const input, const int32_ typedef int32_t (*__data_decompress_l2_fn_t)(const char *const input, const int32_t nelements, char *const output, const char type); +typedef struct { + __data_compress_init initFn; + __data_compress_l1_fn_t l1CompFn; + __data_decompress_l1_fn_t l1DeCompFn; +} TCompressL1; + +typedef struct { + __data_compress_init initFn; + __data_compress_l2_fn_t l2CompFn; + __data_decompress_l2_fn_t l2DeCompFn; +} TCompressL2; + typedef struct { int8_t type; int8_t level; diff --git a/source/util/src/tcompression.c b/source/util/src/tcompression.c index f0e6a5550d..7c5b66226e 100644 --- a/source/util/src/tcompression.c +++ b/source/util/src/tcompression.c @@ -2392,3 +2392,8 @@ int32_t tsDecompressBigint(void *pIn, int32_t nIn, int32_t nEle, void *pOut, int return -1; } } + +TCompressL1 compressL1Dict[] = {{NULL, NULL, NULL}, {NULL, NULL, NULL}}; +TCompressL2 compressL2Dict[] = {{NULL, NULL, NULL}, {NULL, NULL, NULL}}; + +