symmetric_hash_join_into_stream

dfir_rs::compiled::pull

Function symmetric_hash_join_into_stream 

Source 
pub async fn symmetric_hash_join_into_stream<'a, Key, Lhs, V1, Rhs, V2, LhsState, RhsState>(
    lhs: Lhs,
    rhs: Rhs,
    lhs_state: &'a mut LhsState,
    rhs_state: &'a mut RhsState,
    is_new_tick: bool,
) -> impl 'a + Stream<Item = (Key, (V1, V2))>
where
    Key: 'a + Eq + Hash + Clone,
    V1: 'a + Clone,
    V2: 'a + Clone,
    Lhs: 'a + Stream<Item = (Key, V1)>,
    Rhs: 'a + Stream<Item = (Key, V2)>,
    LhsState: HalfJoinState<Key, V1, V2>,
    RhsState: HalfJoinState<Key, V2, V1>,
Expand description

Creates a symmetric hash join stream from two input streams and their join states.