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

Class ComputeResponseStats

java.lang.Object

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

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

com.linkedin.venice.listener.response.stats.ComputeResponseStats

All Implemented Interfaces:

ReadResponseStats, ReadResponseStatsRecorder

public class ComputeResponseStats
extends MultiKeyResponseStats

Field Summary

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

multiChunkLargeValueCount

Constructor Summary

Constructors

Constructor	Description
ComputeResponseStats(int maxKeyCount)

Method Summary

Modifier and Type	Method	Description
void	addReadComputeDeserializationLatency(double latency)
void	addReadComputeLatency(double latency)
void	addReadComputeSerializationLatency(double latency)
void	incrementCosineSimilarityCount(int count)
void	incrementCountOperatorCount(int count)
void	incrementDotProductCount(int count)
void	incrementHadamardProductCount(int count)
void	merge(ReadResponseStatsRecorder other)	Merge the stats contained in this instance with those contained in the instance.
void	recordMetrics(ServerHttpRequestStats stats, HttpResponseStatusEnum statusEnum, HttpResponseStatusCodeCategory statusCategory, VeniceResponseStatusCategory veniceCategory)	Record all metrics, including those which can and cannot be merged.

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

addKeySize, addValueSize, getRecordCount, recordUnmergedMetrics, setRecordCount

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

addDatabaseLookupLatency, getCurrentTimeInNanos, getKeyNotFoundCount, incrementKeyNotFoundCount, incrementMultiChunkLargeValueCount, isAssembledMultiChunkLargeValue, 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

ComputeResponseStats

public ComputeResponseStats(int maxKeyCount)

Method Details

addReadComputeLatency

public void addReadComputeLatency(double latency)

Specified by:

addReadComputeLatency in interface ReadResponseStats

Overrides:

addReadComputeLatency in class AbstractReadResponseStats

addReadComputeDeserializationLatency

public void addReadComputeDeserializationLatency(double latency)

Specified by:

addReadComputeDeserializationLatency in interface ReadResponseStats

Overrides:

addReadComputeDeserializationLatency in class AbstractReadResponseStats

addReadComputeSerializationLatency

public void addReadComputeSerializationLatency(double latency)

Specified by:

addReadComputeSerializationLatency in interface ReadResponseStats

Overrides:

addReadComputeSerializationLatency in class AbstractReadResponseStats

incrementDotProductCount

public void incrementDotProductCount(int count)

Specified by:

incrementDotProductCount in interface ReadResponseStats

Overrides:

incrementDotProductCount in class AbstractReadResponseStats

incrementCountOperatorCount

public void incrementCountOperatorCount(int count)

Specified by:

incrementCountOperatorCount in interface ReadResponseStats

Overrides:

incrementCountOperatorCount in class AbstractReadResponseStats

incrementCosineSimilarityCount

public void incrementCosineSimilarityCount(int count)

Specified by:

incrementCosineSimilarityCount in interface ReadResponseStats

Overrides:

incrementCosineSimilarityCount in class AbstractReadResponseStats

incrementHadamardProductCount

public void incrementHadamardProductCount(int count)

Specified by:

incrementHadamardProductCount in interface ReadResponseStats

Overrides:

incrementHadamardProductCount in class AbstractReadResponseStats

recordMetrics

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

Description copied from interface: ReadResponseStatsRecorder

Record all metrics, including those which can and cannot be merged.

Specified by:

recordMetrics in interface ReadResponseStatsRecorder

Overrides:

recordMetrics 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 MultiKeyResponseStats

Parameters:

other - instance to merge with.