Package com.linkedin.venice.spark.consistency
package com.linkedin.venice.spark.consistency
-
ClassDescriptionWraps a
PubSubPositionwith theTopicManagerandPubSubTopicPartitionneeded to compare it, exposing aComparableinterface.Builds aLilyPadUtils.Snapshotfrom a PubSub partition split by reading records through aPubSubSplitIteratorand wrapping positions inComparablePubSubPosition.Core logic for the lily-pad VT consistency algorithm.LilyPadUtils.Inconsistency<T extends Comparable<T>>A single detected VT inconsistency between two DCs for one key.LilyPadUtils.KeyRecord<T extends Comparable<T>>Per-key snapshot of a single VT record, capturing the value, the upstream position vector that the leader used for its DCR decision, the global high-watermark at that moment, and the logical timestamp used by DCR to pick the winner.LilyPadUtils.Snapshot<T extends Comparable<T>>The per-key record history plus the final partition high-watermark.