risingwave_common::util::epoch::task_local

Function curr_epoch

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

Retrieve the current 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.