risingwave_frontend::optimizer::plan_node

Function stream_enforce_eowc_requirement

Source 
pub fn stream_enforce_eowc_requirement(
    ctx: OptimizerContextRef,
    plan: StreamPlanRef,
    emit_on_window_close: bool,
) -> Result<StreamPlanRef>