visit_fragment

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.