Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
adminstrot
TDengine
提交
4ff7eda8
TDengine
项目概览
adminstrot
/
TDengine
与 Fork 源项目一致
Fork自
taosdata / TDengine
通知
1
Star
1
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
4ff7eda8
编写于
4月 07, 2020
作者:
L
lihui
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[TD-113]
上级
a160b2dc
变更
3
显示空白变更内容
内联
并排
Showing
3 changed file
with
29 addition
and
9 deletion
+29
-9
src/client/src/tscFunctionImpl.c
src/client/src/tscFunctionImpl.c
+20
-3
src/client/src/tscSQLParser.c
src/client/src/tscSQLParser.c
+2
-2
src/system/detail/src/vnodeQueryImpl.c
src/system/detail/src/vnodeQueryImpl.c
+7
-4
未找到文件。
src/client/src/tscFunctionImpl.c
浏览文件 @
4ff7eda8
...
...
@@ -4567,7 +4567,7 @@ static void rate_function(SQLFunctionCtx *pCtx) {
if
(
-
DBL_MAX
==
pRateInfo
->
firstValue
)
{
pRateInfo
->
firstValue
=
v
;
}
else
if
(
v
>
pRateInfo
->
firstValue
)
{
pRateInfo
->
CorrectionValue
+=
pRateInfo
->
firstValue
;
pRateInfo
->
CorrectionValue
+=
v
;
pTrace
(
"CorrectionValue:%f"
,
pRateInfo
->
CorrectionValue
);
}
...
...
@@ -4582,7 +4582,7 @@ static void rate_function(SQLFunctionCtx *pCtx) {
if
(
pCtx
->
prev
.
key
!=
-
1
)
{
if
(
pCtx
->
prev
.
data
>
pRateInfo
->
firstValue
)
{
pRateInfo
->
CorrectionValue
+=
p
RateInfo
->
firstValue
;
pRateInfo
->
CorrectionValue
+=
p
Ctx
->
prev
.
data
;
pTrace
(
"CorrectionValue:%f"
,
pRateInfo
->
CorrectionValue
);
}
...
...
@@ -4758,6 +4758,14 @@ static void irate_function(SQLFunctionCtx *pCtx) {
return
;
}
// next interpolation exists
if
(
pCtx
->
next
.
key
!=
-
1
)
{
pRateInfo
->
lastValue
=
pCtx
->
next
.
data
;
pRateInfo
->
lastKey
=
pCtx
->
next
.
key
;
pCtx
->
next
.
key
=
-
1
;
// clear the flag
pTrace
(
"%p irate_function() get next interpolation for lastValue:%f lastKey:%"
PRId64
,
pCtx
,
pRateInfo
->
lastValue
,
pRateInfo
->
lastKey
);
}
for
(
int32_t
i
=
pCtx
->
size
-
1
;
i
>=
0
;
--
i
)
{
char
*
pData
=
GET_INPUT_CHAR_INDEX
(
pCtx
,
i
);
if
(
pCtx
->
hasNull
&&
isNull
(
pData
,
pCtx
->
inputType
))
{
...
...
@@ -4800,7 +4808,7 @@ static void irate_function(SQLFunctionCtx *pCtx) {
continue
;
}
if
((
INT64_MIN
==
pRateInfo
->
firstKey
)
||
(
-
DBL_MAX
==
pRateInfo
->
firstValue
)){
if
((
INT64_MIN
==
pRateInfo
->
firstKey
)
||
(
-
DBL_MAX
==
pRateInfo
->
firstValue
))
{
pRateInfo
->
firstValue
=
v
;
pRateInfo
->
firstKey
=
primaryKey
[
i
];
...
...
@@ -4809,6 +4817,15 @@ static void irate_function(SQLFunctionCtx *pCtx) {
}
}
if
(
pCtx
->
prev
.
key
!=
-
1
)
{
if
((
INT64_MIN
==
pRateInfo
->
firstKey
)
||
(
-
DBL_MAX
==
pRateInfo
->
firstValue
))
{
pRateInfo
->
firstValue
=
pCtx
->
prev
.
data
;
pRateInfo
->
firstKey
=
pCtx
->
prev
.
key
;
pCtx
->
prev
.
key
=
-
1
;
pTrace
(
"%p irate_function() get prev interpolation for firstValue:%f firstKey:%"
PRId64
,
pCtx
,
pRateInfo
->
firstValue
,
pRateInfo
->
firstKey
);
}
}
SET_VAL
(
pCtx
,
notNullElems
,
1
);
if
(
notNullElems
>
0
)
{
...
...
src/client/src/tscSQLParser.c
浏览文件 @
4ff7eda8
...
...
@@ -1645,7 +1645,7 @@ int32_t addExprAndResultField(SQueryInfo* pQueryInfo, int32_t colIdx, tSQLExprIt
SColumnList
ids
=
getColumnList
(
1
,
0
,
0
);
insertResultField
(
pQueryInfo
,
0
,
&
ids
,
TSDB_KEYSIZE
,
TSDB_DATA_TYPE_TIMESTAMP
,
aAggs
[
TSDB_FUNC_TS_DUMMY
].
aName
,
pExpr
);
}
else
if
(
optr
==
TK_RATE
)
{
}
else
if
(
(
optr
>=
TK_RATE
)
&&
(
optr
<=
TK_AVG_IRATE
)
)
{
SColumnIndex
index1
=
{.
tableIndex
=
index
.
tableIndex
,
.
columnIndex
=
PRIMARYKEY_TIMESTAMP_COL_INDEX
};
tscColumnBaseInfoInsert
(
pQueryInfo
,
&
index1
);
}
...
...
src/system/detail/src/vnodeQueryImpl.c
浏览文件 @
4ff7eda8
...
...
@@ -83,7 +83,7 @@ static int32_t getGroupResultId(int32_t groupIndex) {
static
bool
needsBoundaryTS
(
SQuery
*
pQuery
)
{
for
(
int32_t
i
=
0
;
i
<
pQuery
->
numOfOutputCols
;
++
i
)
{
int32_t
functionId
=
pQuery
->
pSelectExpr
[
i
].
pBase
.
functionId
;
if
(
functionId
==
TSDB_FUNC_
RATE
)
{
if
(
functionId
>=
TSDB_FUNC_RATE
&&
functionId
<=
TSDB_FUNC_AVG_I
RATE
)
{
return
true
;
}
}
...
...
@@ -1749,7 +1749,8 @@ static void doBlockwiseApplyFunctions(SQueryRuntimeEnv *pRuntimeEnv, SWindowStat
pCtx
[
k
].
size
=
forwardStep
;
pCtx
[
k
].
startOffset
=
(
QUERY_IS_ASC_QUERY
(
pQuery
))
?
startPos
:
startPos
-
(
forwardStep
-
1
);
if
((
aAggs
[
functionId
].
nStatus
&
TSDB_FUNCSTATE_SELECTIVITY
)
!=
0
||
functionId
==
TSDB_FUNC_RATE
)
{
if
((
aAggs
[
functionId
].
nStatus
&
TSDB_FUNCSTATE_SELECTIVITY
)
!=
0
||
((
functionId
>=
TSDB_FUNC_RATE
)
&&
(
functionId
<=
TSDB_FUNC_AVG_IRATE
)))
{
pCtx
[
k
].
ptsList
=
(
TSKEY
*
)((
char
*
)
pRuntimeEnv
->
primaryColBuffer
->
data
+
pCtx
[
k
].
startOffset
*
TSDB_KEYSIZE
);
}
...
...
@@ -2062,7 +2063,8 @@ static void doSetInterpolationDataForTimeWindow(SQueryRuntimeEnv* pRuntimeEnv, S
// interpolate for skey value
for
(
int32_t
i
=
0
;
i
<
pQuery
->
numOfOutputCols
;
++
i
)
{
if
(
pQuery
->
pSelectExpr
[
i
].
pBase
.
functionId
!=
TSDB_FUNC_RATE
)
{
if
((
pQuery
->
pSelectExpr
[
i
].
pBase
.
functionId
<
TSDB_FUNC_RATE
)
||
(
pQuery
->
pSelectExpr
[
i
].
pBase
.
functionId
>
TSDB_FUNC_AVG_IRATE
))
{
continue
;
}
...
...
@@ -2072,7 +2074,8 @@ static void doSetInterpolationDataForTimeWindow(SQueryRuntimeEnv* pRuntimeEnv, S
// interpolate for ekey value
for
(
int32_t
i
=
0
;
i
<
pQuery
->
numOfOutputCols
;
++
i
)
{
if
(
pQuery
->
pSelectExpr
[
i
].
pBase
.
functionId
!=
TSDB_FUNC_RATE
)
{
if
((
pQuery
->
pSelectExpr
[
i
].
pBase
.
functionId
<
TSDB_FUNC_RATE
)
||
(
pQuery
->
pSelectExpr
[
i
].
pBase
.
functionId
>
TSDB_FUNC_AVG_IRATE
))
{
continue
;
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录