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

enhance: add log

This commit is contained in:
slzhou 2023-05-24 13:41:21 +08:00
parent 383c828c85
commit 5b1e0be756
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
source/libs/scalar/src/filter.c
View File

@ -3446,10 +3446,10 @@ typedef enum {
typedef struct { typedef struct {
SFltSclDatumKind kind; SFltSclDatumKind kind;
union { union {
int64_t i; // for int64, uint64 and double and bool (1 true, 0 false) int64_t i; // for int and bool (1 true, 0 false) and ts
uint64_t u; uint64_t u; // for uint
double d; double d; // for double
uint8_t *pData; // for varchar, nchar uint8_t *pData; // for varchar, nchar, len prefixed
}; };
SDataType type; // TODO: original data type, may not be used? SDataType type; // TODO: original data type, may not be used?
} SFltSclDatum; } SFltSclDatum;
@ -3765,9 +3765,15 @@ bool filterRangeExecute(SFilterInfo *info, SColumnDataAgg **pDataStatis, int32_t
SColumnDataAgg *pAgg = pDataStatis[j]; SColumnDataAgg *pAgg = pDataStatis[j];
SArray *points = taosArrayInit(2, sizeof(SFltSclPoint)); SArray *points = taosArrayInit(2, sizeof(SFltSclPoint));
fltSclBuildRangeFromBlockSma(colRange, pAgg, numOfRows, points); fltSclBuildRangeFromBlockSma(colRange, pAgg, numOfRows, points);
qDebug("column data agg: nulls %d, rows %d, max %" PRId64 " min " PRId64, pAgg->numOfNull, numOfRows, pAgg->max,
pAgg->min);
SArray *merged = taosArrayInit(8, sizeof(SFltSclPoint)); SArray *merged = taosArrayInit(8, sizeof(SFltSclPoint));
fltSclIntersect(points, colRange->points, merged); fltSclIntersect(points, colRange->points, merged);
bool isIntersect = taosArrayGetSize(merged) != 0; bool isIntersect = taosArrayGetSize(merged) != 0;
qDebug("filter range execute, scalar mode, column range found. colId: %d colName: %s has overlap: %d",
colRange->colNode->colId, colRange->colNode->colName, isIntersect);
taosArrayDestroy(merged); taosArrayDestroy(merged);
taosArrayDestroy(points); taosArrayDestroy(points);
if (!isIntersect) { if (!isIntersect) {