Skip to main content

rewrite_logical_plan_for_stream

risingwave_frontend::optimizer

Function rewrite_logical_plan_for_stream 

Source 
fn rewrite_logical_plan_for_stream(
    plan: &LogicalPlanRef,
    backfill_type: BackfillType,
    locality_backfill_enabled: bool,
) -> Result<(LogicalPlanRef, ColIndexMapping)>