Skip to main content

next_msg

risingwave_stream::executor::iceberg_with_pk_index::writer

Function next_msg 

Source 
async fn next_msg(
    input: &mut BoxedMessageStream,
) -> StreamExecutorResult<Message>