Skip to main content

Module task

flow::batching_mode

Module task 

Source

Modules§

ckpt 🔒
inc 🔒

Structs§

BatchingTask
PlanInfo
TaskArgs
Arguments for creating batching task
TaskConfig
The task’s config, immutable once created

Enums§

DirtyRestore

Constants§

MAX_INCREMENTAL_DIRTY_WINDOW_FILTERS 🔒
Maximum number of dirty time-window predicates attached to one incremental SQL query. This keeps generated OR filters bounded so Substrait encoding and downstream planning remain predictable; if the backlog is larger, the flow drains one capped batch and postpones checkpoint advancement to a later run.

Functions§

determine_query_type 🔒
is_merge_mode_last_non_null 🔒