Package com.linkedin.davinci.stats

Class AggVersionedIngestionStats

java.lang.Object

com.linkedin.davinci.stats.AbstractVeniceAggVersionedStats<IngestionStats,IngestionStatsReporter>

com.linkedin.davinci.stats.AggVersionedIngestionStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggVersionedIngestionStats
extends AbstractVeniceAggVersionedStats<IngestionStats,IngestionStatsReporter>

The store level stats or the total stats will be unpopulated because there is no easy and reliable way to aggregate gauge stats such as rt topic offset lag.

Field Summary

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

metadataRepository

Constructor Summary

Constructors

Constructor	Description
AggVersionedIngestionStats(io.tehuti.metrics.MetricsRepository metricsRepository, ReadOnlyStoreRepository storeRepository, VeniceServerConfig serverConfig)

Method Summary

Modifier and Type	Method	Description
void	recordBytesConsumed(java.lang.String storeName, int version, long bytes)
void	recordConsumedRecordEndToEndProcessingLatency(java.lang.String storeName, int version, double value, long currentTimeMs)
void	recordFollowerConsumed(java.lang.String storeName, int version, long bytes)
void	recordLeaderConsumed(java.lang.String storeName, int version, long bytes)
void	recordLeaderProduced(java.lang.String storeName, int version, long bytesProduced, int recordCount)
void	recordMaxIdleTime(java.lang.String storeName, int version, long idleTimeMs)
void	recordNearlineLocalBrokerToReadyToServeLatency(java.lang.String storeName, int version, double value, long timestamp)
void	recordNearlineProducerToLocalBrokerLatency(java.lang.String storeName, int version, double value, long timestamp)
void	recordOffsetRegressionDCRError(java.lang.String storeName, int version)
void	recordProducerCallBackLatency(java.lang.String storeName, int version, double value, long currentTimeMs)
void	recordRecordsConsumed(java.lang.String storeName, int version)
void	recordRegionHybridConsumption(java.lang.String storeName, int version, int regionId, long bytesConsumed, long offsetConsumed, long currentTimeMs)
void	recordSubscribePrepLatency(java.lang.String storeName, int version, double value)
void	recordTimestampRegressionDCRError(java.lang.String storeName, int version)
void	recordTombStoneCreationDCR(java.lang.String storeName, int version)
void	recordTotalDCR(java.lang.String storeName, int version)
void	recordTransformerError(java.lang.String storeName, int version, double value, long timestamp)
void	recordTransformerLatency(java.lang.String storeName, int version, double value, long timestamp)
void	recordUpdateIgnoredDCR(java.lang.String storeName, int version)
void	recordVersionTopicEndOffsetRewind(java.lang.String storeName, int version)
void	registerTransformerErrorSensor(java.lang.String storeName, int version)
void	registerTransformerLatencySensor(java.lang.String storeName, int version)
void	resetIngestionTaskPushTimeoutGauge(java.lang.String storeName, int version)
void	setIngestionTask(java.lang.String storeVersionTopic, StoreIngestionTask ingestionTask)
void	setIngestionTaskPushTimeoutGauge(java.lang.String storeName, int version)

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 Detail

AggVersionedIngestionStats

public AggVersionedIngestionStats(io.tehuti.metrics.MetricsRepository metricsRepository,
                                  ReadOnlyStoreRepository storeRepository,
                                  VeniceServerConfig serverConfig)

Method Detail

setIngestionTask

public void setIngestionTask(java.lang.String storeVersionTopic,
                             StoreIngestionTask ingestionTask)

recordRecordsConsumed

public void recordRecordsConsumed(java.lang.String storeName,
                                  int version)

recordBytesConsumed

public void recordBytesConsumed(java.lang.String storeName,
                                int version,
                                long bytes)

recordLeaderConsumed

public void recordLeaderConsumed(java.lang.String storeName,
                                 int version,
                                 long bytes)

recordFollowerConsumed

public void recordFollowerConsumed(java.lang.String storeName,
                                   int version,
                                   long bytes)

recordLeaderProduced

public void recordLeaderProduced(java.lang.String storeName,
                                 int version,
                                 long bytesProduced,
                                 int recordCount)

recordRegionHybridConsumption

public void recordRegionHybridConsumption(java.lang.String storeName,
                                          int version,
                                          int regionId,
                                          long bytesConsumed,
                                          long offsetConsumed,
                                          long currentTimeMs)

recordUpdateIgnoredDCR

public void recordUpdateIgnoredDCR(java.lang.String storeName,
                                   int version)

recordTotalDCR

public void recordTotalDCR(java.lang.String storeName,
                           int version)

recordTimestampRegressionDCRError

public void recordTimestampRegressionDCRError(java.lang.String storeName,
                                              int version)

recordOffsetRegressionDCRError

public void recordOffsetRegressionDCRError(java.lang.String storeName,
                                           int version)

recordTombStoneCreationDCR

public void recordTombStoneCreationDCR(java.lang.String storeName,
                                       int version)

setIngestionTaskPushTimeoutGauge

public void setIngestionTaskPushTimeoutGauge(java.lang.String storeName,
                                             int version)

resetIngestionTaskPushTimeoutGauge

public void resetIngestionTaskPushTimeoutGauge(java.lang.String storeName,
                                               int version)

recordSubscribePrepLatency

public void recordSubscribePrepLatency(java.lang.String storeName,
                                       int version,
                                       double value)

recordProducerCallBackLatency

public void recordProducerCallBackLatency(java.lang.String storeName,
                                          int version,
                                          double value,
                                          long currentTimeMs)

recordConsumedRecordEndToEndProcessingLatency

public void recordConsumedRecordEndToEndProcessingLatency(java.lang.String storeName,
                                                          int version,
                                                          double value,
                                                          long currentTimeMs)

recordVersionTopicEndOffsetRewind

public void recordVersionTopicEndOffsetRewind(java.lang.String storeName,
                                              int version)

recordNearlineProducerToLocalBrokerLatency

public void recordNearlineProducerToLocalBrokerLatency(java.lang.String storeName,
                                                       int version,
                                                       double value,
                                                       long timestamp)

recordNearlineLocalBrokerToReadyToServeLatency

public void recordNearlineLocalBrokerToReadyToServeLatency(java.lang.String storeName,
                                                           int version,
                                                           double value,
                                                           long timestamp)

recordTransformerLatency

public void recordTransformerLatency(java.lang.String storeName,
                                     int version,
                                     double value,
                                     long timestamp)

recordTransformerError

public void recordTransformerError(java.lang.String storeName,
                                   int version,
                                   double value,
                                   long timestamp)

recordMaxIdleTime

public void recordMaxIdleTime(java.lang.String storeName,
                              int version,
                              long idleTimeMs)

registerTransformerLatencySensor

public void registerTransformerLatencySensor(java.lang.String storeName,
                                             int version)

registerTransformerErrorSensor

public void registerTransformerErrorSensor(java.lang.String storeName,
                                           int version)