risingwave_common::util::stream_graph_visitor

Function visit_fragment

source
pub fn visit_fragment<F>(fragment: &mut StreamFragment, f: F)
where F: FnMut(&mut NodeBody),
Expand description

A utility for visiting and mutating the NodeBody of the StreamNodes in a StreamFragment recursively.