Package com.linkedin.davinci.listener.response

Interface ReadResponseStats

All Known Implementing Classes:

AbstractReadResponseStats, ComputeResponseStats, ComputeResponseStatsWithSizeProfiling, MultiGetResponseStatsWithSizeProfiling, MultiKeyResponseStats, NoOpReadResponseStats, SingleGetResponseStats

public interface ReadResponseStats

This class is used to accumulate stats associated with a read response. This container is purely for metrics-related work, and should not be used to store any state which is functionally required to achieve the service's goal. Contrast with ReadResponse, which wraps this one. The reason to keep them separate is that the state used for metrics has a slightly longer lifespan than that used for functional purposes, since we record metrics at the very end, after the response is sent back. This allows us to free up the functional state sooner, even while we need to hang on to the metrics state.

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	addKeySize(int size)
void	addReadComputeDeserializationLatency(double latency)
void	addReadComputeLatency(double latency)
void	addReadComputeOutputSize(int size)
void	addReadComputeSerializationLatency(double latency)
void	addValueSize(int size)
long	getCurrentTimeInNanos()
void	incrementCosineSimilarityCount(int count)
void	incrementCountOperatorCount(int count)
void	incrementDotProductCount(int count)
void	incrementHadamardProductCount(int count)
void	incrementMultiChunkLargeValueCount()
void	setStorageExecutionQueueLen(int storageExecutionQueueLen)
void	setStorageExecutionSubmissionWaitTime(double storageExecutionSubmissionWaitTime)

Method Detail

getCurrentTimeInNanos

long getCurrentTimeInNanos()

addDatabaseLookupLatency

void addDatabaseLookupLatency(long startTimeInNanos)

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

Parameters:

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

addReadComputeLatency

void addReadComputeLatency(double latency)

addReadComputeDeserializationLatency

void addReadComputeDeserializationLatency(double latency)

addReadComputeSerializationLatency

void addReadComputeSerializationLatency(double latency)

addKeySize

void addKeySize(int size)

addValueSize

void addValueSize(int size)

addReadComputeOutputSize

void addReadComputeOutputSize(int size)

incrementDotProductCount

void incrementDotProductCount(int count)

incrementCountOperatorCount

void incrementCountOperatorCount(int count)

incrementCosineSimilarityCount

void incrementCosineSimilarityCount(int count)

incrementHadamardProductCount

void incrementHadamardProductCount(int count)

setStorageExecutionSubmissionWaitTime

void setStorageExecutionSubmissionWaitTime(double storageExecutionSubmissionWaitTime)

setStorageExecutionQueueLen

void setStorageExecutionQueueLen(int storageExecutionQueueLen)

incrementMultiChunkLargeValueCount

void incrementMultiChunkLargeValueCount()