Expand description
Run flow as batching mode which is time-window-aware normal query triggered when new data arrives
Modules§
- engine 🔒
- Batching mode engine
- frontend_
client 🔒 - Frontend client to run flow as batching task which is time-window-aware normal query triggered every tick set by user
- state 🔒
- Batching mode task state, which changes frequently
- task 🔒
- time_
window 🔒 - Time window expr and helper functions
- utils 🔒
- some utils for helping with batching mode