Package com.linkedin.venice.spark.consistency

Class LilyPadUtils.Snapshot<T extends Comparable<T>>

java.lang.Object

com.linkedin.venice.spark.consistency.LilyPadUtils.Snapshot<T>

Type Parameters:

T - the position type used in LilyPadUtils.KeyRecord

Enclosing class:

LilyPadUtils

public static class LilyPadUtils.Snapshot<T extends Comparable<T>>
extends Object

The per-key record history plus the final partition high-watermark. The high-watermark is needed to distinguish genuine MISSING inconsistencies when scanning live (non-completed) version topics.

Field Summary

Fields

Modifier and Type	Field	Description
final Map<Long,List<LilyPadUtils.KeyRecord<T>>>	keyRecords	Per-key record history for this partition, keyed by 64-bit hash of the raw key bytes.
final List<T>	partitionHighWatermark	Final running high-watermark at the end of the scan, indexed by region ID.

Constructor Summary

Constructors

Constructor	Description
Snapshot(Map<Long,List<LilyPadUtils.KeyRecord<T>>> keyRecords, List<T> partitionHighWatermark)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

keyRecords

public final Map<Long,List<LilyPadUtils.KeyRecord<T extends Comparable<T>>>> keyRecords

Per-key record history for this partition, keyed by 64-bit hash of the raw key bytes.

partitionHighWatermark

public final List<T extends Comparable<T>> partitionHighWatermark

Final running high-watermark at the end of the scan, indexed by region ID.

Constructor Details

Snapshot

public Snapshot(Map<Long,List<LilyPadUtils.KeyRecord<T>>> keyRecords,
 List<T> partitionHighWatermark)