Package com.linkedin.davinci.stats

Class AggVersionedStorageEngineStats

java.lang.Object

com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats<com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsWrapper,com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsReporter>

com.linkedin.davinci.stats.AggVersionedStorageEngineStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggVersionedStorageEngineStats
extends AbstractVeniceAggVersionedStats<com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsWrapper,com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsReporter>

Aggregated versioned storage engine stats with per-store Tehuti reporters and OTel metrics.

OTel stats lifecycle: OTel stats are created lazily by getOrCreateOtelStats(java.lang.String) and updated by onVersionInfoUpdated(java.lang.String, int, int) via computeIfPresent. This class does NOT override loadAllStats(), and AbstractVeniceAggVersionedStats always calls it from its own constructor. As a result, onVersionInfoUpdated and cleanupVersionResources are called from within super(), before the subclass constructor has run at all — meaning otelStatsMap is still null at that point. This makes the null guards in those overrides mandatory.

Field Summary

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

metadataRepository

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	cleanupVersionResources(String storeName, int version)	Hook method for subclasses to clean up version-specific resources (e.g., OTel stats) when a version is removed.
void	handleStoreChanged(Store store)	Called when a store's version info changes.
void	handleStoreDeleted(String storeName)
protected void	onVersionInfoUpdated(String storeName, int currentVersion, int futureVersion)	Updates version info for existing OTel stats only.
void	recordRocksDBOpenFailure(String topicName)
void	setStorageEngine(String topicName, StorageEngine storageEngine)

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

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

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

AggVersionedStorageEngineStats

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

AggVersionedStorageEngineStats

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

Method Details

setStorageEngine

public void setStorageEngine(String topicName,
 StorageEngine storageEngine)

recordRocksDBOpenFailure

public void recordRocksDBOpenFailure(String topicName)

handleStoreChanged

public void handleStoreChanged(Store store)

Called when a store's version info changes. After the parent updates version info, compares the current version's disk size with the future version's disk size when the future version has completed ingestion (PUSHED status). Records 1 in the alert metric if the future version is significantly smaller, or 0 otherwise.

Specified by:

handleStoreChanged in interface StoreDataChangedListener

Overrides:

handleStoreChanged in class AbstractVeniceAggVersionedStats<com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsWrapper,com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsReporter>

onVersionInfoUpdated

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

Updates version info for existing OTel stats only. Uses computeIfPresent intentionally: OTel stats are created lazily on first access via setStorageEngine(java.lang.String, com.linkedin.davinci.store.StorageEngine)/recordRocksDBOpenFailure(java.lang.String), not eagerly here — this avoids the constructor-time re-entrance hazard described in getOrCreateOtelStats(java.lang.String). Null guard: called from super() constructor before otelStatsMap is initialized.

Overrides:

onVersionInfoUpdated in class AbstractVeniceAggVersionedStats<com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsWrapper,com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsReporter>

cleanupVersionResources

protected void cleanupVersionResources(String storeName,
 int version)

Description copied from class: AbstractVeniceAggVersionedStats

Hook method for subclasses to clean up version-specific resources (e.g., OTel stats) when a version is removed. Same re-entrance warning as AbstractVeniceAggVersionedStats.onVersionInfoUpdated(java.lang.String, int, int).

Overrides:

cleanupVersionResources in class AbstractVeniceAggVersionedStats<com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsWrapper,com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsReporter>

handleStoreDeleted

public void handleStoreDeleted(String storeName)

Specified by:

handleStoreDeleted in interface StoreDataChangedListener

Overrides:

handleStoreDeleted in class AbstractVeniceAggVersionedStats<com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsWrapper,com.linkedin.davinci.stats.AggVersionedStorageEngineStats.StorageEngineStatsReporter>