risingwave_stream::executor::backfill::utils

Function owned_row_iter

source 
pub(crate) fn owned_row_iter<S, E>(
    storage_iter: S,
) -> impl Stream<Item = Result<OwnedRow, StreamExecutorError>>
where
    StreamExecutorError: From<E>,
    S: Stream<Item = Result<KeyedRow<Bytes>, E>>,