iotdb
iotdb copied to clipboard
Subscription: intro poll and prefetch v2 for tsfile topic
The core idea of v2 is:
- Polling should not drive prefetch; instead, during the remaining time, it should poll the prefetching queue.
- Prefetch should handle tsfile events specially by performing stateful, on-demand parsing (with retries if necessary).
TODO:
- [ ] snapshot auto drop
- [ ] nack