Module create_flow

Modules§

DEFER_ON_MISSING_SOURCE_KEY: The flow option key for creating pending flow metadata when source tables do not exist.
FLOW_EXPERIMENTAL_ENABLE_INCREMENTAL_READ_KEY
FLOW_SCHEDULED_TIME_MILLIS_EXTENSION_KEY 🔒
INTERNAL_EVAL_OFFSET_KEY: Internal transient key used to pass the typed EVAL OFFSET (whole seconds) from the operator to meta through CreateFlowExpr.flow_options. Inserted by the operator only after user option validation; parsed and stripped by CreateFlowTask::try_from. Must never be accepted as a user-provided option and must never be persisted into FlowInfoValue.options or be visible in user runtime options / SHOW CREATE.
INTERNAL_EVAL_SCHEDULE_KEY: Internal transient key used to pass the serialized FlowScheduleConfig from meta to flownode through CreateRequest.flow_options. This key must never be accepted as a user-provided option and must never be persisted into FlowInfoValue.options. TODO(discord9): Replace this transient flow_options transport with a typed field in the flow create request.

ceil_to_boundary 🔒: Computes the ceiling of time to the next schedule boundary aligned with anchor + k * interval. All values are Unix timestamps in seconds.
ceil_to_whole_sec 🔒: Rounds a Utc instant up to the next whole second (Unix seconds), with nanosecond precision.
ceil_whole_sec_from_parts 🔒: Pure ceiling computation factored out of ceil_to_whole_sec so the overflow path is testable: chrono::DateTime<Utc> cannot represent instants near i64::MAX seconds, but the arithmetic below guards it anyway.
defer_on_missing_source
effective_eval_schedule_from_flow_info: Returns the effective typed schedule config for flow metadata.
get_flow_type_from_options
resolve_schedule_defaults_into_task 🔒: Resolve FlowScheduleConfig into task.eval_schedule.
user_runtime_flow_options 🔒
validate_flow_options
without_scheduled_time_extension 🔒