risingwave_stream::executor::test_utils::hash_join_executor

Function handle_streams

Source 
pub async fn handle_streams(
    hash_join_workload: HashJoinWorkload,
    join_type: JoinType,
    amp: usize,
    tx_l: MessageSender,
    tx_r: MessageSender,
    stream: BoxedMessageStream,
)