Module mz_storage::source::persist_source
source · [−]Expand description
A source that reads from an a persist shard.
Structs
The stream of batches from persist cannot be dropped at the discretion of
the program unaided without potentially panicking (check
LeasedBatchPart).
To prevent panics, ensure that all of the stream’s values are consumed,
irrespective of the source getting dropped.Functions
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.