Module options 

Structs

FlowQueryExtensions

QueryOptions

Query engine config

ScheduledTimeExtension 🔒

Carries the scheduled logical “now” through [ConfigOptions::extensions] so that the distributed plan analyzer can apply it during expression simplification (preventing wall-clock constant-folding of now()).

Enums

FlowIncrementalMode

Constants

FLOW_INCREMENTAL_AFTER_SEQS

FLOW_INCREMENTAL_MODE

FLOW_INCREMENTAL_MODE_MEMTABLE_ONLY

FLOW_RETURN_REGION_SEQ

FLOW_SCHEDULED_TIME_MILLIS

Flow scheduler binding for the logical time of one scheduled attempt. Query planning, SQL/TQL parsing, range-select rewrite and DataFusion execution read this extension so now() is stable for the whole attempt.

FLOW_SINK_TABLE_ID

QUERY_ENABLE_REMOTE_DYNAMIC_FILTER_PUSHDOWN

Enable by default, set to false to explicitly disable.

Functions

invalid_query_context_extension 🔒

parse_bool 🔒

parse_incremental_after_seqs 🔒

parse_scheduled_time_datetime

Parse the scheduled time from extensions into a DateTime<Utc>.

parse_scheduled_time_millis

Parse the scheduled time (in milliseconds since Unix epoch) from extensions.

remote_dyn_filter_pushdown_enabled_from_extensions

Returns whether query-level remote dynamic filter propagation is enabled.

scheduled_time_from_ctx

Best-effort helper: extract scheduled time from a [QueryContextRef] as a DateTime<Utc>.

should_collect_region_watermark 🔒

should_collect_region_watermark_from_extensions

Returns whether raw Flow query extensions request terminal region watermark collection.