refactor compress
This commit is contained in:
parent
f44734707d
commit
d93302a16c
|
@ -2612,7 +2612,7 @@ int32_t tsCompressSmallint(void *pIn, int32_t nIn, int32_t nEle, void *pOut, int
|
||||||
} else if (cmprAlg == TWO_STAGE_COMP) {
|
} else if (cmprAlg == TWO_STAGE_COMP) {
|
||||||
int32_t len = tsCompressINTImp(pIn, nEle, pBuf, TSDB_DATA_TYPE_SMALLINT);
|
int32_t len = tsCompressINTImp(pIn, nEle, pBuf, TSDB_DATA_TYPE_SMALLINT);
|
||||||
if (len < 0) {
|
if (len < 0) {
|
||||||
return 0;
|
return len;
|
||||||
}
|
}
|
||||||
return tsCompressStringImp(pBuf, len, pOut, nOut);
|
return tsCompressStringImp(pBuf, len, pOut, nOut);
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue