risingwave_stream::executor::wrapper

Module epoch_provide

Functions§

epoch_provide: Streams wrapped by epoch_provide is able to retrieve the current epoch pair from the functions from epoch::task_local.