risingwave_stream::executor::wrapper::epoch_check

Function epoch_check

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

Streams wrapped by epoch_check will check whether the first message received is a barrier, and the epoch in the barriers are monotonically increasing.