10690 commits

Author	SHA1	Message	Date
wangmm0220	f7eb3328c2	fix(stream): print block	2025-06-05 09:48:16 +08:00
wangmm0220	3a82e07bc4	fix(stream): data error for external window & add pesudo function & multi instance for calc reader	2025-06-04 14:09:47 +08:00
wangmm0220	e7c84442dc	fix(stream): add get tsdb/wal interface for vtable	2025-06-03 14:09:25 +08:00
wangmm0220	db29960716	fix(stream): add get last/first ts interface for vtable	2025-05-30 18:54:18 +08:00
facetosea	734e09a22f	fix: table uid hash cache	2025-05-29 11:30:28 +08:00
wangmm0220	3a38149af6	fix(stream): add get OTableInfo interface	2025-05-28 19:41:10 +08:00
wangmm0220	e6dfbf6295	fix(stream): add interface of get vtable info	2025-05-28 18:34:19 +08:00
wangmm0220	1661db33b3	fix(stream): processTag coredump in walCaclRequest	2025-05-28 14:45:48 +08:00
Jing Sima	fa5b70d670	feat: [TS-6100] Parse create stream sql: Sql gen refacotr.	2025-05-28 13:52:56 +08:00
Jinqing Kuang	5f3d1df1fa	Merge branch '3.0' into feat/TS-6100-3.0	2025-05-27 19:31:36 +08:00
Hongze Cheng	430da1f872	enh: add memory usage monitor for vnode (#31212)	2025-05-27 16:40:03 +08:00
wangmm0220	9772e9846c	fix(stream): error if %%n with varchar tag	2025-05-26 19:56:41 +08:00
wangmm0220	3aa8c175f5	feat(stream): reset agg operator & reset tsdb reader in fetch request	2025-05-26 14:52:02 +08:00
Jinqing Kuang	cd5ef52a9d	fix(stream): remove unused files	2025-05-26 09:38:40 +08:00
Jinqing Kuang	18566df281	Merge branch '3.0' into kjq-merge	2025-05-24 14:56:21 +08:00
Haojun Liao	11665b6efe	fix(stream): control the global parameters.	2025-05-23 14:36:20 +08:00
Haojun Liao	8b2eb18323	fix(stream): update the stream info for update.	2025-05-23 11:01:28 +08:00
Haojun Liao	02d70186d2	refactor(stream): add parameters to config the stream queue size.	2025-05-22 19:56:49 +08:00
Haojun Liao	f5db6532dc	refactor(stream): add parameters to config the write queue size.	2025-05-22 19:54:54 +08:00
Haojun Liao	4743cc3683	refactor(stream): check for write queue size for sink tasks.	2025-05-22 17:55:47 +08:00
wangmm0220	2d717c3a4f	feat(stream): set tag value in trigger cols	2025-05-22 15:38:32 +08:00
Haojun Liao	231d8b416e	fix(stream): fix memory leak.	2025-05-22 09:55:18 +08:00
wangmm0220	b13967b8f3	feat(stream): move SStorageAPI from stream directory to vnode	2025-05-17 16:00:50 +08:00
wangmm0220	96ab95e33b	feat(stream): add group values	2025-05-17 11:41:46 +08:00
factosea	edcec9f02b	fix: create table has exist	2025-05-17 10:47:56 +08:00
wangmm0220	3f08f95dde	feat(stream): fix col id error	2025-05-16 17:03:55 +08:00
wangmm0220	2891e73399	feat(stream): fix compile error	2025-05-16 16:13:44 +08:00
wangmm0220	a5007823b8	feat(stream): add ctime for getting wal meta	2025-05-16 16:14:42 +08:00
wangmm0220	39015385f9	feat(stream): add some logs	2025-05-16 09:23:52 +08:00
wangmm0220	88414a1b09	feat(stream): use TimeRangeExpr to filter data in tsdb reader	2025-05-15 19:07:42 +08:00
WANG MINGMING	40216c6143	opti(tmq): save tmq offset in vnode commit time & change log level (#30993)	2025-05-15 18:15:01 +08:00
wangmm0220	0297c7be2c	feat(stream): add ts slotid/blockId in external window	2025-05-15 14:22:46 +08:00
wangmm0220	9ffe95755b	feat(stream): add interface of getting cols value of groupid	2025-05-15 10:03:57 +08:00
facetosea	0a7ac81aeb	fix: table schema version start from 1	2025-05-14 17:41:51 +08:00
wangmm0220	a1955fb3af	feat(stream): add ast for calc in stream reader	2025-05-14 17:39:02 +08:00
facetosea	11760abea2	fix: subtable schema check when table has exist	2025-05-14 11:12:14 +08:00
Haojun Liao	d02b17be0e	fix(stream): extends the node update check interval. (#31048)	2025-05-14 10:15:17 +08:00
wangmm0220	9032653fad	feat(stream): add filter if with external window	2025-05-13 17:57:15 +08:00
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