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

chore: optimize of report time series by quantity

This commit is contained in:
kailixu 2023-08-30 11:45:07 +08:00
parent 8e20740622
commit 1a34cd1020
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/dnode/vnode/inc/vnode.h
View File

@ -288,6 +288,7 @@ typedef struct {
int64_t numOfSTables; int64_t numOfSTables;
int64_t numOfCTables; int64_t numOfCTables;
int64_t numOfNTables; int64_t numOfNTables;
int64_t numOfCmprTables;
int64_t numOfNTimeSeries; int64_t numOfNTimeSeries;
int64_t numOfTimeSeries; int64_t numOfTimeSeries;
int64_t itvTimeSeries; int64_t itvTimeSeries;

1
source/dnode/vnode/src/inc/vnodeInt.h
View File

@ -354,7 +354,6 @@ struct SVStatis {
int64_t nInsertSuccess; // delta int64_t nInsertSuccess; // delta
int64_t nBatchInsert; // delta int64_t nBatchInsert; // delta
int64_t nBatchInsertSuccess; // delta int64_t nBatchInsertSuccess; // delta
int64_t nComparedTables;
}; };
struct SVnodeInfo { struct SVnodeInfo {

5
source/dnode/vnode/src/meta/metaQuery.c
View File

@ -700,14 +700,15 @@ int64_t metaGetTbNum(SMeta *pMeta) {
int64_t metaGetTimeSeriesNum(SMeta *pMeta) { int64_t metaGetTimeSeriesNum(SMeta *pMeta) {
// sum of (number of columns of stable - 1) * number of ctables (excluding timestamp column) // sum of (number of columns of stable - 1) * number of ctables (excluding timestamp column)
int64_t nTables = metaGetTbNum(pMeta); int64_t nTables = metaGetTbNum(pMeta);
if (nTables - pMeta->pVnode->statis.nComparedTables > 100 || pMeta->pVnode->config.vndStats.numOfTimeSeries <= 0 || if (nTables - pMeta->pVnode->config.vndStats.numOfCmprTables > 100 ||
pMeta->pVnode->config.vndStats.numOfTimeSeries <= 0 ||
++pMeta->pVnode->config.vndStats.itvTimeSeries % (60 * 5) == 0) { ++pMeta->pVnode->config.vndStats.itvTimeSeries % (60 * 5) == 0) {
int64_t num = 0; int64_t num = 0;
vnodeGetTimeSeriesNum(pMeta->pVnode, &num); vnodeGetTimeSeriesNum(pMeta->pVnode, &num);
pMeta->pVnode->config.vndStats.numOfTimeSeries = num; pMeta->pVnode->config.vndStats.numOfTimeSeries = num;
pMeta->pVnode->config.vndStats.itvTimeSeries = (TD_VID(pMeta->pVnode) % 100) * 2; pMeta->pVnode->config.vndStats.itvTimeSeries = (TD_VID(pMeta->pVnode) % 100) * 2;
pMeta->pVnode->statis.nComparedTables = nTables; pMeta->pVnode->config.vndStats.numOfCmprTables = nTables;
} }
return pMeta->pVnode->config.vndStats.numOfTimeSeries + pMeta->pVnode->config.vndStats.numOfNTimeSeries; return pMeta->pVnode->config.vndStats.numOfTimeSeries + pMeta->pVnode->config.vndStats.numOfNTimeSeries;