risingwave_stream::executor::join::hash_join

Function into_stream

source 
pub(crate) fn into_stream<'a, K: HashKey, S: StateStore>(
    join_key_data_types: &'a [DataType],
    pk_indices: &'a [usize],
    pk_serializer: &'a OrderedRowSerde,
    state_table: &'a StateTable<S>,
    key: &'a K,
    degrees: Option<Vec<u64>>,
) -> impl Stream<Item = Result<(Vec<u8>, JoinRow<OwnedRow>), StreamExecutorError>> + 'a