risingwave_stream::executor

Function epoch

source
pub fn epoch() -> Option<EpochPair>
Expand description

Retrieve the epoch pair 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.