Expand description
Run flow as batching mode which is time-window-aware normal query triggered when new data arrives
Modules§
- checkpoint 🔒
- 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
- incremental_
filter 🔒 - state 🔒
- Batching mode task state, which changes frequently
- table_
creator 🔒 - task 🔒
- time_
window 🔒 - Time window expr and helper functions
- utils 🔒
- some utils for helping with batching mode