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.