#4985
72%
main: 60%

Ran 15 Mar 2026 07:53PM UTC

Jobs 1

Files 609

Run time 1min

Badge

Embed ▾

Committed 15 Mar 2026 07:43AM UTC coverage: 68.601% (-0.04%) from 68.643%

Build # #4985

Build Type

push

travis-ci

Committed by

web-flow

Commit Message

feat(stream): add natural time units support for PERIOD trigger (#34766)

Implement week/month/year units for stream PERIOD trigger with natural
boundary alignment and offset support.

Key changes:
- Parser: Add validation for natural time units (w/n/y) and offset parameter
- Time utilities: Add getDuration() support for week/month/year units
- TriggerTask: Implement window calculation with natural boundary alignment
  - Week: align to Monday 00:00:00
  - Month: align to 1st of month 00:00:00
  - Year: align to Jan 1st 00:00:00
- Add offset support: PERIOD(1w, 1d) shifts window by 1 day
- Unit tests: Parser validation, time utilities, TriggerTask window calculation
- System tests: End-to-end tests for week/month/year units with offset
- Documentation: Update user manual with natural time unit examples

Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>

Run Details

2 of 60 new or added lines in 2 files covered. (3.33%)

448 existing lines in 114 files now uncovered.

212624 of 309941 relevant lines covered (68.6%)

136450774.73 hits per line

New Missed Lines in Diff

Lines	Coverage	∆	File
58	78.04	-3.44%	source/common/src/ttime.c

Uncovered Existing Lines

Lines	Coverage	∆	File
1	38.36	-0.22%	contrib/TSZ/sz/src/Huffman.c
1	86.43	-0.36%	include/util/tencode.h
1	70.63	0.37%	source/client/src/clientImpl.c
1	37.9	0.13%	source/client/src/clientMain.c
1	87.17	-0.29%	source/client/src/clientSmlJson.c
1	87.17	-0.29%	source/client/src/clientSmlLine.c
1	89.86	-0.72%	source/client/src/clientSmlTelnet.c
1	58.89	-0.37%	source/common/src/tmisce.c
1	84.71	-0.59%	source/dnode/mgmt/mgmt_snode/src/smHandle.c
1	72.57	-0.07%	source/dnode/mgmt/mgmt_vnode/src/vmHandle.c
1	80.09	-0.11%	source/dnode/mnode/impl/src/mndStreamUtil.c
1	78.4	-0.11%	source/dnode/vnode/src/meta/metaCache.c
1	76.44	0.0%	source/dnode/vnode/src/meta/metaEntry2.c
1	81.65	0.23%	source/dnode/vnode/src/tsdb/tsdbIter.c
1	69.02	-0.19%	source/dnode/vnode/src/vnd/vnodeSync.c
1	55.94	0.0%	source/libs/catalog/src/catalog.c
1	76.3	0.21%	source/libs/executor/src/externalwindowoperator.c
1	76.22	0.0%	source/libs/executor/src/groupoperator.c
1	90.31	-0.1%	source/libs/executor/src/timesliceoperator.c
1	72.06	0.0%	source/libs/function/src/thistogram.c
1	89.25	-0.07%	source/libs/new-stream/src/streamTriggerMerger.c
1	78.43	0.09%	source/libs/nodes/src/nodesCloneFuncs.c
1	89.94	0.0%	source/libs/parser/src/parAuthenticator.c
1	44.96	-0.17%	source/libs/parser/src/parser.c
1	83.59	-0.51%	source/libs/planner/src/planScaleOut.c
1	66.98	-0.12%	source/libs/qcom/src/querymsg.c
1	80.99	0.18%	source/libs/qworker/src/qworker.c
1	76.4	-0.18%	source/libs/qworker/src/qwUtil.c
1	83.14	0.0%	source/libs/sync/src/syncRaftCfg.c
1	69.7	0.2%	source/libs/tdb/src/db/tdbBtree.c
1	86.82	-0.32%	source/libs/tdb/src/db/tdbPCache.c
1	56.64	0.0%	source/libs/transport/src/transSvr.c
1	56.06	0.0%	source/os/src/osSocket.c
1	75.09	-0.38%	source/util/src/talgo.c
1	89.37	-0.48%	source/util/src/theap.c
1	75.0	0.0%	source/util/src/tjson.c
1	83.64	-0.36%	source/util/src/trbtree.c
1	46.9	0.0%	tools/taos-tools/deps/toolscJson/src/toolscJson.c
2	55.26	-0.28%	source/client/src/clientEnv.c
2	64.02	0.0%	source/client/src/clientStmt.c
2	78.04	-3.44%	source/common/src/ttime.c
2	76.64	-0.57%	source/common/src/tvariant.c
2	71.35	-0.27%	source/dnode/mnode/impl/src/mndSsMigrate.c
2	85.71	-0.82%	source/dnode/snode/src/snode.c
2	51.63	-0.44%	source/dnode/vnode/src/meta/metaOpen.c
2	80.44	1.01%	source/libs/executor/src/aggregateoperator.c
2	67.79	0.05%	source/libs/executor/src/dataInserter.c
2	80.84	-0.07%	source/libs/executor/src/exchangeoperator.c
2	76.34	0.16%	source/libs/executor/src/executil.c
2	79.28	0.0%	source/libs/executor/src/executorInt.c
2	82.78	-0.51%	source/libs/executor/src/filloperator.c
2	82.69	-0.18%	source/libs/executor/src/sortoperator.c
2	89.7	-0.14%	source/libs/executor/src/tfill.c
2	42.7	-0.03%	source/libs/nodes/src/nodesCodeFuncs.c
2	72.81	0.0%	source/libs/parser/src/parAstCreater.c
2	89.87	-0.63%	source/libs/parser/src/parInsertSml.c
2	83.13	-2.41%	source/libs/sync/src/syncEnv.c
2	89.8	-4.08%	source/libs/sync/src/syncRequestVote.c
2	55.61	-0.53%	source/os/src/osSemaphore.c
2	72.73	-0.42%	source/util/src/tcache.c
2	24.86	-0.1%	source/util/src/tmempool.c
2	76.98	-0.24%	source/util/src/tworker.c
3	70.43	-0.04%	source/common/src/tdatablock.c
3	81.12	-0.33%	source/dnode/mnode/impl/src/mndMain.c
3	57.32	0.16%	source/dnode/mnode/impl/src/mndRetention.c
3	84.44	-0.95%	source/dnode/vnode/src/vnd/vnodeCfg.c
3	78.46	-0.11%	source/libs/command/src/explain.c
3	61.38	0.14%	source/libs/executor/src/operator.c
3	81.7	-0.43%	source/libs/executor/src/querytask.c
3	76.92	-0.11%	source/libs/executor/src/timewindowoperator.c
3	82.28	-0.36%	source/libs/function/src/functionMgt.c
3	52.61	-0.24%	source/libs/index/src/indexFilter.c
3	84.23	-0.02%	source/libs/planner/src/planOptimizer.c
3	73.99	-0.58%	source/libs/qcom/src/queryUtil.c
3	87.31	0.34%	source/libs/scalar/src/sclvector.c
3	80.08	-0.8%	source/libs/scheduler/src/schUtil.c
4	89.04	-0.32%	source/client/src/clientSml.c
4	63.67	-0.25%	source/client/src/clientStmt2.c
4	71.67	-0.51%	source/dnode/mnode/impl/src/mndScan.c
4	67.75	-0.14%	source/dnode/mnode/impl/src/mndVgroup.c
4	63.71	-0.19%	source/libs/catalog/src/ctgRemote.c
4	67.67	-0.06%	source/libs/catalog/src/ctgUtil.c
4	77.67	0.0%	source/libs/function/src/builtinsimpl.c
4	75.0	-0.12%	source/libs/parser/src/parInsertUtil.c
4	76.69	-0.17%	source/libs/scalar/src/scalar.c
4	77.22	-0.22%	source/libs/scheduler/src/schRemote.c
4	77.63	0.41%	source/libs/sync/src/syncPipeline.c
5	67.55	0.14%	source/common/src/tdataformat.c
5	70.33	-1.1%	source/dnode/mnode/impl/src/mndSync.c
5	67.48	-0.33%	source/dnode/vnode/src/meta/metaTable2.c
5	74.73	1.15%	source/libs/executor/src/sysscanoperator.c
5	78.27	-0.28%	source/libs/executor/src/tsort.c
5	51.46	-0.49%	source/os/src/osThread.c
6	58.26	1.24%	source/dnode/mnode/impl/src/mndArbGroup.c
6	52.43	-1.94%	source/libs/new-stream/src/dataSinkCache.c
6	76.13	-0.44%	source/libs/scheduler/src/schJob.c
7	76.11	-0.21%	source/dnode/mnode/impl/src/mndStreamMgmt.c
7	77.49	0.0%	source/libs/scalar/src/filter.c
8	85.71	1.86%	include/util/tcoding.h
8	75.45	-0.71%	source/client/src/clientHb.c
8	54.27	-0.36%	source/libs/parser/src/parInsertStmt.c
8	62.96	-1.33%	source/libs/tmqtt/mqtt/src/tmqttCtx.c
9	63.35	-0.41%	source/libs/sync/src/syncMain.c
10	69.47	-5.26%	source/dnode/vnode/src/vnd/vnodeBufPool.c
10	68.33	-0.34%	source/libs/catalog/src/ctgAsync.c
10	83.65	-0.23%	source/libs/executor/src/scanoperator.c
11	70.99	-0.4%	source/libs/executor/src/executor.c
11	71.51	-1.31%	source/libs/new-stream/src/streamRunner.c
13	70.21	0.08%	source/libs/catalog/src/ctgCache.c
16	80.57	-0.8%	source/libs/decimal/src/decimal.c
19	70.19	-0.55%	source/libs/transport/src/transCli.c
21	73.83	-3.07%	source/dnode/vnode/src/tsdb/tsdbSnapshot.c
22	70.95	-2.22%	source/libs/transport/src/transComm.c
30	40.09	-6.61%	contrib/libmqtt/ttq/src/ttqSubs.c

Jobs

ID	Job ID	Ran	Files	Coverage
1	#4985.1	15 Mar 2026 07:53PM UTC	609	68.6

taosdata / TDengine / #4985
72%
main: 60%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build #4985

taosdata / TDengine / #4985 72% main: 60%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build #4985

taosdata / TDengine / #4985
72%
main: 60%

README BADGES
x