wangmm0220
9ffe95755b
feat(stream): add interface of getting cols value of groupid
2025-05-15 10:03:57 +08:00
facetosea
a93c63053c
feat: build insert data
2025-05-14 19:38:26 +08:00
wangjiaming0909
3db03588bd
impl runner external window operator
2025-05-14 09:55:32 +00:00
wangjiaming0909
ef7d67efe0
new-stream: runner notification
2025-05-14 09:55:07 +00:00
facetosea
0a7ac81aeb
fix: table schema version start from 1
2025-05-14 17:41:51 +08:00
facetosea
11760abea2
fix: subtable schema check when table has exist
2025-05-14 11:12:14 +08:00
wangmm0220
5e7aed840e
feat(stream): add filter if with external window
2025-05-13 10:53:39 +08:00
wangjiaming0909
bfdad60c2e
new-stream: external window operator impl
2025-05-12 17:36:10 +08:00
dapan1121
a4869f5263
fix: compile issues
2025-05-12 17:14:35 +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
facetosea
c913791ffb
fix: clear decoder
2025-05-12 11:16:09 +08:00
facetosea
b0a9169dd7
fix: insertcallback, tdecoder clear
2025-05-12 11:06:52 +08:00
facetosea
b0e0d0e565
fix: data insert, table version changed
2025-05-12 10:22:28 +08:00
Simon Guan
3cfdb304e8
Merge branch 'main' into merge/mainto3.0
2025-05-12 09:01:48 +08:00
wangmm0220
df42d12b06
feat(stream): return calc cols and trigger cols from stream reader
2025-05-10 21:22:11 +08:00
wangjiaming0909
4813560599
fix: external window crash
2025-05-10 19:18:23 +08:00
wangmm0220
f1155c54ad
feat(stream): return calc cols and trigger cols from stream reader
2025-05-10 18:34:01 +08:00
wangjiaming0909
85dbaf78f6
new-stream: fix crash
2025-05-10 16:21:48 +08:00
wangjiaming0909
0c9670b220
new-stream: serialize withExternalWindow flag
2025-05-10 16:04:33 +08:00
wangjiaming0909
c853ad990e
new-stream: external window operator
2025-05-10 15:42:05 +08:00
wangjiaming0909
9bd7381978
stream-runner: runner impl
2025-05-10 15:42:05 +08:00
wangjiaming0909
b9f4426fde
new-stream: runner handle read from cache
2025-05-10 15:42:05 +08:00
facetosea
1946123ac1
fix: tbname
2025-05-10 14:32:01 +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
facetosea
a4e2e1a0b8
feat: normal table version
2025-05-09 17:17:51 +08:00
facetosea
a11fc0d7cd
fix: data insert, build STSchema
2025-05-09 17:05:56 +08:00
factosea
9ab3fcd062
fix: datainsert
2025-05-09 14:34:45 +08:00
factosea
1fafaae137
fix: save table uid
2025-05-09 10:03:35 +08:00
Simon Guan
f31428d422
Merge branch 'main' into merge/mainto3.0
2025-05-09 09:19:07 +08:00
factosea
e4dd28df92
feat inserter param check
2025-05-08 23:00:37 +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
wangjiaming0909
5372df5e22
new-stream: runner impl
2025-05-08 17:36:20 +08:00
wangmm0220
bc1c0f272d
feat(stream): add logic of fetch rsp for calc
2025-05-08 17:27:09 +08:00
Jing Sima
c1ad6d4c70
fix: [TS-6448] Fix schema is old when origin table's column has same prefix during virtual supertable query. ( #31008 )
2025-05-08 17:09:10 +08:00
factosea
14826a47b8
fix: pointer null
2025-05-08 15:25:20 +08:00
factosea
cd9a532064
feat: data inserter
2025-05-08 15:07:04 +08:00
wangjiaming0909
9fd5f6364c
new-stream: runner impl
2025-05-08 14:58:41 +08:00
factosea
f3027e938e
feat: stream data insert
2025-05-08 09:48:53 +08:00
wangmm0220
f4455b3419
feat(stream): add logic of vnodeProcessStreamWalCalcDataReq
2025-05-07 20:17:14 +08:00
wangmm0220
8f1d8729f7
feat(stream): format code
2025-05-07 19:22:18 +08:00
wangjiaming0909
e95c5a9d85
new-stream: runner impl
2025-05-07 18:14:17 +08:00
factosea
b88406554c
enh: auto create table mode
2025-05-07 11:16:07 +08:00
pengrongkun94@qq.com
820a0101ae
feat:add auto create table
2025-05-07 11:06:12 +08:00
pengrongkun94@qq.com
245dc41644
feat:fetch pVgInfo from server
2025-05-07 11:06:02 +08:00
pengrongkun94@qq.com
d0eb0c5962
fix:invalid but no error output
2025-05-07 11:05:52 +08:00
yihaoDeng
209fa90b34
feat(strea): add reader logic for calc
2025-05-06 18:05:47 +08:00
Jinqing Kuang
006cece57f
fix(stream): fix checkpoint hang in vtable stream processing ( #30975 )
...
The checkpoint process could hang during stream processing with virtual
tables. This happened because the merge task was not correctly handling
checkpoint messages.
Jira: https://jira.taosdata.com:18080/browse/TS-6419
2025-05-06 15:12:03 +08:00
wangjiaming0909
1ccc6c69a8
new-stream: runner impl
2025-04-29 15:31:17 +08:00
Jing Sima
6ae805bb7a
feat: [TS-6100] Process SCMCreateStreamReq ver-4
...
support placeHolderBitmap and interval offset in stream trigger.
remove useless code.
2025-04-29 15:19:30 +08:00