risingwave_common::util::stream_graph_visitor

Function visit_fragment

source 
pub fn visit_fragment(fragment: &StreamFragment, f: impl FnMut(&NodeBody))
Expand description

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