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

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	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, getCurrentVersion, getFutureVersion, getStats, getTotalStats, handleStoreChanged, handleStoreCreated, handleStoreDeleted, isFutureVersion, 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

AggVersionedDaVinciRecordTransformerStats

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

Method Details

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)