risingwave_stream::task::barrier_manager

Module progress

Source

Structs§

CreateMviewProgressReporter
The progress held by the backfill executors to report to the local barrier manager.

Enums§

BackfillState 🔒

Type Aliases§

ConsumedEpoch 🔒
ConsumedRows 🔒