risingwave_frontend::stream_fragmenter::rewrite::delta_join

Function build_delta_join_without_arrange

source 
pub(crate) fn build_delta_join_without_arrange(
    state: &mut BuildFragmentGraphState,
    current_fragment: &StreamFragment,
    node: StreamNode,
) -> Result<StreamNode, RwError>