Package com.linkedin.davinci.listener.response

Class ReadResponse

    • Constructor Detail

      • ReadResponse

        public ReadResponse()

    • Method Detail

      • setCompressionStrategy

        public void setCompressionStrategy​(CompressionStrategy compressionStrategy)

      • setStreamingResponse

        public void setStreamingResponse()

      • isStreamingResponse

        public boolean isStreamingResponse()

      • setDatabaseLookupLatency

        public void setDatabaseLookupLatency​(double latency)

      • addDatabaseLookupLatency

        public void addDatabaseLookupLatency​(double latency)

      • getDatabaseLookupLatency

        public double getDatabaseLookupLatency()

      • setReadComputeLatency

        public void setReadComputeLatency​(double latency)

      • addReadComputeLatency

        public void addReadComputeLatency​(double latency)

      • getReadComputeLatency

        public double getReadComputeLatency()

      • setReadComputeDeserializationLatency

        public void setReadComputeDeserializationLatency​(double latency)

      • addReadComputeDeserializationLatency

        public void addReadComputeDeserializationLatency​(double latency)

      • setKeySizeList

        public void setKeySizeList​(it.unimi.dsi.fastutil.ints.IntList keySizeList)

      • setValueSizeList

        public void setValueSizeList​(it.unimi.dsi.fastutil.ints.IntList valueSizeList)

      • getReadComputeDeserializationLatency

        public double getReadComputeDeserializationLatency()

      • setReadComputeSerializationLatency

        public void setReadComputeSerializationLatency​(double latency)

      • addReadComputeSerializationLatency

        public void addReadComputeSerializationLatency​(double latency)

      • addValueSize

        public void addValueSize​(int size)

      • getValueSize

        public int getValueSize()

      • addReadComputeOutputSize

        public void addReadComputeOutputSize​(int size)

      • getReadComputeOutputSize

        public int getReadComputeOutputSize()

      • incrementDotProductCount

        public void incrementDotProductCount​(int count)

      • incrementCountOperatorCount

        public void incrementCountOperatorCount​(int count)

      • incrementCosineSimilarityCount

        public void incrementCosineSimilarityCount​(int count)

      • incrementHadamardProductCount

        public void incrementHadamardProductCount​(int count)

      • getReadComputeSerializationLatency

        public double getReadComputeSerializationLatency()

      • getStorageExecutionHandlerSubmissionWaitTime

        public double getStorageExecutionHandlerSubmissionWaitTime()

      • setStorageExecutionSubmissionWaitTime

        public void setStorageExecutionSubmissionWaitTime​(double storageExecutionSubmissionWaitTime)

      • setRCU

        public void setRCU​(int rcu)
        Set the read compute unit (RCU) cost for this response's request
        Parameters:
        rcu -

      • getRCU

        public int getRCU()
        Get the read compute unit (RCU) for this response's request
        Returns:

      • getStorageExecutionQueueLen

        public int getStorageExecutionQueueLen()

      • setStorageExecutionQueueLen

        public void setStorageExecutionQueueLen​(int storageExecutionQueueLen)

      • incrementMultiChunkLargeValueCount

        public void incrementMultiChunkLargeValueCount()

      • getMultiChunkLargeValueCount

        public int getMultiChunkLargeValueCount()

      • isFound

        public boolean isFound()

      • getKeySizeList

        public it.unimi.dsi.fastutil.ints.IntList getKeySizeList()

      • getValueSizeList

        public it.unimi.dsi.fastutil.ints.IntList getValueSizeList()

      • getDotProductCount

        public int getDotProductCount()

      • getCosineSimilarityCount

        public int getCosineSimilarityCount()

      • getHadamardProductCount

        public int getHadamardProductCount()

      • getCountOperatorCount

        public int getCountOperatorCount()

      • getRecordCount

        public abstract int getRecordCount()

      • getResponseBody

        public abstract io.netty.buffer.ByteBuf getResponseBody()

      • getResponseSchemaIdHeader

        public abstract int getResponseSchemaIdHeader()