flow::expr::utils

Function find_plan_time_window_expr_lower_bound

Source 
pub fn find_plan_time_window_expr_lower_bound(
    plan: &TypedPlan,
    current: Timestamp,
) -> Result<Option<Timestamp>>
Expand description

Find lower bound for time current in given plan for the time window expr.

i.e. for time window expr being date_bin(INTERVAL '5 minutes', ts) as time_window and current="2021-07-01 00:01:01.000", return Some("2021-07-01 00:00:00.000")

if plan doesn’t contain a TIME INDEX column, return None