Package com.linkedin.venice.listener.response.stats

Class MultiKeyResponseStats

java.lang.Object

com.linkedin.venice.listener.response.stats.AbstractReadResponseStats

com.linkedin.venice.listener.response.stats.MultiKeyResponseStats

All Implemented Interfaces:

ReadResponseStats, ReadResponseStatsRecorder

Direct Known Subclasses:

ComputeResponseStats

public class MultiKeyResponseStats
extends AbstractReadResponseStats

Field Summary

Fields inherited from class com.linkedin.venice.listener.response.stats.AbstractReadResponseStats

multiChunkLargeValueCount

Constructor Summary

Constructors

Constructor	Description
MultiKeyResponseStats(int maxKeyCount)

Method Summary

Modifier and Type	Method	Description
void	addKeySize(int size)
void	addValueSize(int size)
protected int	getRecordCount()
void	merge(ReadResponseStatsRecorder other)	Merge the stats contained in this instance with those contained in the instance.
void	recordUnmergedMetrics(ServerHttpRequestStats stats, HttpResponseStatusEnum statusEnum, HttpResponseStatusCodeCategory statusCategory, VeniceResponseStatusCategory veniceCategory)	N.B.: The per-key/value sizes are treated as non-mergeable; each chunk records its own sizes via recordUnmergedMetrics(com.linkedin.venice.stats.ServerHttpRequestStats, com.linkedin.venice.stats.dimensions.HttpResponseStatusEnum, com.linkedin.venice.stats.dimensions.HttpResponseStatusCodeCategory, com.linkedin.venice.stats.dimensions.VeniceResponseStatusCategory).
void	setRecordCount(int count)

Methods inherited from class com.linkedin.venice.listener.response.stats.AbstractReadResponseStats

addDatabaseLookupLatency, addReadComputeDeserializationLatency, addReadComputeLatency, addReadComputeSerializationLatency, getCurrentTimeInNanos, getKeyNotFoundCount, incrementCosineSimilarityCount, incrementCountOperatorCount, incrementDotProductCount, incrementHadamardProductCount, incrementKeyNotFoundCount, incrementMultiChunkLargeValueCount, isAssembledMultiChunkLargeValue, recordMetrics, setStorageExecutionQueueLen, setStorageExecutionSubmissionWaitTime

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.listener.response.stats.ReadResponseStatsRecorder

recordMetrics

Constructor Details

MultiKeyResponseStats

public MultiKeyResponseStats(int maxKeyCount)

Method Details

addKeySize

public void addKeySize(int size)

addValueSize

public void addValueSize(int size)

setRecordCount

public void setRecordCount(int count)

getRecordCount

protected int getRecordCount()

Specified by:

getRecordCount in class AbstractReadResponseStats

recordUnmergedMetrics

public void recordUnmergedMetrics(ServerHttpRequestStats stats,
 HttpResponseStatusEnum statusEnum,
 HttpResponseStatusCodeCategory statusCategory,
 VeniceResponseStatusCategory veniceCategory)

N.B.: The per-key/value sizes are treated as non-mergeable; each chunk records its own sizes via recordUnmergedMetrics(com.linkedin.venice.stats.ServerHttpRequestStats, com.linkedin.venice.stats.dimensions.HttpResponseStatusEnum, com.linkedin.venice.stats.dimensions.HttpResponseStatusCodeCategory, com.linkedin.venice.stats.dimensions.VeniceResponseStatusCategory). Only the aggregate recordCount is merged.

Specified by:

recordUnmergedMetrics in interface ReadResponseStatsRecorder

Overrides:

recordUnmergedMetrics in class AbstractReadResponseStats

Parameters:

stats - the ServerHttpRequestStats object to record stats into.

statusEnum - the HTTP response status enum for OTel dimension tagging.

statusCategory - the HTTP response status code category for OTel dimension tagging.

veniceCategory - the Venice response status category for OTel dimension tagging.

merge

public void merge(ReadResponseStatsRecorder other)

Description copied from interface: ReadResponseStatsRecorder

Merge the stats contained in this instance with those contained in the instance.

Specified by:

merge in interface ReadResponseStatsRecorder

Overrides:

merge in class AbstractReadResponseStats

Parameters:

other - instance to merge with.