flow::recording_rules::time_window

Function eval_phy_time_window_expr

Source 
fn eval_phy_time_window_expr(
    phy: &PhysicalExprRef,
    df_schema: &DFSchema,
    input_value: Timestamp,
) -> Result<Timestamp, Error>
Expand description

Expect the phy expression only have one input column with Timestamp type, and also return Timestamp type