risingwave_
stream
2.2.0-alpha
In risingwave_
stream::
executor::
backfill::
utils
risingwave_stream
::
executor
::
backfill
::
utils
Function
mapping_message
Copy item path
source
pub(crate) fn mapping_message( msg:
Message
, upstream_indices: &[
usize
], ) ->
Option
<
Message
>