flow::recording_rules::time_window

Function probe_expr_time_window_upper_bound

Source 
fn probe_expr_time_window_upper_bound(
    phy_expr: &PhysicalExprRef,
    df_schema: &DFSchema,
    current: Timestamp,
) -> Result<Option<Timestamp>, Error>
Expand description

Probe for the upper bound for time window expression