expand_tumble_analyzer

flow::df_optimizer

Function expand_tumble_analyzer 

Source 
fn expand_tumble_analyzer(
    plan: LogicalPlan,
) -> Result<Transformed<LogicalPlan>, DataFusionError>
Expand description

expand tumble in aggr expr to tumble_start and tumble_end, also expand related alias and column ref

will add tumble_start and tumble_end to outer projection if not exist before