risingwave_frontend::stream_fragmenter

Function build_and_add_fragment

source
fn build_and_add_fragment(
    state: &mut BuildFragmentGraphState,
    stream_node: StreamNode,
) -> Result<Rc<StreamFragment>, RwError>
Expand description

Use the given stream_node to create a fragment and add it to graph.