Struct dataflow::source::timestamp::PartitionTimestamps

pub struct PartitionTimestamps {
    id: PartitionId,
    bindings: Vec<(Timestamp, MzOffset)>,
}

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

impl PartitionTimestamps

fn new(id: PartitionId) -> Self

fn compact(&mut self, frontier: AntichainRef<'_, Timestamp>)

Advance all timestamp bindings to the frontier, and then combine overlapping offset ranges bound to the same timestamp.

fn add_binding(&mut self, timestamp: Timestamp, offset: MzOffset)

fn get_binding(&self, offset: MzOffset) -> Option<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

impl Debug for PartitionTimestamps

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.