Module mz_storage_operators::persist_source

source ·
Expand description

A source that reads from an a persist shard.

Structs§

  • Flow control configuration.
  • Pending work to read from fetched parts
  • This opaque token represents progress within a timestamp, allowing finer-grained frontier progress than would otherwise be possible.

Enums§

Traits§

Functions§

  • Apply flow control to the data input, based on the given FlowControl.
  • Creates a new source that reads from a persist shard, distributing the work of reading data to all timely workers.
  • Creates a new source that reads from a persist shard, distributing the work of reading data to all timely workers.

Type Aliases§