risingwave_storage::mem_table

Function merge_stream

source 
pub(crate) fn merge_stream<'a>(
    mem_table_iter: impl Iterator<Item = (&'a TableKey<Bytes>, &'a KeyOp)> + 'a,
    inner_stream: impl Stream<Item = StorageResult<StateStoreKeyedRow>> + 'static,
    table_id: TableId,
    epoch: u64,
    rev: bool,
) -> impl Stream<Item = Result<StateStoreKeyedRow, StorageError>> + 'a