risingwave_frontend::optimizer::plan_node::convert

Function stream_enforce_eowc_requirement

source 
pub fn stream_enforce_eowc_requirement(
    ctx: OptimizerContextRef,
    plan: PlanRef,
    emit_on_window_close: bool,
) -> Result<PlanRef, RwError>