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

feat: sort data by time before build submit block in schemaless

This commit is contained in:
wangmm0220 2022-06-11 11:33:46 +08:00
parent 7b1c07cf90
commit 341fe3700b
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/client/src/clientSml.c
View File

@ -1311,8 +1311,8 @@ static int32_t smlKvTimeArrayCompare(const void* key1, const void* key2) {
static int32_t smlKvTimeHashCompare(const void* key1, const void* key2) { static int32_t smlKvTimeHashCompare(const void* key1, const void* key2) {
SHashObj *s1 = (SHashObj *)key1; SHashObj *s1 = (SHashObj *)key1;
SHashObj *s2 = (SHashObj *)key2; SHashObj *s2 = (SHashObj *)key2;
SSmlKv *kv1 = (SSmlKv *)taosArrayGetP(s1, 0); SSmlKv *kv1 = (SSmlKv *)taosHashGet(s1, TS, TS_LEN);
SSmlKv *kv2 = (SSmlKv *)taosArrayGetP(s2, 0); SSmlKv *kv2 = (SSmlKv *)taosHashGet(s2, TS, TS_LEN);
ASSERT(kv1->type == TSDB_DATA_TYPE_TIMESTAMP); ASSERT(kv1->type == TSDB_DATA_TYPE_TIMESTAMP);
ASSERT(kv2->type == TSDB_DATA_TYPE_TIMESTAMP); ASSERT(kv2->type == TSDB_DATA_TYPE_TIMESTAMP);
if (kv1->i < kv2->i) { if (kv1->i < kv2->i) {