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

Class AbstractReadResponseStats

java.lang.Object

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

All Implemented Interfaces:

ReadResponseStats, ReadResponseStatsRecorder

Direct Known Subclasses:

MultiKeyResponseStats, SingleGetResponseStats

public abstract class AbstractReadResponseStats
extends Object
implements ReadResponseStats, ReadResponseStatsRecorder

This abstract class is the container for response stats. The stats can be accumulated via the APIs provided by ReadResponseStats, and then recorded using the API from ReadResponseStatsRecorder. The class hierarchy aims to minimize the amount of state required for any given response, based on its type and relevant server configs: - AbstractReadResponseStats +-- SingleGetResponseStats +-- MultiKeyResponseStats +-- MultiGetResponseStatsWithSizeProfiling +-- ComputeResponseStats +-- ComputeResponseStatsWithSizeProfiling

Field Summary

Fields

Modifier and Type	Field	Description
protected int	multiChunkLargeValueCount

Constructor Summary

Constructors

Constructor	Description
AbstractReadResponseStats()

Method Summary

Modifier and Type	Method	Description
void	addDatabaseLookupLatency(long startTimeInNanos)	The implementer is responsible for doing the subtraction between the current time and the start time.
void	addReadComputeDeserializationLatency(double latency)
void	addReadComputeLatency(double latency)
void	addReadComputeOutputSize(int size)
void	addReadComputeSerializationLatency(double latency)
long	getCurrentTimeInNanos()
protected abstract int	getRecordCount()
void	incrementCosineSimilarityCount(int count)
void	incrementCountOperatorCount(int count)
void	incrementDotProductCount(int count)
void	incrementHadamardProductCount(int count)
void	incrementMultiChunkLargeValueCount()
protected boolean	isAssembledMultiChunkLargeValue()
void	merge(ReadResponseStatsRecorder other)	Merge the stats contained in this instance with those contained in the instance.
void	recordMetrics(ServerHttpRequestStats stats)	Record all metrics, including those which can and cannot be merged.
void	recordUnmergedMetrics(ServerHttpRequestStats stats)	Record metrics which are not mergeable by the ReadResponseStatsRecorder.merge(ReadResponseStatsRecorder) function.
void	setStorageExecutionQueueLen(int storageExecutionQueueLen)
void	setStorageExecutionSubmissionWaitTime(double storageExecutionSubmissionWaitTime)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.davinci.listener.response.ReadResponseStats

addKeySize, addValueSize

Field Details

multiChunkLargeValueCount

protected int multiChunkLargeValueCount

Constructor Details

AbstractReadResponseStats

public AbstractReadResponseStats()

Method Details

getRecordCount

protected abstract int getRecordCount()

getCurrentTimeInNanos

public long getCurrentTimeInNanos()

Specified by:

getCurrentTimeInNanos in interface ReadResponseStats

addDatabaseLookupLatency

public void addDatabaseLookupLatency(long startTimeInNanos)

Description copied from interface: ReadResponseStats

The implementer is responsible for doing the subtraction between the current time and the start time.

Specified by:

addDatabaseLookupLatency in interface ReadResponseStats

Parameters:

startTimeInNanos - the timestamp in nanoseconds of beginning of the period to measure.

setStorageExecutionSubmissionWaitTime

public void setStorageExecutionSubmissionWaitTime(double storageExecutionSubmissionWaitTime)

Specified by:

setStorageExecutionSubmissionWaitTime in interface ReadResponseStats

setStorageExecutionQueueLen

public void setStorageExecutionQueueLen(int storageExecutionQueueLen)

Specified by:

setStorageExecutionQueueLen in interface ReadResponseStats

incrementMultiChunkLargeValueCount

public void incrementMultiChunkLargeValueCount()

Specified by:

incrementMultiChunkLargeValueCount in interface ReadResponseStats

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 interface ReadResponseStatsRecorder

Parameters:

stats - the ServerHttpRequestStats object to record stats into.

recordUnmergedMetrics

public void recordUnmergedMetrics(ServerHttpRequestStats stats)

Description copied from interface: ReadResponseStatsRecorder

Record metrics which are not mergeable by the ReadResponseStatsRecorder.merge(ReadResponseStatsRecorder) function.

Specified by:

recordUnmergedMetrics in interface ReadResponseStatsRecorder

Parameters:

stats - the ServerHttpRequestStats 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 instance.

Specified by:

merge in interface ReadResponseStatsRecorder

Parameters:

other - instance to merge with.

isAssembledMultiChunkLargeValue

protected boolean isAssembledMultiChunkLargeValue()

addReadComputeLatency

public void addReadComputeLatency(double latency)

Specified by:

addReadComputeLatency in interface ReadResponseStats

addReadComputeDeserializationLatency

public void addReadComputeDeserializationLatency(double latency)

Specified by:

addReadComputeDeserializationLatency in interface ReadResponseStats

addReadComputeSerializationLatency

public void addReadComputeSerializationLatency(double latency)

Specified by:

addReadComputeSerializationLatency in interface ReadResponseStats

addReadComputeOutputSize

public void addReadComputeOutputSize(int size)

Specified by:

addReadComputeOutputSize in interface ReadResponseStats

incrementDotProductCount

public void incrementDotProductCount(int count)

Specified by:

incrementDotProductCount in interface ReadResponseStats

incrementCountOperatorCount

public void incrementCountOperatorCount(int count)

Specified by:

incrementCountOperatorCount in interface ReadResponseStats

incrementCosineSimilarityCount

public void incrementCosineSimilarityCount(int count)

Specified by:

incrementCosineSimilarityCount in interface ReadResponseStats

incrementHadamardProductCount

public void incrementHadamardProductCount(int count)

Specified by:

incrementHadamardProductCount in interface ReadResponseStats