risingwave_frontend::stream_fragmenter

Function build_fragment

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

Build new fragment and link dependencies by visiting children recursively, update requires_singleton and fragment_type properties for current fragment.