Package com.linkedin.davinci.stats

Class AggVersionedDIVStats

java.lang.Object

com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats<DIVStats,DIVStatsReporter>

com.linkedin.davinci.stats.AggVersionedDIVStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggVersionedDIVStats
extends AbstractVeniceAggVersionedStats<DIVStats,DIVStatsReporter>

Aggregated versioned DIV stats with dual Tehuti + OTel recording.

Recording architecture: Each public recording method (e.g., recordSuccessMsg(java.lang.String, int)) records to both Tehuti (via recordVersionedAndTotalStat into total + per-version DIVStats objects) and OTel (once per call, with store/cluster/version-role dimensions). OTel totals are derived at query time by aggregating across the version-role dimension — no separate OTel recording for total stats.

Version classification: The version number passed to each recording method is classified as CURRENT, FUTURE, or BACKUP for the OTel VERSION_ROLE dimension. Versions not matching the registered current or future version default to BACKUP.

Field Summary

Fields inherited from class com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats

metadataRepository

Constructor Summary

Constructors

Constructor	Description
AggVersionedDIVStats(io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository metadataRepository, boolean unregisterMetricForDeletedStoreEnabled, String clusterName)

Method Summary

Modifier and Type	Method	Description
void	handleStoreDeleted(String storeName)
protected void	onVersionInfoUpdated(String storeName, int currentVersion, int futureVersion)	AbstractVeniceAggVersionedStats.addStore(com.linkedin.venice.meta.Store) calls this from the super() constructor before versionInfoMap is initialized.
void	recordBenignLeaderOffsetRewind(String storeName, int version)
void	recordBenignLeaderProducerFailure(String storeName, int version)
void	recordCorruptedMsg(String storeName, int version)
void	recordDuplicateMsg(String storeName, int version)
void	recordException(String storeName, int version, DataValidationException e)
void	recordLeaderProducerFailure(String storeName, int version)
void	recordMissingMsg(String storeName, int version)
void	recordPotentiallyLossyLeaderOffsetRewind(String storeName, int version)
void	recordSuccessMsg(String storeName, int version)
protected void	updateTotalStats(String storeName)	Some versioned stats might always increasing; in this case, the value in the total stats should be updated with the aggregated values across the new version list.

Methods inherited from class com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats

addStore, cleanupVersionResources, getCurrentVersion, getFutureVersion, getMetricsRepository, getStats, getTotalStats, handleStoreChanged, handleStoreCreated, loadAllStats, recordVersionedAndTotalStat, registerConditionalStats, updateStatsVersionInfo

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.meta.StoreDataChangedListener

handleStoreDeleted

Constructor Details

AggVersionedDIVStats

public AggVersionedDIVStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 ReadOnlyStoreRepository metadataRepository,
 boolean unregisterMetricForDeletedStoreEnabled,
 String clusterName)

Method Details

recordException

public void recordException(String storeName,
 int version,
 DataValidationException e)

recordDuplicateMsg

public void recordDuplicateMsg(String storeName,
 int version)

recordMissingMsg

public void recordMissingMsg(String storeName,
 int version)

recordCorruptedMsg

public void recordCorruptedMsg(String storeName,
 int version)

recordSuccessMsg

public void recordSuccessMsg(String storeName,
 int version)

recordBenignLeaderOffsetRewind

public void recordBenignLeaderOffsetRewind(String storeName,
 int version)

recordPotentiallyLossyLeaderOffsetRewind

public void recordPotentiallyLossyLeaderOffsetRewind(String storeName,
 int version)

recordLeaderProducerFailure

public void recordLeaderProducerFailure(String storeName,
 int version)

recordBenignLeaderProducerFailure

public void recordBenignLeaderProducerFailure(String storeName,
 int version)

onVersionInfoUpdated

protected void onVersionInfoUpdated(String storeName,
 int currentVersion,
 int futureVersion)

AbstractVeniceAggVersionedStats.addStore(com.linkedin.venice.meta.Store) calls this from the super() constructor before versionInfoMap is initialized.

Overrides:

onVersionInfoUpdated in class AbstractVeniceAggVersionedStats<DIVStats,DIVStatsReporter>

handleStoreDeleted

public void handleStoreDeleted(String storeName)

Specified by:

handleStoreDeleted in interface StoreDataChangedListener

Overrides:

handleStoreDeleted in class AbstractVeniceAggVersionedStats<DIVStats,DIVStatsReporter>

updateTotalStats

protected void updateTotalStats(String storeName)

Description copied from class: AbstractVeniceAggVersionedStats

Some versioned stats might always increasing; in this case, the value in the total stats should be updated with the aggregated values across the new version list.

Overrides:

updateTotalStats in class AbstractVeniceAggVersionedStats<DIVStats,DIVStatsReporter>