risingwave_stream::executor::wrapper::epoch_provide

Function epoch_provide

source
pub fn epoch_provide(
    input: impl MessageStream,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>
Expand description

Streams wrapped by epoch_provide is able to retrieve the current epoch pair from the functions from epoch::task_local.