diff --git a/source/util/src/tcompression.c b/source/util/src/tcompression.c index a6fbb0fe18..a66d4eac70 100644 --- a/source/util/src/tcompression.c +++ b/source/util/src/tcompression.c @@ -146,6 +146,35 @@ int32_t l2DecompressImpl_lz4(const char *const input, const int32_t compressedSi } return -1; } +int32_t l2ComressInitImpl_tsz(char *lossyColumns, float fPrecision, double dPrecision, uint32_t maxIntervals, + uint32_t intervals, int32_t ifAdtFse, const char *compressor) { + return 0; +} +int32_t l2CompressImpl_tsz(const char *const input, const int32_t inputSize, char *const output, int32_t outputSize, + const char type, int8_t lvl) { + if (type == TSDB_DATA_TYPE_FLOAT) { + if (lossyFloat) { + return tsCompressFloatLossyImp(input, inputSize, output); + } + } else if (type == TSDB_DATA_TYPE_DOUBLE) { + if (lossyDouble) { + return tsCompressDoubleLossyImp(input, inputSize, output); + } + } + + return l2CompressImpl_lz4(input, inputSize, output, outputSize, type, lvl); +} + +int32_t l2DecompressImpl_tsz(const char *const input, const int32_t inputSize, char *const output, int32_t outputSize, + const char type) { + if (type == TSDB_DATA_TYPE_FLOAT || type == TSDB_DATA_TYPE_DOUBLE) { + if (HEAD_ALGO(((uint8_t *)input)[0]) == ALGO_SZ_LOSSY) { + return tsDecompressFloatLossyImp(input, inputSize, outputSize, output); + } + } + + return l2DecompressImpl_lz4(input, inputSize, output, outputSize, type); +} #if defined(WINDOWS) || defined(_TD_DARWIN_64) #else int32_t l2ComressInitImpl_zlib(char *lossyColumns, float fPrecision, double dPrecision, uint32_t maxIntervals, @@ -215,35 +244,6 @@ int32_t l2DecompressImpl_zstd(const char *const input, const int32_t compressedS } return -1; } -int32_t l2ComressInitImpl_tsz(char *lossyColumns, float fPrecision, double dPrecision, uint32_t maxIntervals, - uint32_t intervals, int32_t ifAdtFse, const char *compressor) { - return 0; -} -int32_t l2CompressImpl_tsz(const char *const input, const int32_t inputSize, char *const output, int32_t outputSize, - const char type, int8_t lvl) { - if (type == TSDB_DATA_TYPE_FLOAT) { - if (lossyFloat) { - return tsCompressFloatLossyImp(input, inputSize, output); - } - } else if (type == TSDB_DATA_TYPE_DOUBLE) { - if (lossyDouble) { - return tsCompressDoubleLossyImp(input, inputSize, output); - } - } - - return l2CompressImpl_lz4(input, inputSize, output, outputSize, type, lvl); -} - -int32_t l2DecompressImpl_tsz(const char *const input, const int32_t inputSize, char *const output, int32_t outputSize, - const char type) { - if (type == TSDB_DATA_TYPE_FLOAT || type == TSDB_DATA_TYPE_DOUBLE) { - if (HEAD_ALGO(((uint8_t *)input)[0]) == ALGO_SZ_LOSSY) { - return tsDecompressFloatLossyImp(input, inputSize, outputSize, output); - } - } - - return l2DecompressImpl_lz4(input, inputSize, output, outputSize, type); -} int32_t l2ComressInitImpl_xz(char *lossyColumns, float fPrecision, double dPrecision, uint32_t maxIntervals, uint32_t intervals, int32_t ifAdtFse, const char *compressor) {