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

fix: use int64 for timestamp

This commit is contained in:
factosea 2024-07-09 18:47:33 +08:00
parent 163b31a4ee
commit 81b62f4a15
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/function/src/builtinsimpl.c
View File

@ -3182,11 +3182,11 @@ static int32_t diffIsNegtive(SDiffInfo* pDiffInfo, int32_t type, const char* pv)
int64_t v = *(int16_t*)pv; int64_t v = *(int16_t*)pv;
return v < pDiffInfo->prev.i64; return v < pDiffInfo->prev.i64;
} }
case TSDB_DATA_TYPE_TIMESTAMP:
case TSDB_DATA_TYPE_UBIGINT:{ case TSDB_DATA_TYPE_UBIGINT:{
uint64_t v = *(uint64_t*)pv; uint64_t v = *(uint64_t*)pv;
return v < (uint64_t)pDiffInfo->prev.i64; return v < (uint64_t)pDiffInfo->prev.i64;
} }
case TSDB_DATA_TYPE_TIMESTAMP:
case TSDB_DATA_TYPE_BIGINT: { case TSDB_DATA_TYPE_BIGINT: {
int64_t v = *(int64_t*)pv; int64_t v = *(int64_t*)pv;
return v < pDiffInfo->prev.i64; return v < pDiffInfo->prev.i64;
@ -3208,7 +3208,7 @@ static int32_t diffIsNegtive(SDiffInfo* pDiffInfo, int32_t type, const char* pv)
static void tryToSetInt64(SDiffInfo* pDiffInfo, int32_t type, SColumnInfoData* pOutput, int64_t v, int32_t pos) { static void tryToSetInt64(SDiffInfo* pDiffInfo, int32_t type, SColumnInfoData* pOutput, int64_t v, int32_t pos) {
bool isNegative = v < pDiffInfo->prev.i64; bool isNegative = v < pDiffInfo->prev.i64;
if(type == TSDB_DATA_TYPE_UBIGINT || type == TSDB_DATA_TYPE_TIMESTAMP){ if(type == TSDB_DATA_TYPE_UBIGINT){
isNegative = (uint64_t)v < (uint64_t)pDiffInfo->prev.i64; isNegative = (uint64_t)v < (uint64_t)pDiffInfo->prev.i64;
} }
int64_t delta = v - pDiffInfo->prev.i64; int64_t delta = v - pDiffInfo->prev.i64;