Struct dataflow::source::timestamp::PartitionTimestamps [−][src]
Expand description
This struct holds per partition timestamp binding state, as a ordered list of bindings (time, offset). Each binding indicates “all offsets < offset must be bound to time”, and adjacent pairs of bindings (time1, offset1), (time2, offset2) denote that offsets in [offset1, offset2) should get bound to time1.
Fields
id: PartitionId
bindings: Vec<(Timestamp, MzOffset)>
Implementations
Advance all timestamp bindings to the frontier, and then combine overlapping offset ranges bound to the same timestamp.
Gets the minimal timestamp binding (time, offset) for offset (the minimal time with offset > requested offset.
Returns None if no such binding exists.
fn get_bindings_in_range(
&self,
lower: AntichainRef<'_, Timestamp>,
upper: AntichainRef<'_, Timestamp>,
bindings: &mut Vec<(PartitionId, Timestamp, MzOffset)>
)
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for PartitionTimestamps
impl Send for PartitionTimestamps
impl Sync for PartitionTimestamps
impl Unpin for PartitionTimestamps
impl UnwindSafe for PartitionTimestamps
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more