risingwave_stream::executor::wrapper

Module epoch_check

Source

Functionsยง

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