TDengine/source/libs/executor/src
WANG MINGMING 4f99614b56
fix(stream): rollback tsdbreader reset to avoid unexcepted error (#33400)
* fix(stream): vnode mem update to avoid lost data

* fix(stream): vnode mem update to avoid lost data

* fix(stream): vnode mem update to avoid lost data

* fix(stream): rollback tsdbreader reset
2025-10-31 17:35:22 +08:00
..
aggregateoperator.c feat: rollup sma (#33063) 2025-09-26 17:32:32 +08:00
anomalywindowoperator.c refactor(gpt): do some internal refactor. (#33123) 2025-09-29 11:43:15 +08:00
cachescanoperator.c fix: last/last_row errors when using together with cols (#32938) 2025-09-12 09:25:43 +08:00
countwindowoperator.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
dataDeleter.c refactor: adjust some logs (#30245) 2025-03-18 17:55:36 +08:00
dataDispatcher.c feat:[TS-4897] virtual table (#30098) 2025-03-15 14:10:46 +08:00
dataInserter.c enh: add stream log (#33201) 2025-10-13 09:10:32 +08:00
dataSinkMgt.c feat: new stream (#31678) 2025-07-16 14:42:16 +08:00
dynqueryctrloperator.c feat: [TD-37052] Handle origin table's vnode change in stream query. (#32931) 2025-09-10 16:12:11 +08:00
eventwindowoperator.c enh: support interp and percentile functions in stream (#33150) 2025-10-13 19:03:45 +08:00
exchangeoperator.c enh: support interp and percentile functions in stream (#33150) 2025-10-13 19:03:45 +08:00
executil.c fix(merge): merge from main 2025-10-21 19:25:14 +08:00
executor.c fix(stream): rollback tsdbreader reset to avoid unexcepted error (#33400) 2025-10-31 17:35:22 +08:00
executorInt.c feat(gpt): add anomalymask pseduo column. (#33090) 2025-09-28 09:47:01 +08:00
externalwindowoperator.c enh: support interp and percentile functions in stream (#33150) 2025-10-13 19:03:45 +08:00
filloperator.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
forecastoperator.c fix(gpt): add additional input check for tdtsfm_1 (#33032) 2025-09-22 13:32:23 +08:00
groupcacheoperator.c fix(stream): memory leak 2025-07-29 17:04:03 +08:00
groupoperator.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
hashjoin.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
hashjoinoperator.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
imputationoperator.c feat(gpt): support correlation functions, e.g., tdw/tdw_path/tlcc (#33425) 2025-10-31 11:26:35 +08:00
mergejoin.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
mergejoinoperator.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
mergeoperator.c feat: new stream (#31678) 2025-07-16 14:42:16 +08:00
operator.c feat(gpt): support correlation functions, e.g., tdw/tdw_path/tlcc (#33425) 2025-10-31 11:26:35 +08:00
projectoperator.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
querytask.c fix(gpt): fix race-condition in preparing tmp files (#32800) 2025-08-29 14:36:36 +08:00
rollupoperator.c enh(rsma): support alter/decimal/composite key (#33177) 2025-10-10 11:24:13 +08:00
scanoperator.c fix(stream): rollback tsdbreader reset to avoid unexcepted error (#33400) 2025-10-31 17:35:22 +08:00
sortoperator.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
streamNotify.c feat: new stream (#31678) 2025-07-16 14:42:16 +08:00
sysscanoperator.c fix(merge): merge from main 2025-10-21 19:25:14 +08:00
tfill.c Merge branch '3.3.6' into merge/3.3.6tomain 2025-10-23 16:49:23 +08:00
timesliceoperator.c enh: support interp and percentile functions in stream (#33150) 2025-10-13 19:03:45 +08:00
timewindowoperator.c feat(stream): optimize stream logic (#33027) 2025-09-25 15:48:14 +08:00
tlinearhash.c Merge pull request #27993 from taosdata/enh/TD-31691 2024-09-20 17:26:58 +08:00
tsort.c enh: optimize vtable scan (#33232) 2025-10-17 13:18:37 +08:00
virtualtablescanoperator.c fix: [TD-38315] virtual supertable scan wrong tsSlotId. (#33288) 2025-10-21 16:19:13 +08:00