Struct PatchOptimizerContext 

pub(crate) struct PatchOptimizerContext {
    pub(crate) inner: OptimizerContext,
    pub(crate) config: Arc<ConfigOptions>,
    pub(crate) scheduled_time: Option<DateTime<Utc>>,
}

The ConstEvaluator in SimplifyExpressions might evaluate some UDFs early in the planning stage, by executing them directly. For example, the database() function. So the ConfigOptions here (which is set from the session context) should be present in the UDF’s ScalarFunctionArgs. However, the default implementation in DataFusion seems to lost track on it: the ConfigOptions is recreated with its default values again. So we create a custom OptimizerConfig with the desired ConfigOptions to walk around the issue. TODO(LFC): Maybe use DataFusion’s OptimizerContext again once https://github.com/apache/datafusion/pull/17742 is merged.

Fields

inner: OptimizerContext

config: Arc<ConfigOptions>

scheduled_time: Option<DateTime<Utc>>

Override for query_execution_start_time() — used during scheduled Flow evaluation so that SimplifyExpressions does not constant-fold now() into wall-clock literals. When None, falls back to the inner context.

Trait Implementations

impl OptimizerConfig for PatchOptimizerContext

fn query_execution_start_time(&self) -> Option<DateTime<Utc>>

Return the time at which the query execution started. This time is used as the value for now(). If None, time-dependent functions like now() will not be simplified during optimization.

fn alias_generator(&self) -> &Arc<AliasGenerator>

Return alias generator used to generate unique aliases for subqueries

fn options(&self) -> Arc<ConfigOptions>

fn function_registry(&self) -> Option<&dyn FunctionRegistry>