Struct mz_storage::render::debezium::TrackFull

struct TrackFull {
    seen_positions: HashMap<RowCoordinates, i64>,
    seen_snapshot_keys: HashSet<Row>,
    max_seen_time: i64,
    range: Option<TrackRange>,
    started_padding: bool,
    started: bool,
}

If we need to deal with debezium possibly going back after it hasn’t seen things. During normal (non-snapshot) operation, we deduplicate based on binlog position: (pos, row), for MySQL. During the initial snapshot, (pos, row) values are all the same, but primary keys are unique and thus we can get deduplicate based on those.

Fields

seen_positions: HashMap<RowCoordinates, i64>

binlog position to (timestamp that this binlog entry was first seen)

seen_snapshot_keys: HashSet<Row>

max_seen_time: i64

The highest-ever seen timestamp, used in logging to let us know how far backwards time might go

range: Option<TrackRange>

started_padding: bool

started: bool

Whether we have started full deduplication mode

Implementations

impl TrackFull

fn from_keys() -> Self

fn from_keys_in_range(
    start: NaiveDateTime,
    end: NaiveDateTime,
    pad_start: Option<NaiveDateTime>
) -> Self

Trait Implementations

impl Debug for TrackFull

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

Formats the value using the given formatter.