risingwave_common::util::stream_graph_visitor

Function visit_stream_node_stream_scan

Source 
pub fn visit_stream_node_stream_scan(
    stream_node: &StreamNode,
    f: impl FnMut(&StreamScanNode),
)