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
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
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