Module persist_source 

A source that reads from an a persist shard.

Structs

FlowControl

Flow control configuration.

Subtime

This opaque token represents progress within a timestamp, allowing finer-grained frontier progress than would otherwise be possible.

Traits

Backpressureable

A trait representing a type that can be used in backpressure.

Functions

backpressure

Apply flow control to the data input, based on the given FlowControl.

decode_and_mfp

persist_source

Creates a new source that reads from a persist shard, distributing the work of reading data to all timely workers.

persist_source_core

Creates a new source that reads from a persist shard, distributing the work of reading data to all timely workers.