Package com.linkedin.davinci.stats

Class AggHostLevelIngestionStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceAggStats<T>

com.linkedin.venice.stats.AbstractVeniceAggStoreStats<HostLevelIngestionStats>

com.linkedin.davinci.stats.AggHostLevelIngestionStats

All Implemented Interfaces:

StoreDataChangedListener

public class AggHostLevelIngestionStats
extends AbstractVeniceAggStoreStats<HostLevelIngestionStats>

Aggregates host-level ingestion statistics across all stores. This class provides aggregate initialization and management support for HostLevelIngestionStats, enabling centralized tracking of ingestion metrics at the host level. It extends AbstractVeniceAggStoreStats to provide automatic aggregation across all stores on the host.

Field Summary

Fields inherited from class com.linkedin.venice.stats.AbstractVeniceAggStats

STORE_NAME_FOR_TOTAL_STAT, storeStats, totalStats

Constructor Summary

Constructors

Constructor	Description
AggHostLevelIngestionStats(io.tehuti.metrics.MetricsRepository metricsRepository, VeniceServerConfig serverConfig, Map<String,StoreIngestionTask> ingestionTaskMap, ReadOnlyStoreRepository metadataRepository, boolean unregisterMetricForDeletedStoreEnabled, Time time)	Constructs an AggHostLevelIngestionStats instance.

Method Summary

Methods inherited from class com.linkedin.venice.stats.AbstractVeniceAggStoreStats

getStoreStats, handleStoreDeleted

Methods inherited from class com.linkedin.venice.stats.AbstractVeniceAggStats

getNullableStoreStats, getTotalStats, setStatsSupplier

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

handleStoreChanged, handleStoreCreated, handleStoreDeleted

Constructor Details

AggHostLevelIngestionStats

public AggHostLevelIngestionStats(io.tehuti.metrics.MetricsRepository metricsRepository,
 VeniceServerConfig serverConfig,
 Map<String,StoreIngestionTask> ingestionTaskMap,
 ReadOnlyStoreRepository metadataRepository,
 boolean unregisterMetricForDeletedStoreEnabled,
 Time time)

Constructs an AggHostLevelIngestionStats instance.

Parameters:

metricsRepository - the metrics repository for recording statistics

serverConfig - the Venice server configuration

ingestionTaskMap - a map of store names to their corresponding ingestion tasks

metadataRepository - the store metadata repository

unregisterMetricForDeletedStoreEnabled - whether to unregister metrics when stores are deleted

time - the time instance for timestamp operations