risingwave_connector::sink::log_store

Trait Alias LogWriterPostFlushCurrentEpochFn

source
trait LogWriterPostFlushCurrentEpochFn<'a> = FnOnce(Option<Arc<Bitmap>>) -> BoxFuture<'a, LogStoreResult<()>>;