10652 commits

Author	SHA1	Message	Date
wangmm0220	5e7aed840e	feat(stream): add filter if with external window	2025-05-13 10:53:39 +08:00
dapan1121	009e8aa41e	Merge remote-tracking branch 'origin/3.0' into feat/TS-6100-3.0	2025-05-12 16:24:22 +08:00
wangmm0220	b07d8d2dd0	feat(stream): add interface vnodeProcessStreamGroupColValueReq	2025-05-12 14:33:20 +08:00
Hongze Cheng	0dfb4596fb	enh: add another recover mode (#30985)	2025-05-12 11:28:07 +08:00
Haojun Liao	e439569455	test(stream): update the test cases. (#31044)	2025-05-12 11:25:07 +08:00
facetosea	b0e0d0e565	fix: data insert, table version changed	2025-05-12 10:22:28 +08:00
wangmm0220	df42d12b06	feat(stream): return calc cols and trigger cols from stream reader	2025-05-10 21:22:11 +08:00
wangmm0220	f1155c54ad	feat(stream): return calc cols and trigger cols from stream reader	2025-05-10 18:34:01 +08:00
Jinqing Kuang	4d4544109e	fix(stream): fix history calc of stream trigger task	2025-05-10 18:17:17 +08:00
wangjiaming0909	9bd7381978	stream-runner: runner impl	2025-05-10 15:42:05 +08:00
Jing Sima	84016904ff	fix: [TS-6445] Fix virtual tables not detecting schema changes. (#30999) ... Ensure virtual tables invalidate cached schema metadata and reload it when a schema change (e.g., ALTER VTABLE) is detected. This prevents stale schema references and query errors after structural updates.	2025-05-10 10:34:54 +08:00
wangmm0220	aea901d2c8	fix(stream): add trigger cols	2025-05-09 18:37:54 +08:00
Jinqing Kuang	27d7d71057	fix(stream): fix response type of stream reader task	2025-05-09 14:41:45 +08:00
factosea	9ab3fcd062	fix: datainsert	2025-05-09 14:34:45 +08:00
wangmm0220	441d3d3648	fix(stream): change code from no data to success if wal read out	2025-05-09 12:19:18 +08:00
dongming chen	28fda620c7	feat: add tsRoutineReportInterval and integrate into syncNodeTimerRou… (#30956)	2025-05-09 09:16:49 +08:00
wangmm0220	332d21630c	feat(stream): reset task if fetchMsg.reset is true for calc	2025-05-08 19:53:40 +08:00
wangmm0220	9dfcb4d63b	feat(stream): add logic of fetch rsp for calc	2025-05-08 17:39:12 +08:00
wangmm0220	bc1c0f272d	feat(stream): add logic of fetch rsp for calc	2025-05-08 17:27:09 +08:00
wangjiaming0909	9fd5f6364c	new-stream: runner impl	2025-05-08 14:58:41 +08:00
wangmm0220	1bb860519f	feat(stream): add logic of fetch rsp for calc	2025-05-08 13:52:45 +08:00
wangmm0220	6f8076092e	feat(stream): add logic of fetch rsp for calc	2025-05-08 11:43:45 +08:00
wangmm0220	58959b5526	feat(stream): add logic of fetch rsp for calc	2025-05-08 11:24:37 +08:00
wangmm0220	e28e48cbf9	feat(stream): add logic of fetch rsp for calc	2025-05-08 10:30:51 +08:00
wangmm0220	f4455b3419	feat(stream): add logic of vnodeProcessStreamWalCalcDataReq	2025-05-07 20:17:14 +08:00
pengrongkun94@qq.com	820a0101ae	feat:add auto create table	2025-05-07 11:06:12 +08:00
pengrongkun94@qq.com	d0eb0c5962	fix:invalid but no error output	2025-05-07 11:05:52 +08:00
Jinqing Kuang	1c71c8ce40	fix(stream): fix wal meta datablock of stream reader task	2025-05-06 18:46:14 +08:00
yihaoDeng	209fa90b34	feat(strea): add reader logic for calc	2025-05-06 18:05:47 +08:00
wangmm0220	bd8188c533	fix(stream): add error code if no data in block	2025-05-06 09:43:20 +08:00
wangmm0220	8d9a2b1c56	feat(stream): add logic for stream reader	2025-04-30 18:08:08 +08:00
wangmm0220	2236273044	feat(stream): add logic for stream reader	2025-04-30 17:39:14 +08:00
wangmm0220	10d955528a	feat(stream): add logic for stream reader	2025-04-30 13:37:48 +08:00
wangmm0220	ae43f9023d	feat(stream): remove useless code	2025-04-30 09:14:19 +08:00
wangmm0220	145a535e12	feat(stream): remove useless code	2025-04-30 09:12:20 +08:00
wangmm0220	19a878cc79	feat(stream): add thread worker for stream reader	2025-04-29 18:51:21 +08:00
wangmm0220	0b861a2c7c	feat(stream): add thread worker for stream reader	2025-04-29 16:28:33 +08:00
WANG MINGMING	be7fffcde4	Merge branch 'feat/TS-6100-marks-new' into feat/TS-6100-3.0	2025-04-29 15:05:38 +07:00
wangmm0220	37a315fcc7	feat(stream): add thread worker for stream reader	2025-04-29 16:02:05 +08:00
Jinqing Kuang	162d083951	fix(stream): fix compile issues	2025-04-29 09:23:09 +08:00
wangmm0220	5d13d3a4ce	feat(stream): add logic of stream reader	2025-04-28 19:26:02 +08:00
wangmm0220	c632dcf0c1	feat(stream): add logic of stream reader	2025-04-28 19:21:47 +08:00
wangmm0220	a78b09577a	feat(stream): add thread worker for stream reader	2025-04-28 14:37:05 +08:00
Kaili Xu	b88ec2f1a8	fix: timeseries statis for virtual table (#30911)	2025-04-27 18:03:20 +08:00
wangmm0220	2a1a6d0d95	feat(stream): add thread worker for stream reader	2025-04-27 09:11:50 +08:00
wangmm0220	eee6456cc4	feat(stream): add thread worker for stream reader	2025-04-25 18:18:17 +08:00
dapan1121	cc025dbd59	enh: add task plan update	2025-04-25 14:59:41 +08:00
Hongze Cheng	de110f95ef	fix: invalid parameter input (#30873)	2025-04-24 20:02:52 +08:00
wangmm0220	5ce115cc23	feat(stream): fix compile error	2025-04-24 18:02:12 +08:00
WANG MINGMING	ddd32e23d9	fix(tmq): init tmq handle error if snapshotVer is out of range (#30859)	2025-04-24 09:50:51 +08:00