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
- Direct Known Subclasses:
ComputeResponseStatsWithSizeProfiling
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()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addReadComputeDeserializationLatency(double latency)
void
addReadComputeLatency(double latency)
void
addReadComputeOutputSize(int size)
void
addReadComputeSerializationLatency(double latency)
void
addValueSize(int size)
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 {@param other} instance.void
recordMetrics(ServerHttpRequestStats stats)
Record all metrics, including those which can and cannot be merged.-
Methods inherited from class com.linkedin.venice.listener.response.stats.MultiKeyResponseStats
addKeySize, getRecordCount, setRecordCount
-
Methods inherited from class com.linkedin.venice.listener.response.stats.AbstractReadResponseStats
addDatabaseLookupLatency, getCurrentTimeInNanos, incrementMultiChunkLargeValueCount, isAssembledMultiChunkLargeValue, recordUnmergedMetrics, setStorageExecutionQueueLen, setStorageExecutionSubmissionWaitTime
-
-
-
-
Method Detail
-
addValueSize
public void addValueSize(int size)
- Specified by:
addValueSize
in interfaceReadResponseStats
- Overrides:
addValueSize
in classMultiKeyResponseStats
-
addReadComputeLatency
public void addReadComputeLatency(double latency)
- Specified by:
addReadComputeLatency
in interfaceReadResponseStats
- Overrides:
addReadComputeLatency
in classAbstractReadResponseStats
-
addReadComputeDeserializationLatency
public void addReadComputeDeserializationLatency(double latency)
- Specified by:
addReadComputeDeserializationLatency
in interfaceReadResponseStats
- Overrides:
addReadComputeDeserializationLatency
in classAbstractReadResponseStats
-
addReadComputeSerializationLatency
public void addReadComputeSerializationLatency(double latency)
- Specified by:
addReadComputeSerializationLatency
in interfaceReadResponseStats
- Overrides:
addReadComputeSerializationLatency
in classAbstractReadResponseStats
-
addReadComputeOutputSize
public void addReadComputeOutputSize(int size)
- Specified by:
addReadComputeOutputSize
in interfaceReadResponseStats
- Overrides:
addReadComputeOutputSize
in classAbstractReadResponseStats
-
incrementDotProductCount
public void incrementDotProductCount(int count)
- Specified by:
incrementDotProductCount
in interfaceReadResponseStats
- Overrides:
incrementDotProductCount
in classAbstractReadResponseStats
-
incrementCountOperatorCount
public void incrementCountOperatorCount(int count)
- Specified by:
incrementCountOperatorCount
in interfaceReadResponseStats
- Overrides:
incrementCountOperatorCount
in classAbstractReadResponseStats
-
incrementCosineSimilarityCount
public void incrementCosineSimilarityCount(int count)
- Specified by:
incrementCosineSimilarityCount
in interfaceReadResponseStats
- Overrides:
incrementCosineSimilarityCount
in classAbstractReadResponseStats
-
incrementHadamardProductCount
public void incrementHadamardProductCount(int count)
- Specified by:
incrementHadamardProductCount
in interfaceReadResponseStats
- Overrides:
incrementHadamardProductCount
in classAbstractReadResponseStats
-
recordMetrics
public void recordMetrics(ServerHttpRequestStats stats)
Description copied from interface:ReadResponseStatsRecorder
Record all metrics, including those which can and cannot be merged.- Specified by:
recordMetrics
in interfaceReadResponseStatsRecorder
- Overrides:
recordMetrics
in classAbstractReadResponseStats
- Parameters:
stats
- theServerHttpRequestStats
object to record stats into.
-
merge
public void merge(ReadResponseStatsRecorder other)
Description copied from interface:ReadResponseStatsRecorder
Merge the stats contained in this instance with those contained in the {@param other} instance.- Specified by:
merge
in interfaceReadResponseStatsRecorder
- Overrides:
merge
in classMultiKeyResponseStats
- Parameters:
other
- instance to merge with.
-
-