risingwave_common::util::stream_graph_visitor

Function visit_stream_node

source 
pub fn visit_stream_node(stream_node: &StreamNode, f: impl FnMut(&NodeBody))
Expand description

A utility for visiting the NodeBody of the StreamNodes recursively.