stream_enforce_eowc_requirement

risingwave_frontend::optimizer::plan_node::convert

Function stream_enforce_eowc_requirement 

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