risingwave_stream::executor

Function prev_epoch

source
pub fn prev_epoch() -> Option<Epoch>
Expand description

Retrieve the previous epoch from the task local storage.

This value is updated after every yield of the barrier message. Returns None if the first barrier message is not yielded.