Package com.linkedin.davinci.stats

Class AggBlobTransferStats

java.lang.Object

com.linkedin.davinci.stats.AggBlobTransferStats

public class AggBlobTransferStats
extends Object

Aggregates blob transfer statistics across both versioned and host-level metrics. This class serves as a facade that coordinates recording blob transfer events to both version-specific statistics and host-level aggregated statistics.

Constructor Summary

Constructors

Constructor	Description
AggBlobTransferStats(AggVersionedBlobTransferStats aggVersionedBlobTransferStats, AggHostLevelIngestionStats aggHostLevelIngestionStats)	Constructs an AggBlobTransferStats instance.

Method Summary

Modifier and Type	Method	Description
AggVersionedBlobTransferStats	getAggVersionedBlobTransferStats()	Returns the versioned blob transfer statistics aggregator.
void	recordBlobTransferBytesReceived(String storeName, int version, long value)	Records the number of bytes received during a blob transfer operation.
void	recordBlobTransferBytesSent(String storeName, int version, long value)	Records the number of bytes sent during a blob transfer operation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AggBlobTransferStats

public AggBlobTransferStats(AggVersionedBlobTransferStats aggVersionedBlobTransferStats,
 AggHostLevelIngestionStats aggHostLevelIngestionStats)

Constructs an AggBlobTransferStats instance.

Parameters:

aggVersionedBlobTransferStats - the versioned blob transfer statistics aggregator

aggHostLevelIngestionStats - the host-level ingestion statistics aggregator

Method Details

recordBlobTransferBytesSent

public void recordBlobTransferBytesSent(String storeName,
 int version,
 long value)

Records the number of bytes sent during a blob transfer operation. This method updates both version-specific and host-level statistics.

Parameters:

storeName - the name of the Venice store

version - the version number of the store

value - the number of bytes sent

recordBlobTransferBytesReceived

public void recordBlobTransferBytesReceived(String storeName,
 int version,
 long value)

Records the number of bytes received during a blob transfer operation. This method updates both version-specific and host-level statistics.

Parameters:

storeName - the name of the Venice store

version - the version number of the store

value - the number of bytes received

getAggVersionedBlobTransferStats

public AggVersionedBlobTransferStats getAggVersionedBlobTransferStats()

Returns the versioned blob transfer statistics aggregator.

Returns:

the AggVersionedBlobTransferStats instance