Package com.linkedin.davinci.stats

Class AggVersionedDaVinciRecordTransformerStats

java.lang.Object

com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats<DaVinciRecordTransformerStats,DaVinciRecordTransformerStatsReporter>

com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggVersionedDaVinciRecordTransformerStats
extends AbstractVeniceAggVersionedStats<DaVinciRecordTransformerStats,DaVinciRecordTransformerStatsReporter>

The store level stats for DaVinciRecordTransformer. OTel metrics are recorded directly here (separate API) because Tehuti uses the Reporter layer (DaVinciRecordTransformerStatsReporter) with AsyncGauge polling, while OTel records at the point of the call.

Field Summary

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

metadataRepository

Constructor Summary

Constructors

Constructor	Description
AggVersionedDaVinciRecordTransformerStats(io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository metadataRepository, VeniceServerConfig serverConfig)

Method Summary

Modifier and Type	Method	Description
void	handleStoreDeleted(String storeName)
void	recordDeleteError(String storeName, int version, long timestamp)
void	recordDeleteLatency(String storeName, int version, double value, long timestamp)
void	recordPutError(String storeName, int version, long timestamp)
void	recordPutLatency(String storeName, int version, double value, long timestamp)

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

addStore, cleanupVersionResources, getCurrentVersion, getFutureVersion, getMetricsRepository, getStats, getTotalStats, handleStoreChanged, handleStoreCreated, loadAllStats, onVersionInfoUpdated, 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

AggVersionedDaVinciRecordTransformerStats

public AggVersionedDaVinciRecordTransformerStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 ReadOnlyStoreRepository metadataRepository,
 VeniceServerConfig serverConfig)

Method Details

handleStoreDeleted

public void handleStoreDeleted(String storeName)

Specified by:

handleStoreDeleted in interface StoreDataChangedListener

Overrides:

handleStoreDeleted in class AbstractVeniceAggVersionedStats<DaVinciRecordTransformerStats,DaVinciRecordTransformerStatsReporter>

recordPutLatency

public void recordPutLatency(String storeName,
 int version,
 double value,
 long timestamp)

recordDeleteLatency

public void recordDeleteLatency(String storeName,
 int version,
 double value,
 long timestamp)

recordPutError

public void recordPutError(String storeName,
 int version,
 long timestamp)

recordDeleteError

public void recordDeleteError(String storeName,
 int version,
 long timestamp)