mirror of
https://github.com/taosdata/TDengine
synced 2026-05-24 10:09:01 +00:00
b9eb340111
- Add IDLE_TIMEOUT(duration_time) option to STREAM_OPTIONS for configuring partition idle detection (valid range: [1s, 10d]) - Add IDLE and RESUME event types to EVENT_TYPE option - Track per-partition last-receive time using monotonic clock to detect idle state transitions (ACTIVE -> IDLE -> ACTIVE) - Trigger IDLE event once when a partition exceeds idle timeout; trigger RESUME event immediately when idle partition receives data - Provide _tidlestart/_tidleend placeholders for idle/resume computation SQL (ns precision; incompatible with _twstart/_twend) - Add idle/resume fields to notification payload: idleStart, idleEnd, idleDurationMs; IDLE and RESUME share the same triggerId - Add system test: test/cases/18-StreamProcessing/04-Options/ test_idle_trigger.py covering basic detection, resume, multiple partitions, timeout config, placeholder values, event combinations - Update zh/en SQL reference and advanced-usage docs; add IDLE, IDLE_TIMEOUT, RESUME to reserved keywords list (3.3.4.0+) Co-authored-by: Claude Sonnet 4.6 (1M context) <noreply@anthropic.com> |
||
|---|---|---|
| .. | ||
| Testing/Temporary | ||
| CMakeLists.txt | ||
| mockCatalog.cpp | ||
| mockCatalog.h | ||
| mockCatalogService.cpp | ||
| mockCatalogService.h | ||
| parAlterToBalanceTest.cpp | ||
| parExplainToSyncdbTest.cpp | ||
| parInitialCTest.cpp | ||
| parInitialDTest.cpp | ||
| parInsertTest.cpp | ||
| parSelectTest.cpp | ||
| parShowToUse.cpp | ||
| parStreamTest.cpp | ||
| parTestMain.cpp | ||
| parTestUtil.cpp | ||
| parTestUtil.h | ||