risingwave_common::util::stream_graph_visitor

Function visit_fragment_mut

Source 
pub fn visit_fragment_mut(
    fragment: &mut StreamFragment,
    f: impl FnMut(&mut NodeBody),
)
Expand description

A utility for visiting and mutating the [NodeBody] of the [StreamNode]s in a [StreamFragment] recursively.